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
    }

      go:generate counterfeiter -o grpc_fake/fake_clientconn.go . ClientConn

      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)
      }

        go:generate counterfeiter -o grpc_fake/fake_grpc.go . Grpc

        type GrpcShim

        type GrpcShim struct{}

        func (*GrpcShim) Code

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

        func (*GrpcShim) Creds

        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

        Directories

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