- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 104 for listener (0.08 sec)
-
internal/http/listener.go
return } listener = &httpListener{ listeners: listeners, acceptCh: make(chan acceptResult, len(listeners)), opts: opts, } listener.ctx, listener.ctxCanceler = context.WithCancel(ctx) if opts.Trace != nil { opts.Trace(fmt.Sprint("opening ", len(listener.listeners), " listeners")) } listener.start() return
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5.6K bytes - Viewed (0) -
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 {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 2K bytes - Viewed (0) -
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 {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 18.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
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 2.5K bytes - Viewed (0) -
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{}{}
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Mon Sep 11 15:29:30 UTC 2023 - 6K bytes - Viewed (0) -
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) }
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/grid/debug.go
listeners = append(listeners, l) } return } func startHTTPServer(listener net.Listener, handler http.Handler) (server *httptest.Server) { server = httptest.NewUnstartedServer(handler) server.Config.Addr = listener.Addr().String() server.Listener = listener server.Start() return server } func dummyRequestValidate(r *http.Request) error { return nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 4.4K bytes - Viewed (0) -
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{{
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Mon Sep 11 15:29:30 UTC 2023 - 4.1K bytes - Viewed (0) -
cni/pkg/monitoring/monitoring.go
) 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) if err != nil {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Fri Jun 09 07:54:01 UTC 2023 - 1.5K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/testdata/config_dump_summary.txt
NAME ADDRESSES PORT MATCH DESTINATION listener/main_internal 0 ALL Cluster: inbound-vip|8100|http|httpbin.default.svc.cluster.local listener/main_internal 0 ALL Cluster: inbound-vip|8000|http|httpbin.default.svc.cluster.local listener/main_internal 0 ALL Cluster: encap listener/main_internal 0 ALL Cluster: encap listener/ 0.0.0.0 15021 ALL Inline Route: /healthz/ready*
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Jan 03 23:08:06 UTC 2024 - 2.2K bytes - Viewed (0)