type google.golang.org/grpc.CallOption
42 uses
google.golang.org/grpc (current package)
balancer_conn_wrappers.go#L426: func (acbw *acBalancerWrapper) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
balancer_conn_wrappers.go#L436: func (acbw *acBalancerWrapper) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...CallOption) error {
call.go#L29: func (cc *ClientConn) Invoke(ctx context.Context, method string, args, reply interface{}, 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 interface{}, cc *ClientConn, opts ...CallOption) error {
call.go#L65: func invoke(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error {
clientconn.go#L348: chainedInt = func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error {
clientconn.go#L360: return func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error {
clientconn.go#L379: chainedInt = func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error) {
clientconn.go#L391: return func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
clientconn.go#L447: Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...CallOption) error
clientconn.go#L449: NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)
dialoptions.go#L69: callOptions []CallOption
dialoptions.go#L184: func WithDefaultCallOptions(cos ...CallOption) DialOption {
interceptor.go#L26: type UnaryInvoker func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error
interceptor.go#L43: type UnaryClientInterceptor func(ctx context.Context, method string, req, reply interface{}, 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#L173: type CallOption interface {
rpc_util.go#L193: func Header(md *metadata.MD) CallOption {
rpc_util.go#L215: func Trailer(md *metadata.MD) CallOption {
rpc_util.go#L237: func Peer(p *peer.Peer) CallOption {
rpc_util.go#L270: func WaitForReady(waitForReady bool) CallOption {
rpc_util.go#L277: func FailFast(failFast bool) CallOption {
rpc_util.go#L301: func MaxCallRecvMsgSize(bytes int) CallOption {
rpc_util.go#L325: func MaxCallSendMsgSize(bytes int) CallOption {
rpc_util.go#L348: func PerRPCCredentials(creds credentials.PerRPCCredentials) CallOption {
rpc_util.go#L377: func UseCompressor(name string) CallOption {
rpc_util.go#L413: func CallContentSubtype(contentSubtype string) CallOption {
rpc_util.go#L452: func ForceCodec(codec encoding.Codec) CallOption {
rpc_util.go#L477: func CallCustomCodec(codec Codec) CallOption {
rpc_util.go#L505: func MaxRetryRPCBufferSize(bytes int) CallOption {
stream.go#L154: func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L166: func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L170: func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L231: func newClientStreamWithParams(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, mc serviceconfig.MethodConfig, onCommit, doneFunc func(), opts ...CallOption) (_ iresolver.ClientStream, err error) {
stream.go#L500: opts []CallOption
stream.go#L1172: func newNonRetryClientStream(ctx context.Context, desc *StreamDesc, method string, t transport.ClientTransport, ac *addrConn, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L1277: opts []CallOption