Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for WithUnaryInterceptor (0.33 sec)

  1. pkg/security/retry.go

    // around CARetryOptions. If needed to chain with other interceptors, the CARetryOptions can be used
    // directly.
    func CARetryInterceptor() grpc.DialOption {
    	return grpc.WithUnaryInterceptor(retry.UnaryClientInterceptor(CARetryOptions...))
    }
    
    // grpcretry has no hooks to trigger logic on failure (https://github.com/grpc-ecosystem/go-grpc-middleware/issues/375)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service.go

    	if err != nil {
    		return nil, err
    	}
    
    	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:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 00:47:46 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    		// Even with Noop  TracerProvider, the otelgrpc still handles context propagation.
    		// See https://github.com/open-telemetry/opentelemetry-go/tree/main/example/passthrough
    		dialOptions = append(dialOptions,
    			grpc.WithUnaryInterceptor(otelgrpc.UnaryClientInterceptor(tracingOpts...)),
    			grpc.WithStreamInterceptor(otelgrpc.StreamClientInterceptor(tracingOpts...)))
    	}
    	if egressDialer != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:56:39 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top