type google.golang.org/grpc.CallOption
58 uses
google.golang.org/grpc (current package)
balancer_wrapper.go#L361: func (acbw *acBalancerWrapper) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
balancer_wrapper.go#L372: 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#L533: chainedInt = func(ctx context.Context, method string, req, reply any, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error {
clientconn.go#L545: return func(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error {
clientconn.go#L564: chainedInt = func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error) {
clientconn.go#L576: return func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
clientconn.go#L649: Invoke(ctx context.Context, method string, args any, reply any, opts ...CallOption) error
clientconn.go#L651: NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)
dialoptions.go#L85: callOptions []CallOption
dialoptions.go#L274: 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#L234: type CallOption interface {
rpc_util.go#L256: func StaticMethod() CallOption {
rpc_util.go#L268: func Header(md *metadata.MD) CallOption {
rpc_util.go#L290: func Trailer(md *metadata.MD) CallOption {
rpc_util.go#L312: func Peer(p *peer.Peer) CallOption {
rpc_util.go#L341: func WaitForReady(waitForReady bool) CallOption {
rpc_util.go#L348: func FailFast(failFast bool) CallOption {
rpc_util.go#L380: func OnFinish(onFinish func(err error)) CallOption {
rpc_util.go#L407: func MaxCallRecvMsgSize(bytes int) CallOption {
rpc_util.go#L436: func CallAuthority(authority string) CallOption {
rpc_util.go#L461: func MaxCallSendMsgSize(bytes int) CallOption {
rpc_util.go#L484: func PerRPCCredentials(creds credentials.PerRPCCredentials) CallOption {
rpc_util.go#L513: func UseCompressor(name string) CallOption {
rpc_util.go#L537: func acceptCompressors(names ...string) CallOption {
rpc_util.go#L574: func CallContentSubtype(contentSubtype string) CallOption {
rpc_util.go#L613: func ForceCodec(codec encoding.Codec) CallOption {
rpc_util.go#L652: func ForceCodecV2(codec encoding.CodecV2) CallOption {
rpc_util.go#L678: func CallCustomCodec(codec Codec) CallOption {
rpc_util.go#L706: func MaxRetryRPCBufferSize(bytes int) CallOption {
stream.go#L167: func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L179: func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L188: func endOfClientStream(cc *ClientConn, err error, opts ...CallOption) {
stream.go#L204: func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L222: opts = append([]CallOption{OnFinish(func(error) { cc.idlenessMgr.OnCallEnd() })}, opts...)
stream.go#L286: 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#L576: opts []CallOption
stream.go#L1283: func newNonRetryClientStream(ctx context.Context, desc *StreamDesc, method string, t transport.ClientTransport, ac *addrConn, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L1395: 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...)