Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for WithStreamInterceptor (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    		// 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 {
    		dialer := func(ctx context.Context, addr string) (net.Conn, error) {
    			if strings.Contains(addr, "//") {
    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