type google.golang.org/grpc.CallOption

56 uses

	google.golang.org/grpc (current package)
		balancer_wrapper.go#L365: func (acbw *acBalancerWrapper) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
		balancer_wrapper.go#L376: func (acbw *acBalancerWrapper) Invoke(ctx context.Context, method string, args any, reply any, opts ...CallOption) error {
		call.go#L29: func (cc *ClientConn) Invoke(ctx context.Context, method string, args, reply any, opts ...CallOption) error {
		call.go#L40: func combine(o1 []CallOption, o2 []CallOption) []CallOption {
		call.go#L49: 	ret := make([]CallOption, len(o1)+len(o2))
		call.go#L59: func Invoke(ctx context.Context, method string, args, reply any, cc *ClientConn, opts ...CallOption) error {
		call.go#L65: func invoke(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error {
		clientconn.go#L476: 		chainedInt = func(ctx context.Context, method string, req, reply any, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error {
		clientconn.go#L488: 	return func(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error {
		clientconn.go#L507: 		chainedInt = func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error) {
		clientconn.go#L519: 	return func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
		clientconn.go#L592: 	Invoke(ctx context.Context, method string, args any, reply any, opts ...CallOption) error
		clientconn.go#L594: 	NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)
		dialoptions.go#L85: 	callOptions                 []CallOption
		dialoptions.go#L260: func WithDefaultCallOptions(cos ...CallOption) DialOption {
		interceptor.go#L26: type UnaryInvoker func(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error
		interceptor.go#L43: type UnaryClientInterceptor func(ctx context.Context, method string, req, reply any, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error
		interceptor.go#L46: type Streamer func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error)
		interceptor.go#L63: type StreamClientInterceptor func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error)
		rpc_util.go#L175: type CallOption interface {
		rpc_util.go#L197: func StaticMethod() CallOption {
		rpc_util.go#L209: func Header(md *metadata.MD) CallOption {
		rpc_util.go#L231: func Trailer(md *metadata.MD) CallOption {
		rpc_util.go#L253: func Peer(p *peer.Peer) CallOption {
		rpc_util.go#L282: func WaitForReady(waitForReady bool) CallOption {
		rpc_util.go#L289: func FailFast(failFast bool) CallOption {
		rpc_util.go#L321: func OnFinish(onFinish func(err error)) CallOption {
		rpc_util.go#L348: func MaxCallRecvMsgSize(bytes int) CallOption {
		rpc_util.go#L377: func CallAuthority(authority string) CallOption {
		rpc_util.go#L402: func MaxCallSendMsgSize(bytes int) CallOption {
		rpc_util.go#L425: func PerRPCCredentials(creds credentials.PerRPCCredentials) CallOption {
		rpc_util.go#L454: func UseCompressor(name string) CallOption {
		rpc_util.go#L490: func CallContentSubtype(contentSubtype string) CallOption {
		rpc_util.go#L529: func ForceCodec(codec encoding.Codec) CallOption {
		rpc_util.go#L568: func ForceCodecV2(codec encoding.CodecV2) CallOption {
		rpc_util.go#L594: func CallCustomCodec(codec Codec) CallOption {
		rpc_util.go#L622: func MaxRetryRPCBufferSize(bytes int) CallOption {
		stream.go#L164: func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
		stream.go#L176: func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
		stream.go#L180: func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
		stream.go#L189: 	opts = append([]CallOption{OnFinish(func(error) { cc.idlenessMgr.OnCallEnd() })}, opts...)
		stream.go#L261: func newClientStreamWithParams(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, mc serviceconfig.MethodConfig, onCommit, doneFunc func(), nameResolutionDelayed bool, opts ...CallOption) (_ iresolver.ClientStream, err error) {
		stream.go#L539: 	opts     []CallOption
		stream.go#L1247: func newNonRetryClientStream(ctx context.Context, desc *StreamDesc, method string, t transport.ClientTransport, ac *addrConn, opts ...CallOption) (_ ClientStream, err error) {
		stream.go#L1357: 	opts             []CallOption

	google.golang.org/grpc/health/grpc_health_v1
		health_grpc.pb.go#L59: 	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
		health_grpc.pb.go#L71: 	List(ctx context.Context, in *HealthListRequest, opts ...grpc.CallOption) (*HealthListResponse, error)
		health_grpc.pb.go#L87: 	Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HealthCheckResponse], error)
		health_grpc.pb.go#L98: func (c *healthClient) Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) {
		health_grpc.pb.go#L99: 	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
		health_grpc.pb.go#L108: func (c *healthClient) List(ctx context.Context, in *HealthListRequest, opts ...grpc.CallOption) (*HealthListResponse, error) {
		health_grpc.pb.go#L109: 	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
		health_grpc.pb.go#L118: func (c *healthClient) Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HealthCheckResponse], error) {
		health_grpc.pb.go#L119: 	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)