Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for calls (0.14 sec)

  1. cni/pkg/nodeagent/cni-watcher_test.go

    		},
    		Status: corev1.PodStatus{
    			PodIP: fakePodIP,
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    	// We are expecting at most 1 calls to the mock, wait for them
    	wg, waitForMockCalls := NewWaitForNCalls(t, 1)
    	fs := &fakeServer{testWG: wg}
    
    	fs.On("AddPodToMesh",
    		ctx,
    		pod,
    		util.GetPodIPsIfPresent(pod),
    		valid.Netns,
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Feb 02 08:18:40 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server_test.go

    			},
    		},
    	}
    }
    
    type fakeServer struct {
    	mock.Mock
    	testWG *WaitGroup // optional waitgroup, if code under test makes a number of async calls to fakeServer
    }
    
    func (f *fakeServer) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error {
    	if f.testWG != nil {
    		defer f.testWG.Done()
    	}
    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)
  3. istioctl/pkg/clioptions/central.go

    	// XDSSAN is the expected Subject Alternative Name of the XDS server
    	XDSSAN string
    
    	// Plaintext forces plain text communication (for talking to port 15010)
    	Plaintext bool
    
    	// GCP project number or ID to use for XDS calls, if any.
    	GCPProject string
    
    	// Istiod address. For MCP may be different than Xds.
    	IstiodAddr string
    }
    
    // AttachControlPlaneFlags attaches control-plane flags to a Cobra command.
    // (Currently just --endpoint)
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Jun 06 03:39:27 GMT 2022
    - 3.2K bytes
    - Viewed (0)
  4. common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto

      // +optional
      optional string sideEffects = 6;
    
      // TimeoutSeconds specifies the timeout for this webhook. After the timeout passes,
      // the webhook call will be ignored or the API call will fail based on the
      // failure policy.
      // The timeout value must be between 1 and 30 seconds.
      // Default to 30 seconds.
      // +optional
      optional int32 timeoutSeconds = 7;
    
    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)
  5. istioctl/pkg/metrics/metrics_test.go

    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/istioctl/pkg/util/testutil"
    )
    
    // mockPromAPI lets us mock calls to Prometheus API
    type mockPromAPI struct {
    	cannedResponse map[string]prometheus_model.Value
    }
    
    func TestMetricsNoPrometheus(t *testing.T) {
    	cases := []testutil.TestCase{
    		{ // case 0
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed Oct 25 02:07:44 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/informers_test.go

    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    	// We are expecting at most 1 calls to the mock, wait for them
    	wg, waitForMockCalls := NewWaitForNCalls(t, 1)
    	fs := &fakeServer{testWG: wg}
    
    	fs.On("AddPodToMesh",
    		ctx,
    		pod,
    		util.GetPodIPsIfPresent(pod),
    		"",
    	).Return(nil)
    
    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)
  7. common-protos/k8s.io/api/storage/v1beta1/generated.proto

      // 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.
      //
      // +optional
      optional bool requiresRepublish = 7;
    
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 24.9K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/storage/v1alpha1/generated.proto

      optional bool attached = 1;
    
      // attachmentMetadata is populated with any
      // information returned by the attach operation, upon successful attach, that must be passed
      // into subsequent WaitForAttach or Mount calls.
      // This field must only be set by the entity completing the attach
      // operation, i.e. the external-attacher.
      // +optional
      map<string, string> attachmentMetadata = 2;
    
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/podcgroupns.go

    // Cgroup represents a linux cgroup.
    type Cgroup struct {
    	HierarchyID    string
    	ControllerList string
    	GroupPath      string
    }
    
    // GetCGroups returns a slice of cgroups for pid using fs for filesystem calls.
    //
    // The expected cgroup format is "hierarchy-ID:controller-list:cgroup-path", and
    // this function will return an error if every cgroup does not meet that format.
    //
    // For more information, see:
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/admissionregistration/v1/generated.proto

      // sideEffects == Unknown or Some.
      optional string sideEffects = 6;
    
      // TimeoutSeconds specifies the timeout for this webhook. After the timeout passes,
      // the webhook call will be ignored or the API call will fail based on the
      // failure policy.
      // The timeout value must be between 1 and 30 seconds.
      // Default to 10 seconds.
      // +optional
      optional int32 timeoutSeconds = 7;
    
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 24.4K bytes
    - Viewed (0)
Back to top