Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for prod (0.15 sec)

  1. istioctl/pkg/workload/workload.go

    	md["POD_NAMESPACE"] = wg.Namespace
    	md["SERVICE_ACCOUNT"] = we.ServiceAccount
    	md["TRUST_DOMAIN"] = meshConfig.TrustDomain
    
    	md["ISTIO_META_CLUSTER_ID"] = clusterID
    	md["ISTIO_META_MESH_ID"] = meshConfig.DefaultConfig.MeshId
    	md["ISTIO_META_NETWORK"] = we.Network
    	if portsStr := marshalWorkloadEntryPodPorts(we.Ports); portsStr != "" {
    		md["ISTIO_META_POD_PORTS"] = portsStr
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/pod_cache.go

    		currentPodCache: map[string]WorkloadInfo{},
    	}
    }
    
    func (p *podNetnsCache) UpsertPodCache(pod *corev1.Pod, nspath string) (Netns, error) {
    	newnetns, err := p.openNetns(nspath)
    	if err != nil {
    		return nil, err
    	}
    	wl := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    newnetns,
    	}
    	return p.UpsertPodCacheWithNetns(string(pod.UID), wl), nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server.go

    	ConstructInitialSnapshot(ambientPods []*corev1.Pod) error
    	Start(ctx context.Context)
    
    	//	IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error)
    	AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error
    	RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error
    	DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error
    
    	Stop()
    }
    
    type Server struct {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net.go

    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	log.Debug("Pod is now stopped... cleaning up.")
    
    	if err := removePodFromHostNSIpset(pod, &s.hostsideProbeIPSet); err != nil {
    		log.Errorf("failed to remove pod %s from host ipset, error was: %v", pod.Name, err)
    		return err
    	}
    
    	log.Info("in pod mode - deleting pod from ztunnel")
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  5. cni/pkg/nodeagent/podcgroupns_test.go

    )
    
    func TestWithProcFs(t *testing.T) {
    	n := NewPodNetnsProcFinder(fakeFs())
    	pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		UID:       types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"),
    	}}
    	podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{
    		pod.UID: pod,
    	})
    	if err != nil {
    		panic(err)
    	}
    	defer podUIDNetns.Close()
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  6. istioctl/pkg/checkinject/checkinject.go

    		Example: `  # Check the injection status of a pod
      istioctl experimental check-inject details-v1-fcff6c49c-kqnfk.test
    	
      # Check the injection status of a pod under a deployment
      istioctl x check-inject deployment/details-v1
    
      # Check the injection status of a pod under a deployment in namespace test
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    // PrintVersionSummary prints version information for Istio and Ztunnel from the config dump
    func (c *ConfigWriter) PrintVersionSummary() error {
    	// TODO
    	return nil
    }
    
    // PrintPodRootCAFromDynamicSecretDump prints just pod's root ca from dynamic secret config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPodRootCAFromDynamicSecretDump() (string, error) {
    	// TODO
    	return "", nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  8. cmd/metrics-v3-handler.go

    		// hence not included in the collector path.
    		pathComponents = pathComponents[:bucketIdx]
    	}
    
    	innerHandler := h.handle(pathComponents, isListingRequest, buckets)
    
    	// Add tracing to the prom. handler
    	tracedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if ok {
    			tc.FuncName = "handler.MetricsV3"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  9. istioctl/pkg/proxystatus/proxystatus.go

    				if err != nil {
    					return err
    				}
    				if ambient.IsZtunnelPod(kubeClient, podName, ns) {
    					_, _ = fmt.Fprintf(c.OutOrStdout(),
    						"Sync diff is not available for ztunnel pod %s.%s\n", podName, ns)
    					return nil
    				}
    				var envoyDump []byte
    				if configDumpFile != "" {
    					envoyDump, err = readConfigFile(configDumpFile)
    				} else {
    					path := "config_dump"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  10. istioctl/pkg/dashboard/dashboard.go

      istioctl dashboard proxy productpage-123-456.default
    
      # Open envoy admin dashboard for one pod under a deployment
      istioctl dashboard proxy deployment/productpage-v1
    
      # Open dashboard for the ztunnel-bwh89.istio-system pod
      istioctl dashboard proxy ztunnel-bwh89.istio-system
    
      # Open dashboard for a waypoint pod
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 20.5K bytes
    - Viewed (0)
Back to top