Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for int32 (0.18 sec)

  1. istioctl/pkg/writer/envoy/clusters/clusters.go

    		return false
    	}
    	if e.Cluster != "" && !strings.EqualFold(cluster, e.Cluster) {
    		return false
    	}
    	status := retrieveEndpointStatus(host)
    	if e.Status != "" && !strings.EqualFold(core.HealthStatus_name[int32(status)], e.Status) {
    		return false
    	}
    	return true
    }
    
    // PrintEndpointsSummary prints just the endpoints config summary to the ConfigWriter stdout
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 5.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server_test.go

    // Custom "wait group with timeout" for waiting for fakeServer calls in a goroutine to finish
    type WaitGroup struct {
    	count int32
    	done  chan struct{}
    }
    
    func NewWaitGroup() *WaitGroup {
    	return &WaitGroup{
    		done: make(chan struct{}),
    	}
    }
    
    func NewWaitForNCalls(t *testing.T, n int32) (*WaitGroup, func()) {
    	wg := &WaitGroup{
    		done: make(chan struct{}),
    	}
    
    	wg.Add(n)
    	return wg, func() {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/fakes_test.go

    	return &fakeFileFakeFds{File: f, fd: 0}
    }
    
    type fakeIptablesDeps struct {
    	AddRouteErr           error
    	AddInpodMarkIPRuleCnt atomic.Int32
    	DelInpodMarkIPRuleCnt atomic.Int32
    	AddLoopbackRoutesCnt  atomic.Int32
    	DelLoopbackRoutesCnt  atomic.Int32
    }
    
    var _ iptables.NetlinkDependencies = &fakeIptablesDeps{}
    
    func (r *fakeIptablesDeps) AddInpodMarkIPRule(cfg *iptables.Config) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  4. istioctl/pkg/describe/describe_test.go

    		}
    	}
    }
    
    func TestGetIstioVirtualServicePathForSvcFromRoute(t *testing.T) {
    	tests := []struct {
    		name         string
    		inputConfig  string
    		inputService corev1.Service
    		inputPort    int32
    		expected     string
    	}{
    		{
    			name:        "test tls config",
    			inputConfig: "testdata/describe/tls_config.json",
    			inputService: corev1.Service{
    				TypeMeta: metav1.TypeMeta{},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Mar 28 09:54:01 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  5. istioctl/pkg/workload/workload_test.go

    		})
    	}
    }
    
    func TestWorkloadEntryToPodPortsMeta(t *testing.T) {
    	cases := []struct {
    		description string
    		ports       map[string]uint32
    		want        string
    	}{
    		{
    			description: "test json marshal",
    			ports: map[string]uint32{
    				"HTTP":  80,
    				"HTTPS": 443,
    			},
    			want: `[{"name":"HTTP","containerPort":80,"protocol":""},{"name":"HTTPS","containerPort":443,"protocol":""}]`,
    		},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Mar 27 16:59:05 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/envoy/configdump/listener.go

    )
    
    // ListenerFilter is used to pass filter information into listener based config writer print functions
    type ListenerFilter struct {
    	Address string
    	Port    uint32
    	Type    string
    	Verbose bool
    }
    
    // Verify returns true if the passed listener matches the filter fields
    func (l *ListenerFilter) Verify(listener *listener.Listener) bool {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  7. istioctl/pkg/describe/describe.go

    	return []string{}, nil
    }
    
    // Return the first HTTP Connection Manager config for the inbound port
    func getInboundHTTPConnectionManager(cd *configdump.Wrapper, port int32) (*hcm.HttpConnectionManager, error) {
    	filter := istio_envoy_configdump.ListenerFilter{
    		Port: uint32(port),
    	}
    	listeners, err := cd.GetListenerConfigDump()
    	if err != nil {
    		return nil, err
    	}
    
    	for _, l := range listeners.DynamicListeners {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/endpoint.go

    	}
    	status := retrieveEndpointStatus(ep)
    	if e.Status != "" && !strings.EqualFold(core.HealthStatus_name[int32(status)], e.Status) {
    		return false
    	}
    	return true
    }
    
    func retrieveEndpointStatus(ep *endpoint.LbEndpoint) core.HealthStatus {
    	return ep.GetHealthStatus()
    }
    
    func retrieveEndpointPort(ep *endpoint.LbEndpoint) uint32 {
    	return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue()
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  9. cni/pkg/repair/repair_test.go

    					},
    				},
    				LastTerminationState: corev1.ContainerState{
    					Terminated: &corev1.ContainerStateTerminated{
    						Message:  terminationMessage,
    						ExitCode: int32(exitCode),
    					},
    				},
    			},
    		})
    	}
    
    	cases := []struct {
    		name   string
    		config config.RepairConfig
    		pod    *corev1.Pod
    		want   bool
    	}{
    		{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Oct 24 03:31:28 GMT 2023
    - 10.6K bytes
    - Viewed (0)
  10. istioctl/pkg/proxyconfig/proxyconfig.go

    					},
    					configdump.ListenerFilter{
    						Address: address,
    						Port:    uint32(port),
    						Type:    listenerType,
    						Verbose: verboseProxyConfig,
    					},
    					configdump.RouteFilter{
    						Name:    routeName,
    						Verbose: verboseProxyConfig,
    					},
    					configdump.EndpointFilter{
    						Address: address,
    						Port:    uint32(port),
    						Cluster: clusterName,
    						Status:  status,
    					},
    				)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 16 03:28:36 GMT 2024
    - 48K bytes
    - Viewed (0)
Back to top