- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 161 for It (0.02 sec)
-
pilot/pkg/leaderelection/leaderelection_test.go
_, stop2 := createElection(t, "pod2", "red", watcher, true, client) // Third pod with revision "red" comes in and cannot take the lock since another revision with "red" has it _, stop3 := createElection(t, "pod3", "red", watcher, false, client) // Fourth pod with revision "green" cannot take the lock since a revision with "red" has it.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/zdsapi/zds.pb.go
return x.WorkloadInfo } return nil } // Keep workload that we can't find in the fd cache. This can only be sent before SnapshotSent is sent // to signal ztunnel to not delete the workload if it has it. type KeepWorkload struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 02:27:10 UTC 2024 - 25.8K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
if len(addr) == 0 { return netip.Prefix{}, fmt.Errorf("empty address") } // Already a CIDR, just parse it. if strings.Contains(addr, "/") { return netip.ParsePrefix(addr) } // Otherwise it is a raw IP. Make it a /32 or /128 depending on family ipa, err := netip.ParseAddr(addr) if err != nil { return netip.Prefix{}, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0) -
cni/pkg/install/install.go
for { // if sleepWatchInstall yields without error, that means the config might have been modified in some fashion. // so we rerun `install`, which will update the modified config if it has fallen out of sync with // our desired state err := in.sleepWatchInstall(ctx, installedBins) if err != nil { installLog.Error("error watching node CNI config") return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 10.7K bytes - Viewed (0) -
cni/test/install_cni.go
cp(wd+k8sSvcAcctSubDir+f, tempK8sSvcAcctDir+"/"+f, t) } t.Logf("Finished pre-populating working dirs") } // create an install server instance and run it, blocking until it gets terminated // via context cancellation func startInstallServer(ctx context.Context, serverConfig *config.Config, t *testing.T) { readyFlag := &atomic.Value{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 11.4K bytes - Viewed (0) -
tests/integration/ambient/main_test.go
// WaypointProxies by WaypointProxies map[string]ambient.WaypointProxy } // TestMain defines the entrypoint for pilot tests using a standard Istio installation. // If a test requires a custom install it should go into its own package, otherwise it should go // here to reuse a single install across tests. func TestMain(m *testing.M) { // nolint: staticcheck framework. NewSuite(m). RequireMinVersion(24).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
return subsetCluster.build() } // applyDestinationRule applies the destination rule if it exists for the Service. // It returns the subset clusters if any created as it applies the destination rule. func (cb *ClusterBuilder) applyDestinationRule(mc *clusterWrapper, clusterMode ClusterMode, service *model.Service,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
return nil } } if !pi.Containers.Contains(ISTIOPROXY) { log.Infof("excluded because it does not have istio-proxy container (have %v)", sets.SortedList(pi.Containers)) return nil } if pi.ProxyType != "" && pi.ProxyType != "sidecar" { log.Infof("excluded %s/%s pod because it has proxy type %s", podNamespace, podName, pi.ProxyType) return nil } val := pi.Annotations[injectAnnotationKey]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 10.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/certcontroller.go
// configured as the ratio of the certificate TTL. defaultCertGracePeriodRatio = 0.5 // the interval polling root cert and resign istiod cert when it changes. rootCertPollingInterval = 60 * time.Second // Default CA certificate path // Currently, custom CA path is not supported; no API to get custom CA cert yet.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 11.3K bytes - Viewed (0) -
common/config/.golangci.yml
# XXX: if you enable this setting, unparam will report a lot of false-positives in text editors: # if it's called for subdir of a project it can't find external interfaces. All text editor integrations # with golangci-lint call it on a directory with the changed file. check-exported: false gci: sections: - standard # Captures all standard packages if they do not match another section.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 20:03:06 UTC 2024 - 11.3K bytes - Viewed (0)