- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 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 Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K 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 Apr 17 22:53:10 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 6K bytes - Viewed (0) -
internal/http/listener_test.go
} } else if listenErrs[i] == nil { t.Fatalf("Test %d: listenErrs[%d]: expected = %v, got = <nil>", testIdx+1, i, expectedListenErr) } } if listener != nil { listener.Close() } } } func TestHTTPListenerStartClose(t *testing.T) { if runtime.GOOS == "windows" { t.Skip() } nonLoopBackIP := getNonLoopBackIP(t)
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Mon Jun 12 16:09:28 GMT 2023 - 11.8K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
// Test deadlineconn handles read timeout properly by reading two messages beyond deadline. func TestBuffConnReadTimeout(t *testing.T) { l, err := net.Listen("tcp", "localhost:0") if err != nil { t.Fatalf("unable to create listener. %v", err) } defer l.Close() serverAddr := l.Addr().String() tcpListener, ok := l.(*net.TCPListener) if !ok { t.Fatalf("failed to assert to net.TCPListener") } var wg sync.WaitGroup
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
if l.ActiveState == nil { continue } // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info. l.ActiveState.Listener.TypeUrl = v3.ListenerType listenerTyped := &listener.Listener{} err = l.ActiveState.Listener.UnmarshalTo(listenerTyped) if err != nil { return nil, err } if listenerTyped.Name == model.VirtualInboundListenerName {
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
if err != nil { return nil, fmt.Errorf("failed to listen unix: %w", err) } return &ztunnelServer{ listener: l, conns: &connMgr{ connectionSet: map[*ZtunnelConnection]struct{}{}, }, pods: pods, }, nil } func (z *ztunnelServer) Close() error { return z.listener.Close() } func (z *ztunnelServer) Run(ctx context.Context) { context.AfterFunc(ctx, func() { _ = z.Close() })
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer.go
if err != nil { return nil, fmt.Errorf("failed to get dynamic listener dump: %s", err) } return &Analyzer{listenerDump: listeners}, nil } // Print print the analysis results. func (a *Analyzer) Print(writer io.Writer) { var listeners []*listener.Listener for _, l := range a.listenerDump.DynamicListeners { listenerTyped := &listener.Listener{} // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer_test.go
{ Name: "10.102.11.148_15021", ActiveState: &envoy_admin.ListenersConfigDump_DynamicListenerState{ VersionInfo: "2023-06-20T09:07:41Z/3", Listener: &any1.Any{ TypeUrl: "type.googleapis.com/envoy.config.listener.v3.Listener", }, LastUpdated: timestamppb.Now(), }, ClientStatus: 453, }, }, }, } tests := []struct { name string
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Mon Jul 24 04:04:34 GMT 2023 - 2.8K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
wantException: false, }, { // supplying valid pod name retrieves Envoy config (fails because we don't check in Envoy config unit tests) execClientConfig: loggingConfig, args: strings.Split("listener httpbin-794b576b6c-qx6pf", " "), expectedString: `config dump has no configuration type`, wantException: true, },
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K 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 Apr 17 22:53:10 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0)