- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WaitForReady (0.24 sec)
-
plugin/pkg/admission/podnodeselector/admission.go
func (p *Plugin) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error { if shouldIgnore(a) { return nil } if !p.WaitForReady() { return admission.NewForbidden(a, fmt.Errorf("not yet ready to handle request")) } resource := a.GetResource().GroupResource() pod := a.GetObject().(*api.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service.go
return nil, err } s := &gRPCService{callTimeout: callTimeout} s.connection, err = grpc.Dial( addr, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithDefaultCallOptions(grpc.WaitForReady(true)), grpc.WithContextDialer( func(context.Context, string) (net.Conn, error) { // Ignoring addr and timeout arguments: // addr - comes from the closure
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 23:18:16 UTC 2023 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service.go
s := &gRPCService{callTimeout: callTimeout} s.connection, err = grpc.Dial( addr, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithUnaryInterceptor(s.interceptor), grpc.WithDefaultCallOptions(grpc.WaitForReady(true)), grpc.WithContextDialer( func(context.Context, string) (net.Conn, error) { // Ignoring addr and timeout arguments: // addr - comes from the closure
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 00:47:46 UTC 2023 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/plugin.go
ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces, ) (err error) { if !c.enabled { return nil } else if c.shouldIgnoreResource(a) { return nil } else if !c.WaitForReady() { return admission.NewForbidden(a, fmt.Errorf("not yet ready to handle request")) } return c.dispatcher.Dispatch(ctx, a, o, c.source.Hooks()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 19:11:10 UTC 2024 - 6.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go
func (a *Webhook) Dispatch(ctx context.Context, attr admission.Attributes, o admission.ObjectInterfaces) error { if rules.IsExemptAdmissionConfigurationResource(attr) { return nil } if !a.WaitForReady() { return admission.NewForbidden(attr, fmt.Errorf("not yet ready to handle request")) } hooks := a.hookSource.Webhooks() return a.dispatcher.Dispatch(ctx, attr, o, hooks)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 9.3K bytes - Viewed (0)