- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Cancel (0.23 sec)
-
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 01 22:53:12 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 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
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 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
PodName: "pod-bingo", PodNamespace: "funkyns", IPs: []IPConfig{{ Address: *addr, }}, } setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod-bingo", Namespace: "funkyns", }, Spec: corev1.PodSpec{ NodeName: NodeName, },
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Feb 02 08:18:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
expectedFilepath = filepath.Join(tempDir, c.expectedConfName) } if !c.chainedCNIPlugin { // Standalone CNI plugin parent := context.Background() ctx1, cancel := context.WithTimeout(parent, 100*time.Millisecond) defer cancel() result, err := getCNIConfigFilepath(ctx1, cfg) if err != nil { assert.Equal(t, result, "") if err == context.DeadlineExceeded {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 17 02:22:22 GMT 2023 - 15.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
handlers K8sHandlers, dataplane MeshDataplane, ) *CniPluginServer { ctx, cancel := context.WithCancel(ctx) mux := http.NewServeMux() s := &CniPluginServer{ handlers: handlers, dataplane: dataplane, cniListenServer: &http.Server{ Handler: mux, }, cniListenServerCancel: cancel, sockAddress: pluginSocket, ctx: ctx, }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
var ztunnelTestCounter atomic.Uint32 func TestZtunnelSendsPodSnapshot(t *testing.T) { ztunnelKeepAliveCheckInterval = time.Second / 10 mt := monitortest.New(t) setupLogging() ctx, cancel := context.WithCancel(context.Background()) defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid m, fds := readRequest(t, ztunClient)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
resource.Namespace(ctx.Namespace()), resource.Namespace(ctx.IstioNamespace()), nil, ) if err != nil { return nil, err } sa.AddRunningKubeSource(cli) cancel := make(chan struct{}) result, err := sa.Analyze(cancel) if err != nil { return nil, err } if result.Messages != nil { msgs = append(msgs, result.Messages...) } return msgs, nil }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K 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 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/cmd/install-cni/main.go
) func main() { // Create context that cancels on termination signal ctx, cancel := context.WithCancel(context.Background()) sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM) go func(sigChan chan os.Signal, cancel context.CancelFunc) { sig := <-sigChan log.Infof("Exit signal received: %s", sig) cancel() }(sigChan, cancel) rootCmd := cmd.GetCommand()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.2K bytes - Viewed (0)