- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 112 for done (0.17 sec)
-
cni/pkg/nodeagent/informers_test.go
"", ).Return(nil) server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`, constants.DataplaneMode, constants.DataplaneModeAmbient))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
common/scripts/lint_copyright_banner.sh
Shell Script - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Sep 11 23:32:21 GMT 2019 - 1.2K bytes - Viewed (0) -
common/scripts/fix_copyright_banner.sh
Shell Script - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Nov 17 04:35:57 GMT 2022 - 1.3K bytes - Viewed (0) -
cni/test/install_cni.go
cancel() wg.Wait() }() go func() { runInstall(ctx, tempCNIConfDir, tempCNIBinDir, tempK8sSvcAcctDir, envPreconf, filepath.Join(env.IstioSrc, "cni/test/testdata/bindir"), chainedCNIPlugin, t) wg.Done() }() resultFile := tempCNIConfDir + "/" + resultFileName if chainedCNIPlugin && delayedConfFile != "" { retry.UntilSuccessOrFail(t, func() error {
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) -
cni/pkg/nodeagent/server_test.go
} func (wg *WaitGroup) Add(i int32) { select { case <-wg.done: panic("use of an already closed WaitGroup") default: } atomic.AddInt32(&wg.count, i) } func (wg *WaitGroup) Done() { i := atomic.AddInt32(&wg.count, -1) if i == 0 { close(wg.done) } } func (wg *WaitGroup) C() <-chan struct{} { return wg.done
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
common/scripts/kind_provisioner.sh
while read -r value; do CLUSTER_NAMES+=("$value") done < <(echo "${KUBE_CLUSTERS}" | jq -r '.cluster_name // .clusterName') while read -r value; do CLUSTER_POD_SUBNETS+=("$value") done < <(echo "${KUBE_CLUSTERS}" | jq -r '.pod_subnet // .podSubnet') while read -r value; do CLUSTER_SVC_SUBNETS+=("$value") done < <(echo "${KUBE_CLUSTERS}" | jq -r '.svc_subnet // .svcSubnet')
Shell Script - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 08 19:12:55 GMT 2024 - 17.3K bytes - Viewed (1) -
common-protos/k8s.io/api/autoscaling/v2beta2/generated.proto
// considered while scaling up or scaling down. // StabilizationWindowSeconds must be greater than or equal to zero and less than or equal to 3600 (one hour). // If not set, use the default values: // - For scale up: 0 (i.e. no stabilization is done). // - For scale down: 300 (i.e. the stabilization window is 300 seconds long). // +optional optional int32 stabilizationWindowSeconds = 3;
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21K bytes - Viewed (0) -
RELEASE_BRANCHES.md
## Feature implementation Release managers will continue to have a final say in what gets merged or not, unless directed by the TOC. See the next section if the implementation is done, but a bug is being addressed. * Any code that changes feature functionality must be done within 2 weeks of the release branch cutting. Even then it is at the discretion of the release managers if PRs will be accepted and merged into the release branch.
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Nov 12 23:27:43 GMT 2021 - 3.9K bytes - Viewed (0) -
cni/pkg/repair/repair.go
} rc, err := NewRepairController(client, cfg) if err != nil { repairLog.Fatalf("Fatal error constructing repair controller: %+v", err) } go rc.Run(ctx.Done()) client.RunAndWait(ctx.Done()) } // Set up Kubernetes client using kubeconfig (or in-cluster config if no file provided) func clientSetup() (kube.Client, error) { config, err := kube.DefaultRestConfig("", "") if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0)