- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for Kistner (0.22 sec)
-
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/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/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 May 01 22:53:12 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: &anypb.Any{ TypeUrl: "type.googleapis.com/envoy.config.listener.v3.Listener", }, LastUpdated: timestamppb.Now(), }, ClientStatus: 453, }, }, }, } tests := []struct { name string
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 2.8K 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) -
internal/grid/connection_test.go
} t.Logf("host %q should connect to %d hosts", hosts[x], should) } } func startServer(t testing.TB, listener net.Listener, handler http.Handler) (server *httptest.Server) { t.Helper() server = httptest.NewUnstartedServer(handler) server.Config.Addr = listener.Addr().String() server.Listener = listener server.Start() // t.Cleanup(server.Close) t.Log("Started server on", server.Config.Addr, "URL:", server.URL)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 6K 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 28 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
internal/http/check_port_others.go
defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.5K 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 May 01 22:53:12 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K bytes - Viewed (0)