client

Documentation

Index

• func ContextWithConnPool(ctx context.Context) context.Context
• func RegisterImplementor(cp ConnPool)
• func StreamServerInterceptor() grpc.StreamServerInterceptor
• func UnaryServerInterceptor() grpc.UnaryServerInterceptor
• func WithContext(ctx context.Context, keyID int64) context.Context
• func WithMetadata(md *common.Metadata, keyID int64) context.Context
• type ConnPool
  • func ContextConnPool(ctx context.Context) ConnPool
  • func Implementor() ConnPool

Functions

func ContextWithConnPool

func ContextWithConnPool(ctx context.Context) context.Context

func RegisterImplementor

func RegisterImplementor(cp ConnPool)

Register service implementor.

func StreamServerInterceptor

func StreamServerInterceptor() grpc.StreamServerInterceptor

StreamServerInterceptor returns a new streaming server interceptor for gRPC client connection pool.

func UnaryServerInterceptor

func UnaryServerInterceptor() grpc.UnaryServerInterceptor

UnaryServerInterceptor returns a new unary server interceptor for gRPC client connection pool.

func WithContext

func WithContext(ctx context.Context, keyID int64) context.Context

func WithMetadata

func WithMetadata(md *common.Metadata, keyID int64) context.Context

Types

type ConnPool

type ConnPool interface {
	Get(target string) *grpc.ClientConn
	Close()
}

gRPC client connection pool interface.

func ContextConnPool

func ContextConnPool(ctx context.Context) ConnPool

func Implementor

func Implementor() ConnPool

Return the service implementor.