- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for canceled (0.17 sec)
-
cni/test/install_cni.go
viper.Set(constants.MonitoringPort, 0) viper.Set(constants.LogUDSAddress, "") viper.Set(constants.RepairEnabled, false) ctx, cancel := context.WithCancel(context.Background()) wg := sync.WaitGroup{} wg.Add(1) defer func() { cancel() wg.Wait() }() go func() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/install/install.go
} // sleepWatchInstall blocks until any file change for the binaries or config are detected. // At that point, the func yields so the caller can recheck the validity of the install. // If an error occurs or context is canceled, the function will return an error. func (in *Installer) sleepWatchInstall(ctx context.Context, installedBinFiles sets.String) error { // Watch our specific binaries, in each configured binary dir.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
cni/pkg/install/install_test.go
} for _, c := range cases { t.Run(c.name, func(t *testing.T) { // Create temp directory for files tempDir := t.TempDir() // Initialize parameters ctx, cancel := context.WithCancel(context.Background()) defer cancel() cfg := &config.InstallConfig{ MountedCNINetDir: tempDir, ChainedCNIPlugin: c.chainedCNIPlugin, } cniConfigFilepath := filepath.Join(tempDir, c.cniConfigFilename)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
operator/cmd/mesh/install.go
prompt := fmt.Sprintf("This will install the Istio %s %q profile (with components: %s) into the cluster. Proceed? (y/N)", tag, profile, humanReadableJoin(enabledComponents)) if !Confirm(prompt, stdOut) { p.Println("Cancelled.") os.Exit(1) } } iop.Name = savedIOPName(iop) // Detect whether previous installation exists prior to performing the installation.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
common-protos/k8s.io/api/batch/v1/generated.proto
// Valid values are: // // - "Allow" (default): allows CronJobs to run concurrently; // - "Forbid": forbids concurrent runs, skipping next run if previous run hasn't finished yet; // - "Replace": cancels currently running job and replaces it with a new one // +optional optional string concurrencyPolicy = 3; // This flag tells the controller to suspend subsequent executions, it does
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
UID: "123", }, Spec: corev1.PodSpec{ Containers: containers, }, Status: podStatus, } } func TestServerAddPod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging() fixture := getTestFixure(ctx) netServer := fixture.netServer ztunnelServer := fixture.ztunnelServer podMeta := metav1.ObjectMeta{ Name: "foo",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
"istio.io/istio/pkg/monitoring/monitortest" "istio.io/istio/pkg/test/util/assert" ) func TestExistingPodAddedWhenNsLabeled(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: NodeName, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
installLog.Infof("Created CNI config %s", cniConfigFilepath) return cniConfigFilepath, nil } // If configured as chained CNI plugin, waits indefinitely for a main CNI config file to exist before returning // Or until cancelled by parent context func getCNIConfigFilepath(ctx context.Context, cfg pluginConfig) (string, error) { filename := cfg.cniConfName if !cfg.chainedCNIPlugin { if len(filename) == 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// nolint: unparam func (z *ztunnelServer) handleConn(ctx context.Context, conn *ZtunnelConnection) error { defer conn.Close() context.AfterFunc(ctx, func() { log.Debug("context cancelled - closing conn") conn.Close() }) // before doing anything, add the connection to the list of active connections z.conns.addConn(conn) defer z.conns.deleteConn(conn)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/cmd/root.go
// installer.Run() will block indefinitely, and attempt to permanently "keep" // the CNI binary installed. if err = installer.Run(ctx); err != nil { if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { log.Infof("installer complete: %v", err) // Error was caused by interrupt/termination signal err = nil } else { log.Errorf("installer failed: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0)