Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Kistner (0.17 sec)

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

    		l := &listener.Listener{}
    		err = dal[i].ActiveState.Listener.UnmarshalTo(l)
    		if err != nil {
    			return false
    		}
    		name := l.Name
    		err = dal[j].ActiveState.Listener.UnmarshalTo(l)
    		if err != nil {
    			return false
    		}
    		return name < l.Name
    	})
    	if stripVersions {
    		for i := range dal {
    			dal[i].ActiveState.VersionInfo = ""
    			dal[i].ActiveState.LastUpdated = nil
    Go
    - Registered: Wed Apr 24 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

    	filterChains []*filterChain
    }
    
    func getFilterConfig(filter *listener.Filter, out proto.Message) error {
    	switch c := filter.ConfigType.(type) {
    	case *listener.Filter_TypedConfig:
    		if err := c.TypedConfig.UnmarshalTo(out); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func getHTTPConnectionManager(filter *listener.Filter) *hcm.HttpConnectionManager {
    	cm := &hcm.HttpConnectionManager{}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  3. 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 Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  4. internal/http/listener.go

    		}
    	case <-listener.ctx.Done():
    	}
    	return nil, syscall.EINVAL
    }
    
    // Close - closes underneath all TCP listeners.
    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.tcpListeners {
    		listener.tcpListeners[i].Close()
    	}
    
    	return nil
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/listener.go

    		return false
    	}
    	return true
    }
    
    func getFilterChains(l *listener.Listener) []*listener.FilterChain {
    	res := l.FilterChains
    	if l.DefaultFilterChain != nil {
    		res = append(res, l.DefaultFilterChain)
    	}
    	return res
    }
    
    // retrieveListenerType classifies a Listener as HTTP|TCP|HTTP+TCP|UNKNOWN
    func retrieveListenerType(l *listener.Listener) string {
    	nHTTP := 0
    	nTCP := 0
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/compare/listener.go

    Kuat <******@****.***> 1712262548 -0700
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Apr 04 20:29:08 GMT 2024
    - 2K bytes
    - Viewed (0)
Back to top