- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 237 for withCancel (0.14 sec)
-
internal/http/listener.go
return } listener = &httpListener{ listeners: listeners, acceptCh: make(chan acceptResult, len(listeners)), opts: opts, } listener.ctx, listener.ctxCanceler = context.WithCancel(ctx) if opts.Trace != nil { opts.Trace(fmt.Sprint("opening ", len(listener.listeners), " listeners")) } listener.start() return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
cmd/kube-scheduler/app/testing/testserver.go
// enough time to remove temporary files. func StartTestServer(ctx context.Context, customFlags []string) (result TestServer, err error) { logger := klog.FromContext(ctx) ctx, cancel := context.WithCancel(ctx) var errCh chan error tearDown := func() { cancel() // If the scheduler was started, let's wait for it to // shutdown clearly. if errCh != nil { err, ok := <-errCh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 10:35:59 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go
alwaysRetry := func(e error) bool { return true } attemptsGot := 0 webhookFunc := func() error { attemptsGot++ return nil } ctx, cancel := context.WithCancel(context.TODO()) cancel() // We don't expect the webhook function to be called since the context is already canceled. retryBackoff := wait.Backoff{Steps: 5}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
compactor.cancel() compactor.client.Close() } else { // start new compactor compactor = &runningCompactor{} compactors[key] = compactor } ctx, cancel := context.WithCancel(context.Background()) compactor.interval = interval compactor.cancel = cancel compactor.client = compactorClient etcd3.StartCompactor(ctx, compactorClient, interval) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
// NewWebhookTarget - creates new Webhook target. func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) { ctx, cancel := context.WithCancel(ctx) target := &WebhookTarget{ id: event.TargetID{ID: id, Name: "webhook"}, args: args, loggerOnce: loggerOnce, transport: transport, cancel: cancel,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/scheduler/util/utils_test.go
}) pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo"}, Status: v1.PodStatus{NominatedNodeName: test.currentNominatedNodeName}, } ctx, cancel := context.WithCancel(context.Background()) defer cancel() if err := ClearNominatedNodeName(ctx, cs, pod); err != nil { t.Fatalf("Error calling removeNominatedNodeName: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 14.5K bytes - Viewed (0) -
cmd/ftp-server-driver.go
stopFn := globalFtpMetrics.log(ctx, objPath) defer stopFn(0, err) clnt, err := driver.getMinIOClient(ctx) if err != nil { return err } cctx, cancel := context.WithCancel(context.Background()) defer cancel() bucket, prefix := path2BucketObject(objPath) if bucket == "" { buckets, err := clnt.ListBuckets(cctx) if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 14K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager_test.go
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.SeparateTaintEvictionController, test.enableFeatureGate) _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() controllerCtx := ControllerContext{} controllerCtx.ComponentConfig.Generic.Controllers = []string{names.TaintEvictionController} initFuncCalled := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/kube-controller-manager/app/testing/testserver.go
// enough time to remove temporary files. func StartTestServer(ctx context.Context, customFlags []string) (result TestServer, err error) { logger := klog.FromContext(ctx) ctx, cancel := context.WithCancel(ctx) var errCh chan error tearDown := func() { cancel() // If the kube-controller-manager was started, let's wait for // it to shutdown cleanly. if errCh != nil { err, ok := <-errCh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/plugin.go
return err } c.source = c.sourceFactory(c.informerFactory, c.client, c.dynamicClient, c.restMapper) c.dispatcher = c.dispatcherFactory(c.authorizer, c.matcher) pluginContext, pluginContextCancel := context.WithCancel(context.Background()) go func() { defer pluginContextCancel() <-c.stopCh }() go func() { err := c.source.Run(pluginContext) if err != nil && !errors.Is(err, context.Canceled) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 19:11:10 UTC 2024 - 6.6K bytes - Viewed (0)