Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for called (0.16 sec)

  1. 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 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  2. cni/pkg/plugin/plugin_test.go

    		t.Fatalf("Didnt Expect nsenterFunc to be called because this pod does not contain a sidecar")
    	}
    }
    
    func TestCmdAddExcludePod(t *testing.T) {
    	pod, ns := buildFakePodAndNSForClient()
    
    	mockIntercept := testDoAddRun(t, buildMockConf(true, ""), "testExcludeNS", pod, ns)
    	if len(mockIntercept.lastRedirect) != 0 {
    		t.Fatalf("failed to exclude pod")
    	}
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/informers_test.go

    	client.RunAndWait(ctx.Done())
    	go handlers.Start()
    
    	waitForMockCalls()
    	// wait until pod add was called
    	mt.Assert(EventTotals.Name(), map[string]string{"type": "add"}, monitortest.AtLeast(1))
    
    	assertPodAnnotated(t, client, pod)
    
    	// check expectations on mocked calls
    	fs.AssertExpectations(t)
    }
    
    func assertPodAnnotated(t *testing.T, client kube.Client, pod *corev1.Pod) {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Feb 08 01:03:24 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	podIPs := []netip.Addr{podIP}
    
    	expectPodAddedToIPSet(fixture.ipsetDeps, podMeta)
    	err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "faksens")
    	// no calls to ztunnel if iptables failed
    	assert.Equal(t, ztunnelServer.addedPods.Load(), 0)
    
    	// error is not partial error
    	if errors.Is(err, ErrPartialAdd) {
    		t.Fatal("expected not a partial error")
    	}
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/storage/v1/generated.proto

      // requiresRepublish indicates the CSI driver wants `NodePublishVolume`
      // being periodically called to reflect any possible change in the mounted
      // volume. This field defaults to false.
      //
      // Note: After a successful initial NodePublishVolume call, subsequent calls
      // to NodePublishVolume should only update the contents of the volume. New
      // mount points will not be seen by a running container.
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 24.7K bytes
    - Viewed (0)
  6. 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 Mar 20 22:53:08 GMT 2024
    - Last Modified: Tue Feb 27 16:55:16 GMT 2024
    - 23.7K bytes
    - Viewed (0)
  7. 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 Mar 20 22:53:08 GMT 2024
    - Last Modified: Tue Feb 27 16:55:16 GMT 2024
    - 23.7K bytes
    - Viewed (1)
  8. cni/pkg/nodeagent/server_test.go

    	if f.testWG != nil {
    		defer f.testWG.Done()
    	}
    	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() {
    }
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto

      //
      // Never: the webhook will not be called more than once in a single admission evaluation.
      //
      // IfNeeded: the webhook will be called at least one additional time as part of the admission evaluation
      // if the object being admitted is modified by other admission plugins after the initial webhook call.
      // Webhooks that specify this option *must* be idempotent, able to process objects they previously admitted.
      // Note:
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 22.6K bytes
    - Viewed (0)
  10. operator/cmd/mesh/manifest-diff.go

    	// e.g.
    	// Deployment:istio-system:* - compare all deployments in istio-system namespace
    	// Service:*:istio-pilot - compare Services called "istio-pilot" in all namespaces.
    	selectResources string
    	// ignoreResources ignores all listed items during comparison. It uses the same list format as selectResources.
    	ignoreResources string
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 5.8K bytes
    - Viewed (0)
Back to top