- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for util (0.12 sec)
-
istioctl/pkg/writer/envoy/configdump/listener.go
tcp "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/tcp_proxy/v3" "sigs.k8s.io/yaml" "istio.io/istio/istioctl/pkg/util/proto" "istio.io/istio/pilot/pkg/networking/util" "istio.io/istio/pilot/pkg/util/protoconv" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/wellknown" ) const (
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
istioctl/pkg/writer/compare/listener.go
package compare import ( "bytes" "fmt" "github.com/pmezard/go-difflib/difflib" // Force import protos _ "istio.io/istio/pilot/pkg/xds/filters" "istio.io/istio/pkg/util/protomarshal" ) // ListenerDiff prints a diff between Istiod and Envoy listeners to the passed writer func (c *Comparator) ListenerDiff() error { envoyBytes, istiodBytes := &bytes.Buffer{}, &bytes.Buffer{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
internal/http/listener.go
select { case listener.acceptCh <- result: // Successfully written to acceptCh return true case <-listener.ctx.Done(): return false } } // Closure to handle TCPListener until done channel is closed. handleListener := func(idx int, listener net.Listener) { for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0)