Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for Kistner (0.21 sec)

  1. 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)
  2. 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 21 19:28:08 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. istioctl/pkg/proxyconfig/proxyconfig.go

    	var podName, podNamespace string
    
    	listenerConfigCmd := &cobra.Command{
    		Use:   "listener [<type>/]<name>[.<namespace>]",
    		Short: "Retrieves listener configuration for the Envoy in the specified pod",
    		Long:  `Retrieve information about listener configuration for the Envoy instance in the specified pod.`,
    		Example: `  # Retrieve summary about listener configuration for a given pod from Envoy.
      istioctl proxy-config listeners <pod-name[.namespace]>
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 16 03:28:36 GMT 2024
    - 48K bytes
    - Viewed (0)
  6. cmd/metacache-set.go

    	// If false only main directory will be scanned.
    	// Should always be true if Separator is n SlashSeparator.
    	Recursive bool
    
    	// Separator to use.
    	Separator string
    
    	// Create indicates that the lister should not attempt to load an existing cache.
    	Create bool
    
    	// Include pure directories.
    	IncludeDirectories bool
    
    	// Transient is set if the cache is transient due to an error or being a reserved bucket.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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 May 01 22:53:12 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
  10. 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)
Back to top