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