- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Arun (0.23 sec)
-
cni/pkg/iptables/iptables.go
} for _, iptVer := range iptablesVariant { for _, cmd := range deleteCmds { delErrs = append(delErrs, cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...)) } for _, cmd := range optionalDeleteCmds { err := cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...) if err != nil { log.Debugf("ignoring error deleting optional iptables rule: %v", err) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
want: []string{}, }, { name: "Non-parseable", args: args{ports: []string{"abcd", "2345", "abcd"}}, want: []string{"abcd", "2345"}, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if got := dedupPorts(tt.args.ports); !reflect.DeepEqual(got, tt.want) { t.Errorf("dedupPorts() = %v, want %v", got, tt.want) } }) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/util/podutil_test.go
args: args{ namespace: unlabelledNamespace, pod: podWithSidecarAndAmbientEnabledLabel, }, want: false, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if got := PodRedirectionEnabled(tt.args.namespace, tt.args.pod); got != tt.want { t.Errorf("PodRedirectionEnabled() = %v, want %v", got, tt.want) } }) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
return pod, nil } return nil, nil } func (s *InformerHandlers) Start() { kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced) go s.queue.Run(s.ctx.Done()) } func (s *InformerHandlers) GetAmbientPods() []*corev1.Pod { var pods []*corev1.Pod for _, pod := range s.pods.List(metav1.NamespaceAll, klabels.Everything()) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
operator/cmd/mesh/install.go
} else if processed { p.Println("Made this installation the default for cluster-wide operations.") } if iArgs.Verify { if rootArgs.DryRun { l.LogAndPrint("Control plane health check is not applicable in dry-run mode") return nil } l.LogAndPrint("\n\nVerifying installation:") installationVerifier, err := verifier.NewStatusVerifier(kubeClient, client, iop.Namespace, iArgs.ManifestsPath,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
cni/pkg/plugin/plugin.go
// The field names need to match exact keys in containerd args for unmarshalling // https://github.com/containerd/containerd/blob/ced9b18c231a28990617bc0a4b8ce2e81ee2ffa1/pkg/cri/server/sandbox_run.go#L526-L532 type K8sArgs struct { types.CommonArgs K8S_POD_NAME types.UnmarshallableString // nolint: revive, stylecheck K8S_POD_NAMESPACE types.UnmarshallableString // nolint: revive, stylecheck
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list_test.go
}, Annotations: map[string]string{ annotation.SidecarStatus.Name: `{"revision":"test-anno"}`, }, }, }, expectedRevision: "test-anno", }, } for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, c.name), func(t *testing.T) { assert.Equal(t, c.expectedRevision, extractRevisionFromPod(c.pod)) }) } } func Test_getNamespaces(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 2.9K bytes - Viewed (0)