grpcshim

package
v0.39.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 7, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT. with command: counterfeiter -p -o /Users/pivotal/workspace/diego-release/src/code.cloudfoundry.org/goshims/grpcshim google.golang.org/grpc

Code generated by counterfeiter. DO NOT EDIT. with command: counterfeiter -p -o /Users/pivotal/workspace/diego-release/src/code.cloudfoundry.org/goshims/grpcshim google.golang.org/grpc

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientConn 

type ClientConn interface {
	Close() error
}

type ClientConnShim 

type ClientConnShim struct {
	ClientConn *grpc.ClientConn
}

func (*ClientConnShim) Close 

func (c *ClientConnShim) Close() error

type Grpc 

type Grpc interface {
	RoundRobin(r naming.Resolver) grpc.Balancer
	Invoke(ctx context.Context, method string, args, reply interface{}, cc *grpc.ClientConn, opts ...grpc.CallOption) error
	WithCodec(c grpc.Codec) grpc.DialOption
	WithCompressor(cp grpc.Compressor) grpc.DialOption
	WithDecompressor(dc grpc.Decompressor) grpc.DialOption
	WithBalancer(b grpc.Balancer) grpc.DialOption
	WithServiceConfig(c <-chan grpc.ServiceConfig) grpc.DialOption
	WithBackoffMaxDelay(md time.Duration) grpc.DialOption
	WithBackoffConfig(b grpc.BackoffConfig) grpc.DialOption
	WithBlock() grpc.DialOption
	WithInsecure() grpc.DialOption
	WithTransportCredentials(creds credentials.TransportCredentials) grpc.DialOption
	WithPerRPCCredentials(creds credentials.PerRPCCredentials) grpc.DialOption
	WithTimeout(d time.Duration) grpc.DialOption
	WithDialer(f func(string, time.Duration) (net.Conn, error)) grpc.DialOption
	WithStatsHandler(h stats.Handler) grpc.DialOption
	FailOnNonTempDialError(f bool) grpc.DialOption
	WithUserAgent(s string) grpc.DialOption
	WithUnaryInterceptor(f grpc.UnaryClientInterceptor) grpc.DialOption
	WithStreamInterceptor(f grpc.StreamClientInterceptor) grpc.DialOption
	Dial(target string, opts ...grpc.DialOption) (ClientConn, error)
	DialContext(ctx context.Context, target string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)
	NewGZIPCompressor() grpc.Compressor
	NewGZIPDecompressor() grpc.Decompressor
	Header(md *metadata.MD) grpc.CallOption
	Trailer(md *metadata.MD) grpc.CallOption
	FailFast(failFast bool) grpc.CallOption
	Code(err error) codes.Code
	ErrorDesc(err error) string
	Errorf(c codes.Code, format string, a ...interface{}) error
	CustomCodec(codec grpc.Codec) grpc.ServerOption
	RPCCompressor(cp grpc.Compressor) grpc.ServerOption
	RPCDecompressor(dc grpc.Decompressor) grpc.ServerOption
	MaxMsgSize(m int) grpc.ServerOption
	MaxConcurrentStreams(n uint32) grpc.ServerOption
	Creds(c credentials.TransportCredentials) grpc.ServerOption
	UnaryInterceptor(i grpc.UnaryServerInterceptor) grpc.ServerOption
	StreamInterceptor(i grpc.StreamServerInterceptor) grpc.ServerOption
	InTapHandle(h tap.ServerInHandle) grpc.ServerOption
	StatsHandler(h stats.Handler) grpc.ServerOption
	NewServer(opt ...grpc.ServerOption) *grpc.Server
	SetHeader(ctx context.Context, md metadata.MD) error
	SendHeader(ctx context.Context, md metadata.MD) error
	SetTrailer(ctx context.Context, md metadata.MD) error
	NewClientStream(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, opts ...grpc.CallOption) (_ grpc.ClientStream, err error)
}

type GrpcShim 

type GrpcShim struct{}

func (*GrpcShim) Code 

func (sh *GrpcShim) Code(err error) codes.Code

func (*GrpcShim) Creds 

func (sh *GrpcShim) Creds(c credentials.TransportCredentials) grpc.ServerOption

func (*GrpcShim) CustomCodec 

func (sh *GrpcShim) CustomCodec(codec grpc.Codec) grpc.ServerOption

func (*GrpcShim) Dial 

func (sh *GrpcShim) Dial(target string, opts ...grpc.DialOption) (ClientConn, error)

func (*GrpcShim) DialContext 

func (sh *GrpcShim) DialContext(ctx context.Context, target string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)

func (*GrpcShim) ErrorDesc 

func (sh *GrpcShim) ErrorDesc(err error) string

func (*GrpcShim) Errorf 

func (sh *GrpcShim) Errorf(c codes.Code, format string, a ...interface{}) error

func (*GrpcShim) FailFast 

func (sh *GrpcShim) FailFast(failFast bool) grpc.CallOption

func (*GrpcShim) FailOnNonTempDialError 

func (sh *GrpcShim) FailOnNonTempDialError(f bool) grpc.DialOption

func (*GrpcShim) Header 

func (sh *GrpcShim) Header(md *metadata.MD) grpc.CallOption

