Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for Marche (0.2 sec)

  1. cni/pkg/nodeagent/net_test.go

    	assert.Equal(t, ztunnelServer.deletedPods.Load(), 1)
    	assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1)
    	assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1)
    	// make sure the uid was taken from cache and netns closed
    	netns := fixture.podNsMap.Take(string(pod.UID))
    	assert.Equal(t, nil, netns)
    
    	// run gc to clean up ns:
    
    	//revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns
    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)
  2. common-protos/k8s.io/api/core/v1/generated.proto

      // This can be used to provide different probe parameters at the beginning of a Pod's lifecycle,
      // when it might take a long time to load data or warm a cache, than during steady-state operation.
      // This cannot be updated.
      // More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes
      // +optional
      optional Probe startupProbe = 22;
    
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 255.8K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/pod_cache.go

    	"istio.io/istio/pkg/maps"
    	"istio.io/istio/pkg/zdsapi"
    )
    
    var ErrPodNotFound = errors.New("netns not provided, but is needed as pod is not in cache")
    
    type PodNetnsCache interface {
    	ReadCurrentPodSnapshot() map[string]WorkloadInfo
    }
    
    // Hold a cache of node local pods with their netns
    // if we don't know the netns, the pod will still be here with a nil netns.
    type podNetnsCache struct {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  4. common/scripts/run.sh

        --mount "type=bind,source=${MOUNT_SOURCE},destination=/work" \
        --mount "type=volume,source=go,destination=/go" \
        --mount "type=volume,source=gocache,destination=/gocache" \
        --mount "type=volume,source=cache,destination=/home/.cache" \
        --mount "type=volume,source=crates,destination=/home/.cargo/registry" \
        --mount "type=volume,source=git-crates,destination=/home/.cargo/git" \
        ${CONDITIONAL_HOST_MOUNTS} \
    Shell Script
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Aug 11 02:34:11 GMT 2023
    - 2.2K bytes
    - Viewed (1)
  5. cni/pkg/nodeagent/informers.go

    	switch event.Event {
    	case controllers.EventAdd:
    		// pod was added to our cache
    		// we get here in 2 cases:
    		// 1. new pod was created on our node
    		// 2. we were restarted and current existing pods are added to our cache
    
    		// We have no good way to distinguish between these two cases from here. But we don't need to!
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Feb 08 01:03:24 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  6. operator/cmd/mesh/install.go

    	"istio.io/istio/istioctl/pkg/clioptions"
    	revtag "istio.io/istio/istioctl/pkg/tag"
    	"istio.io/istio/istioctl/pkg/util"
    	v1alpha12 "istio.io/istio/operator/pkg/apis/istio/v1alpha1"
    	"istio.io/istio/operator/pkg/cache"
    	"istio.io/istio/operator/pkg/helmreconciler"
    	"istio.io/istio/operator/pkg/manifest"
    	"istio.io/istio/operator/pkg/name"
    	"istio.io/istio/operator/pkg/translate"
    	"istio.io/istio/operator/pkg/util/clog"
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 15.2K bytes
    - Viewed (0)
  7. operator/cmd/mesh/manifest_shared_test.go

    	"sigs.k8s.io/controller-runtime/pkg/client/interceptor"
    	"sigs.k8s.io/controller-runtime/pkg/envtest"
    
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/operator/pkg/apis/istio/v1alpha1"
    	"istio.io/istio/operator/pkg/cache"
    	"istio.io/istio/operator/pkg/helmreconciler"
    	"istio.io/istio/operator/pkg/manifest"
    	"istio.io/istio/operator/pkg/name"
    	"istio.io/istio/operator/pkg/object"
    	"istio.io/istio/operator/pkg/util/clog"
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Tue Feb 20 22:39:28 GMT 2024
    - 11.7K bytes
    - Viewed (0)
  8. operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz

    "targets": [ { "expr": "avg(envoy_wasm_remote_load_cache_hits)", "interval": "", "legendFormat": "hits", "refId": "A" }, { "expr": "avg(envoy_wasm_remote_load_cache_misses)", "interval": "", "legendFormat": "misses", "refId": "B" }, { "expr": "avg(envoy_wasm_remote_load_cache_negative_hits)", "interval": "", "legendFormat": "negative hits", "refId": "C" } ], "thresholds": [], "timeFrom": null, "timeRegions": [], "timeShift": null, "title": "Cache Visit", "tooltip": { "shared": true, "sort": 0, "value_type":...
    Others
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Wed Jan 10 05:10:03 GMT 2024
    - 198.1K bytes
    - Viewed (1)
  9. cni/pkg/nodeagent/net.go

    func (s *NetServer) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error {
    	log.Infof("in pod mode - adding pod %s/%s to ztunnel ", pod.Namespace, pod.Name)
    	// make sure the cache is aware of the pod, even if we don't have the netns yet.
    	s.currentPodSnapshot.Ensure(string(pod.UID))
    	openNetns, err := s.getOrOpenNetns(pod, netNs)
    	if err != nil {
    		return err
    	}
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  10. common-protos/k8s.io/api/authorization/v1/generated.proto

    // or to quickly let an end user reason about their permissions. It should NOT Be used by external systems to
    // drive authorization decisions as this raises confused deputy, cache lifetime/revocation, and correctness concerns.
    // SubjectAccessReview, and LocalAccessReview are the correct way to defer authorization decisions to the API server.
    message SelfSubjectRulesReview {
      // Standard list metadata.
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 11.9K bytes
    - Viewed (0)
Back to top