Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for listeners (0.18 sec)

  1. istioctl/pkg/util/configdump/listener.go

    package configdump
    
    import (
    	"sort"
    
    	admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3"
    	listener "github.com/envoyproxy/go-control-plane/envoy/config/listener/v3"
    
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    )
    
    // GetDynamicListenerDump retrieves a listener dump with just dynamic active listeners in it
    func (w *Wrapper) GetDynamicListenerDump(stripVersions bool) (*admin.ListenersConfigDump, error) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 2.5K bytes
    - Viewed (1)
  2. istioctl/pkg/authz/listener.go

    		return "", ""
    	}
    	return fmt.Sprintf("%s.%s", parts[2], parts[1]), parts[3]
    }
    
    // Print prints the AuthorizationPolicy in the listener.
    func Print(writer io.Writer, listeners []*listener.Listener) {
    	parsedListeners := parse(listeners)
    	if parsedListeners == nil {
    		return
    	}
    
    	actionToPolicy := map[rbacpb.RBAC_Action]map[string]struct{}{}
    	policyToRule := map[string]map[string]struct{}{}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  3. internal/http/listener.go

    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.listeners {
    		listener.listeners[i].Close()
    	}
    
    	return nil
    }
    
    // Addr - net.Listener interface compatible method returns net.Addr.  In case of multiple TCP listeners, it returns '0.0.0.0' as IP address.
    func (listener *httpListener) Addr() (addr net.Addr) {
    	addr = listener.listeners[0].Addr()
    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)
  4. istioctl/pkg/writer/envoy/configdump/listener.go

    		if l.Listener != nil {
    			listenerTyped := &listener.Listener{}
    			// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    			l.Listener.TypeUrl = v3.ListenerType
    			err = l.Listener.UnmarshalTo(listenerTyped)
    			if err != nil {
    				return nil, fmt.Errorf("unmarshal listener: %v", err)
    			}
    			listeners = append(listeners, listenerTyped)
    		}
    	}
    	if len(listeners) == 0 {
    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)
  5. cni/pkg/pluginlistener/listener.go

    	}
    
    	var err error
    	listener, err := net.Listen("unix", path)
    	if err != nil {
    		return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err)
    	}
    
    	// Update file permission so that cni plugin has permission to access it.
    	if _, err := os.Stat(path); err != nil {
    		return nil, fmt.Errorf("cni listener file %q doesn't exist", path)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/compare/listener.go

    	}
    	diff := difflib.UnifiedDiff{
    		FromFile: "Istiod Listeners",
    		A:        difflib.SplitLines(istiodBytes.String()),
    		ToFile:   "Envoy Listeners",
    		B:        difflib.SplitLines(envoyBytes.String()),
    		Context:  c.context,
    	}
    	text, err := difflib.GetUnifiedDiffString(diff)
    	if err != nil {
    		return err
    	}
    	if text != "" {
    		fmt.Fprintln(c.w, "Listeners Don't Match")
    		fmt.Fprintln(c.w, text)
    	} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 04 20:29:08 GMT 2024
    - 2K bytes
    - Viewed (0)
Back to top