func (*GrpcShim) InTapHandle 

func (sh *GrpcShim) InTapHandle(h tap.ServerInHandle) grpc.ServerOption

func (*GrpcShim) Invoke 

func (sh *GrpcShim) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, cc *grpc.ClientConn, opts ...grpc.CallOption) error

func (*GrpcShim) MaxConcurrentStreams 

func (sh *GrpcShim) MaxConcurrentStreams(n uint32) grpc.ServerOption

func (*GrpcShim) MaxMsgSize 

func (sh *GrpcShim) MaxMsgSize(m int) grpc.ServerOption

func (*GrpcShim) NewClientStream 

func (sh *GrpcShim) NewClientStream(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, opts ...grpc.CallOption) (_ grpc.ClientStream, err error)

func (*GrpcShim) NewGZIPCompressor 

func (sh *GrpcShim) NewGZIPCompressor() grpc.Compressor

func (*GrpcShim) NewGZIPDecompressor 

func (sh *GrpcShim) NewGZIPDecompressor() grpc.Decompressor

func (*GrpcShim) NewServer 

func (sh *GrpcShim) NewServer(opt ...grpc.ServerOption) *grpc.Server

func (*GrpcShim) RPCCompressor 

func (sh *GrpcShim) RPCCompressor(cp grpc.Compressor) grpc.ServerOption

func (*GrpcShim) RPCDecompressor 

func (sh *GrpcShim) RPCDecompressor(dc grpc.Decompressor) grpc.ServerOption

func (*GrpcShim) RoundRobin 

func (sh *GrpcShim) RoundRobin(r naming.Resolver) grpc.Balancer

func (*GrpcShim) SendHeader 

func (sh *GrpcShim) SendHeader(ctx context.Context, md metadata.MD) error

func (*GrpcShim) SetHeader 

func (sh *GrpcShim) SetHeader(ctx context.Context, md metadata.MD) error

func (*GrpcShim) SetTrailer 

func (sh *GrpcShim) SetTrailer(ctx context.Context, md metadata.MD) error

func (*GrpcShim) StatsHandler 

func (sh *GrpcShim) StatsHandler(h stats.Handler) grpc.ServerOption

func (*GrpcShim) StreamInterceptor 

func (sh *GrpcShim) StreamInterceptor(i grpc.StreamServerInterceptor) grpc.ServerOption

func (*GrpcShim) Trailer 

func (sh *GrpcShim) Trailer(md *metadata.MD) grpc.CallOption

func (*GrpcShim) UnaryInterceptor 

func (sh *GrpcShim) UnaryInterceptor(i grpc.UnaryServerInterceptor) grpc.ServerOption

func (*GrpcShim) WithBackoffConfig 

func (sh *GrpcShim) WithBackoffConfig(b grpc.BackoffConfig) grpc.DialOption

func (*GrpcShim) WithBackoffMaxDelay 

func (sh *GrpcShim) WithBackoffMaxDelay(md time.Duration) grpc.DialOption

func (*GrpcShim) WithBalancer 

func (sh *GrpcShim) WithBalancer(b grpc.Balancer) grpc.DialOption

func (*GrpcShim) WithBlock 

func (sh *GrpcShim) WithBlock() grpc.DialOption

func (*GrpcShim) WithCodec 

func (sh *GrpcShim) WithCodec(c grpc.Codec) grpc.DialOption

func (*GrpcShim) WithCompressor 

func (sh *GrpcShim) WithCompressor(cp grpc.Compressor) grpc.DialOption

func (*GrpcShim) WithDecompressor 

func (sh *GrpcShim) WithDecompressor(dc grpc.Decompressor) grpc.DialOption

func (*GrpcShim) WithDialer 

func (sh *GrpcShim) WithDialer(f func(string, time.Duration) (net.Conn, error)) grpc.DialOption

func (*GrpcShim) WithInsecure 

func (sh *GrpcShim) WithInsecure() grpc.DialOption

func (*GrpcShim) WithPerRPCCredentials 

func (sh *GrpcShim) WithPerRPCCredentials(creds credentials.PerRPCCredentials) grpc.DialOption

func (*GrpcShim) WithServiceConfig 

func (sh *GrpcShim) WithServiceConfig(c <-chan grpc.ServiceConfig) grpc.DialOption

func (*GrpcShim) WithStatsHandler 

func (sh *GrpcShim) WithStatsHandler(h stats.Handler) grpc.DialOption

func (*GrpcShim) WithStreamInterceptor 

func (sh *GrpcShim) WithStreamInterceptor(f grpc.StreamClientInterceptor) grpc.DialOption

func (*GrpcShim) WithTimeout 

func (sh *GrpcShim) WithTimeout(d time.Duration) grpc.DialOption

func (*GrpcShim) WithTransportCredentials 

func (sh *GrpcShim) WithTransportCredentials(creds credentials.TransportCredentials) grpc.DialOption

func (*GrpcShim) WithUnaryInterceptor 

func (sh *GrpcShim) WithUnaryInterceptor(f grpc.UnaryClientInterceptor) grpc.DialOption

func (*GrpcShim) WithUserAgent 

func (sh *GrpcShim) WithUserAgent(s string) grpc.DialOption

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.