Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for WaitForReady (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top