- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for int32 (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)