Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 75 for we (0.14 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/cmd/options.go

    	"log_output_level":     true,
    	// istioctl also inherits support for log_rotate, log_rotate_max_age, log_rotate_max_backups,
    	// log_rotate_max_size, but these are rarely appropriate for a user-facing CLI so we ignore them
    }
    
    func optionsCommand(rootCmd *cobra.Command) *cobra.Command {
    	retval := &cobra.Command{
    		Use:   "options",
    		Short: "Displays istioctl global options",
    		Args:  cobra.ExactArgs(0),
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.8K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. operator/cmd/mesh/profile-dump_test.go

    			outPath := filepath.Join(testDataDir, "output", tt.desc+".yaml")
    
    			got, err := runProfileDump(inPath, tt.configPath, snapshotCharts, "")
    			if err != nil {
    				t.Fatal(err)
    			}
    			// installPackagePath may change, we will remove it for consistent output
    			got = installPackagePathRegex.ReplaceAllString(got, "")
    
    			if refreshGoldenFiles() {
    				t.Logf("Refreshing golden file for %s", outPath)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jan 20 11:44:25 GMT 2022
    - 3.7K bytes
    - Viewed (0)
  10. 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)
Back to top