Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 67 for We (0.12 sec)

  1. cni/pkg/repair/netns.go

    	}
    	oldest := uint64(math.MaxUint64)
    	best := ""
    	// We will iterate over all processes. Our goal is to find a process with the same network ID as we found above.
    	// There should be 1 or 2 processes that match: the pause container should always be there, and the istio-validation *might*.
    	// We want the pause container, as the istio-validation one may exit before we are done.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Dec 20 22:14:13 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net.go

    	}
    	return nil
    }
    
    func realDependencies() *dep.RealDependencies {
    	return &dep.RealDependencies{
    		CNIMode:          false, // we are in cni, but as we do the netns ourselves, we should keep this as false.
    		NetworkNamespace: "",
    	}
    }
    
    // Remove pod from mesh: pod is not deleted, we just want to remove it from the mesh.
    func (s *NetServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    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)
  3. cni/pkg/nodeagent/pod_cache.go

    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 {
    	openNetns func(nspath string) (NetnsCloser, error)
    
    	currentPodCache map[string]WorkloadInfo
    	mu              sync.RWMutex
    }
    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)
  4. istioctl/pkg/util/handlers/handlers.go

    func inferNsInfo(name, namespace string) (string, string) {
    	if idx := strings.LastIndex(name, "/"); idx > 0 {
    		// If there is a / in it, we need to handle differently. This is resourcetype/name.namespace.
    		// However, resourcetype can have . in it as well, so we should only look for namespace after the /.
    		separator := strings.LastIndex(name[idx:], ".")
    		if separator < 0 {
    			return name, namespace
    		}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Feb 06 15:01:41 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  5. istioctl/pkg/util/configdump/wrapper.go

    var nonStrictResolver = &resolver{protoregistry.GlobalTypes}
    
    func (r *resolver) FindMessageByURL(url string) (protoreflect.MessageType, error) {
    	typ, err := r.Types.FindMessageByURL(url)
    	if err != nil {
    		// Here we ignore the error since we want istioctl to ignore unknown types due to the Envoy version change
    		msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}}
    		return msg.ProtoReflect().Type(), nil
    	}
    	return typ, nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/server.go

    	if err != nil {
    		return nil, fmt.Errorf("error configuring iptables: %w", err)
    	}
    
    	// Create hostprobe rules now, in the host netns
    	// Later we will reuse this same configurator inside the pod netns for adding other rules
    	iptablesConfigurator.DeleteHostRules()
    
    	if err := iptablesConfigurator.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil {
    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)
  7. operator/cmd/mesh/profile-diff_test.go

    }
    
    func TestProfileDiffDirect(t *testing.T) {
    	cases := []profileDiffTestcase{
    		{
    			// We won't be parsing with Cobra, but this is the command equivalent
    			args: "profile diff default openshift",
    			// This is just one of the many differences
    			expectedString: "+    profile: openshift",
    			// The profile doesn't change istiocoredns, so we shouldn't see this in the diff
    			notExpected: "-    istiocoredns:",
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 10 05:10:03 GMT 2024
    - 3.6K bytes
    - Viewed (1)
  8. istioctl/pkg/workload/workload_test.go

    				if !strings.Contains(output, noClusterID) {
    					t.Fatal(err)
    				}
    			}
    
    			checkFiles := map[string]bool{
    				// inputs that we allow to exist, if other files seep in unexpectedly we fail the test
    				".gitignore": false, "meshconfig.yaml": false, "workloadgroup.yaml": false,
    			}
    			for k, v := range generated {
    				checkFiles[k] = v
    			}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Mar 27 16:59:05 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  9. operator/cmd/mesh/profile-dump.go

    }
    
    // Convert the generated YAML to pretty JSON.
    func yamlToPrettyJSON(yml string) (string, error) {
    	// YAML objects are not completely compatible with JSON
    	// objects. Let yaml.YAMLToJSON handle the edge cases and
    	// we'll re-encode the result to pretty JSON.
    	uglyJSON, err := yaml.YAMLToJSON([]byte(yml))
    	if err != nil {
    		return "", err
    	}
    	var decoded any
    	if uglyJSON[0] == '[' {
    		decoded = make([]any, 0)
    	} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  10. cni/pkg/log/uds_test.go

    	log.Debug("debug log")
    	log.Info("info log")
    	log.Warn("warn log")
    	log.Error("error log")
    	// This will error because stdout cannot sync, but the UDS part should sync
    	// Ideally we would fail if the UDS part fails but the error library makes it kind of tricky
    	_ = log.Sync()
    
    	// Restore os stdout.
    	os.Stdout = stdout
    	assert.NoError(t, log.Configure(loggingOptions))
    
    	assert.NoError(t, w.Close())
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Mar 16 00:20:01 GMT 2024
    - 2.5K bytes
    - Viewed (0)
Back to top