- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Kistner (0.19 sec)
-
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 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/log/uds.go
if sockAddress == "" { return nil } log.Info("Start a UDS server for CNI plugin logs") unixListener, err := uds.NewListener(sockAddress) if err != nil { return fmt.Errorf("failed to create UDS listener: %v", err) } go func() { if err := l.loggingServer.Serve(unixListener); network.IsUnexpectedListenerError(err) { log.Errorf("Error running UDS log server: %v", err) } }() go func() { <-stop
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/pkg/monitoring/monitoring.go
"istio.io/istio/pkg/network" ) func SetupMonitoring(port int, path string, stop <-chan struct{}) { if port <= 0 { return } mux := http.NewServeMux() var listener net.Listener var err error if listener, err = net.Listen("tcp", fmt.Sprintf(":%d", port)); err != nil { log.Errorf("unable to listen on socket: %v", err) return } exporter, err := monitoring.RegisterPrometheusExporter(nil, nil)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jun 09 07:54:01 GMT 2023 - 1.5K bytes - Viewed (0) -
istioctl/pkg/util/configdump/endpoint.go
// limitations under the License. package configdump import ( admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3" ) // GetEndpointsConfigDump retrieves the listener config dump from the ConfigDump func (w *Wrapper) GetEndpointsConfigDump() (*admin.EndpointsConfigDump, error) { endpointsDumpAny, err := w.getSection(endpoints) if err != nil { return nil, nil }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Oct 24 14:14:42 GMT 2023 - 1.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
if err != nil { return fmt.Errorf("failed to create CNI listener: %v", err) } go func() { err := s.cniListenServer.Serve(unixListener) select { case <-s.ctx.Done(): // ctx done, we should silently go away return default: // If the cniListener exits, at least we should record an error log log.Errorf("CNI listener server exiting unexpectedly: %v", err) } }()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
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 May 01 22:53:12 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.5K bytes - Viewed (1) -
istioctl/pkg/writer/envoy/configdump/listener_test.go
Type: "TCP", }, inListener: &listener.Listener{ FilterChains: []*listener.FilterChain{{ Filters: []*listener.Filter{{ Name: wellknown.TCPProxy, }}, }}, }, expect: true, }, { desc: "unknown-type", inFilter: &ListenerFilter{ Type: "UNKNOWN", }, inListener: &listener.Listener{ FilterChains: []*listener.FilterChain{{
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 4.1K bytes - Viewed (0) -
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 May 01 22:53:12 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 6K bytes - Viewed (0) -
istioctl/pkg/writer/compare/listener.go
Kuat <******@****.***> 1712262548 -0700
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
John Howard <******@****.***> 1707429512 -0800
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0)