- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 48 for Caller (0.19 sec)
-
cni/pkg/ipset/nldeps_mock.go
func (m *MockedIpsetDeps) ipsetIPHashCreate(name string, v6 bool) error { args := m.Called(name, v6) return args.Error(0) } func (m *MockedIpsetDeps) destroySet(name string) error { args := m.Called(name) return args.Error(0) } func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error { args := m.Called(name, ip, ipProto, comment, replace) return args.Error(0) }
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/plugin/plugin_test.go
ns.ObjectMeta.Labels = map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient} testCmdAddExpectFail(t, cniConf, pod, ns) wasCalled := serverClose() // server called, but errored assert.Equal(t, wasCalled, true) } func TestCmdAddPodWithProxySidecarAmbientEnabledNS(t *testing.T) { url, serverClose := setupCNIEventClientWithMockServer(false)
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/nodeagent/informers_test.go
kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // wait until pod add was called mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(1)) log.Debug("labeling namespace") _, err := client.Kube().CoreV1().Namespaces().Patch(ctx, ns.Name,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: "bar", UID: "123", }, Spec: corev1.PodSpec{ServiceAccountName: "sa"}, } // this is usually called after add. so manually add the pod uid for now fakens := newFakeNs(123) closed := fakens.closed workload := WorkloadInfo{ Workload: podToWorkload(pod), Netns: fakens, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1/generated.proto
// If the CSIDriverRegistry feature gate is enabled and the value is // specified to false, the attach operation will be skipped. // Otherwise the attach operation will be called. // // This field is immutable. // // +optional optional bool attachRequired = 1; // podInfoOnMount indicates this CSI volume driver requires additional pod information (like podName, podUID, etc.)
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 24.7K bytes - Viewed (0) -
manifests/charts/istiod-remote/files/injection-template.yaml
{{- else if $holdProxy }} lifecycle: postStart: exec: command: - pilot-agent - wait {{- else if $nativeSidecar }} {{- /* preStop is called when the pod starts shutdown. Initialize drain. We will get SIGTERM once applications are torn down. */}} lifecycle: preStop: exec: command: - pilot-agent - request
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 26 16:51:17 GMT 2024 - 23.7K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/files/injection-template.yaml
{{- else if $holdProxy }} lifecycle: postStart: exec: command: - pilot-agent - wait {{- else if $nativeSidecar }} {{- /* preStop is called when the pod starts shutdown. Initialize drain. We will get SIGTERM once applications are torn down. */}} lifecycle: preStop: exec: command: - pilot-agent - request
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 26 16:51:17 GMT 2024 - 23.7K bytes - Viewed (1) -
common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
// before taking the alternate action. // +optional optional int32 retryAfterSeconds = 5; } // TableOptions are used when a Table is requested by the caller. // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object message TableOptions { // includeObject decides whether to include each object along with its columnar information.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 53.3K bytes - Viewed (0) -
istioctl/cmd/root.go
root.LoggingOptions.AttachCobraFlags(rootCmd) hiddenFlags := []string{ "log_as_json", "log_rotate", "log_rotate_max_age", "log_rotate_max_backups", "log_rotate_max_size", "log_stacktrace_level", "log_target", "log_caller", "log_output_level", } for _, opt := range hiddenFlags { _ = rootCmd.PersistentFlags().MarkHidden(opt) } cmd.AddFlags(rootCmd) kubeInjectCmd := kubeinject.InjectCommand(ctx)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
} if !reflect.DeepEqual(netns1, netns2) { t.Fatalf("Expected the same Netns for the same uid, got %v and %v", netns1, netns2) } if counter.Load() != 2 { t.Fatalf("Expected openNetns to be called twice, got %d", counter.Load()) } } func TestUpsertPodCacheWithNewInode(t *testing.T) { counter.Store(0) p := newPodNetnsCache(openNsTestOverrideWithInodes(1, 2))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.2K bytes - Viewed (0)