Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for exists (0.18 sec)

  1. cni/pkg/install/cniconfig.go

    	for !file.Exists(cniConfigFilepath) {
    		if strings.HasSuffix(cniConfigFilepath, ".conf") && file.Exists(cniConfigFilepath+"list") {
    			installLog.Infof("%s doesn't exist, but %[1]slist does; Using it as the CNI config file instead.", cniConfigFilepath)
    			cniConfigFilepath += "list"
    		} else if strings.HasSuffix(cniConfigFilepath, ".conflist") && file.Exists(cniConfigFilepath[:len(cniConfigFilepath)-4]) {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  2. cni/pkg/iptables/iptables.go

    	// we cannot make assumptions there.
    
    	// -A OUTPUT -m owner --socket-exists -p tcp -m set --match-set istio-inpod-probes dst,dst -j SNAT --to-source 169.254.7.127
    	iptablesBuilder.AppendRuleV4(
    		iptableslog.UndefinedCommand, ChainHostPostrouting, iptablesconstants.NAT,
    		"-m", "owner",
    		"--socket-exists",
    		"-p", "tcp",
    		"-m", "set",
    		"--match-set", fmt.Sprintf(ipset.V4Name, ProbeIPSet),
    		"dst",
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 19.6K bytes
    - Viewed (0)
  3. common-protos/k8s.io/api/storage/v1/generated.proto

    //
    // The following three cases all imply that no capacity is available for
    // a certain combination:
    // - no object exists with suitable topology and storage class name
    // - such an object exists, but the capacity is unset
    // - such an object exists, but the capacity is zero
    //
    // The producer of these objects can decide which approach is more suitable.
    //
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 24.7K bytes
    - Viewed (0)
  4. cni/test/install_cni.go

    		if len(expectedPostCleanFile) == 0 {
    			compareConfResult(resultFile, wd+cniConfSubDir+preConfFile, t)
    		} else {
    			compareConfResult(resultFile, expectedPostCleanFile, t)
    		}
    	} else {
    		if file.Exists(resultFile) {
    			t.Logf("FAIL: Istio CNI config file was not removed: %s", resultFile)
    		}
    	}
    	retry.UntilSuccessOrFail(t, func() error {
    		return checkBinDir(t, tempCNIBinDir, "del", "istio-cni")
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net_test.go

    	setupLogging()
    	fixture := getTestFixure(ctx)
    	netServer := fixture.netServer
    	ztunnelServer := fixture.ztunnelServer
    	podMeta := metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		// this uid exists in the fake filesystem.
    		UID: "863b91d4-4b68-4efa-917f-4b560e3e86aa",
    	}
    	podIP := netip.MustParseAddr("99.9.9.9")
    	podIPs := []netip.Addr{podIP}
    	expectPodAddedToIPSet(fixture.ipsetDeps, podMeta)
    
    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)
  6. operator/cmd/mesh/install.go

    	// "no running Istio pods in istio-system" for the first time
    	_ = detectIstioVersionDiff(p, tag, ns, kubeClient, iop)
    	exists := revtag.PreviousInstallExists(context.Background(), kubeClient.Kube())
    	err = detectDefaultWebhookChange(p, kubeClient, iop, exists)
    	if err != nil {
    		return fmt.Errorf("failed to detect the default webhook change: %v", err)
    	}
    
    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. istioctl/pkg/kubeinject/kubeinject.go

    			meshConfigMapName, ctx.IstioNamespace(), err)
    	}
    	// values in the data are strings, while proto might use a
    	// different data type.  therefore, we have to get a value by a
    	// key
    	configYaml, exists := meshConfigMap.Data[configMapKey]
    	if !exists {
    		return nil, fmt.Errorf("missing configuration map key %q", configMapKey)
    	}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
  8. istioctl/pkg/tag/generate.go

    }
    
    // Generate generates the manifests for a revision tag pointed the given revision.
    func Generate(ctx context.Context, client kube.Client, opts *GenerateOptions, istioNS string) (string, error) {
    	// abort if there exists a revision with the target tag name
    	revWebhookCollisions, err := GetWebhooksWithRevision(ctx, client.Kube(), opts.Tag)
    	if err != nil {
    		return "", err
    	}
    	if !opts.Generate && !opts.Overwrite &&
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Jan 16 17:43:49 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  9. cni/pkg/install/install_test.go

    			} else if file.Exists(cniConfigFilePath) {
    				t.Fatalf("file %s was not deleted", c.configFilename)
    			}
    
    			// check if kubeconfig is deleted
    			if file.Exists(kubeConfigFilePath) {
    				t.Fatal("kubeconfig was not deleted")
    			}
    
    			// check if binaries are deleted
    			if file.Exists(filepath.Join(cniBinDir, "istio-cni")) {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  10. istioctl/pkg/multicluster/remote_secret.go

    	yaml, err := generateServiceAccountYAML(opt)
    	if err != nil {
    		return err
    	}
    
    	// Before we can apply the yaml, we have to ensure the system namespace exists.
    	if err := createNamespaceIfNotExist(client, opt.Namespace); err != nil {
    		return err
    	}
    
    	// Apply the YAML to the cluster.
    	return client.ApplyYAMLContents(opt.Namespace, yaml)
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed Oct 11 01:43:17 GMT 2023
    - 24K bytes
    - Viewed (0)
Back to top