Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for util (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top