- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 185 for func (0.12 sec)
-
cni/pkg/iptables/nldeps.go
} func (r *realDeps) DelLoopbackRoutes(cfg *Config) error { return DelLoopbackRoutes(cfg) } type emptyDeps struct{} func EmptyNlDeps() NetlinkDependencies { return &emptyDeps{} } func (r *emptyDeps) AddInpodMarkIPRule(cfg *Config) error { return nil } func (r *emptyDeps) DelInpodMarkIPRule(cfg *Config) error { return nil } func (r *emptyDeps) AddLoopbackRoutes(cfg *Config) error { return nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.6K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_unspecified.go
import ( "errors" "net/netip" ) func RealNlDeps() NetlinkIpsetDeps { return &realDeps{} } type realDeps struct{} func (m *realDeps) ipsetIPHashCreate(name string, v6 bool) error { return errors.New("not implemented on this platform") } func (m *realDeps) destroySet(name string) error { return errors.New("not implemented on this platform") }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 1.8K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
args := f.Called(ctx, pod) return args.Error(0) } func (f *fakeServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error { if f.testWG != nil { defer f.testWG.Done() } args := f.Called(ctx, pod) return args.Error(0) } func (f *fakeServer) Start(ctx context.Context) { } func (f *fakeServer) Stop() { } func (f *fakeServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error {
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/pod_cache.go
type podNetnsCache struct { openNetns func(nspath string) (NetnsCloser, error) currentPodCache map[string]WorkloadInfo mu sync.RWMutex } type WorkloadInfo struct { Workload *zdsapi.WorkloadInfo Netns NetnsCloser } var _ PodNetnsCache = &podNetnsCache{} func newPodNetnsCache(openNetns func(nspath string) (NetnsCloser, error)) *podNetnsCache { return &podNetnsCache{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
} } return nil } func AddLoopbackRoutes(cfg *Config) error { return forEachLoopbackRoute(cfg, netlink.RouteReplace) } func DelLoopbackRoutes(cfg *Config) error { return forEachLoopbackRoute(cfg, netlink.RouteDel) } func forEachLoopbackRoute(cfg *Config, f func(*netlink.Route) error) error { loopbackLink, err := netlink.LinkByName("lo") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.3K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
return s, nil } func (s *Server) Ready() { s.isReady.Store(true) } func (s *Server) NotReady() { s.isReady.Store(false) } // buildKubeClient creates the kube client func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation kubeRestConfig, err := kube.DefaultRestConfig(kubeConfig, "", func(config *rest.Config) { config.QPS = 80
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/tag/util.go
nsNames[i] = ns.Name } return nsNames, nil } // GetWebhookTagName extracts tag name from webhook object. func GetWebhookTagName(wh admitv1.MutatingWebhookConfiguration) string { return wh.ObjectMeta.Labels[IstioTagLabel] } // GetWebhookRevision extracts tag target revision from webhook object. func GetWebhookRevision(wh admitv1.MutatingWebhookConfiguration) (string, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:42 GMT 2024 - 5.4K bytes - Viewed (1) -
istioctl/pkg/writer/compare/sds/util.go
} // Name sets the name field on a secretItemBuilder func (s *secretItemBuilder) Name(name string) SecretItemBuilder { s.name = name return s } // Data sets the data field on a secretItemBuilder func (s *secretItemBuilder) Data(data string) SecretItemBuilder { s.data = data return s } // Source sets the source field on a secretItemBuilder func (s *secretItemBuilder) Source(source string) SecretItemBuilder {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jun 06 15:14:48 GMT 2023 - 6.6K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
termEnvVar = env.Register("TERM", "", "Specifies terminal type. Use 'dumb' to suppress color output") ) func init() { for _, key := range MsgOutputFormatKeys { MsgOutputFormats[key] = true } } // Print output messages in the specified format with color options func Print(ms diag.Messages, format string, colorize bool) (string, error) { switch format { case LogFormat:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/clusters/clusters.go
} } return "unknown" } func retrieveEndpointPort(l *admin.HostStatus) uint32 { addr := l.Address.GetSocketAddress() if addr != nil { return addr.GetPortValue() } return 0 } func retrieveEndpointStatus(l *admin.HostStatus) core.HealthStatus { return l.HealthStatus.GetEdsHealthStatus() } func retrieveFailedOutlierCheck(l *admin.HostStatus) bool {
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)