client

Documentation

Index

• Constants
• 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, product ...string) context.Context
• func WithMetadata(incomingMD *common.Metadata, keyID int64) context.Context
• type ConnPool
  • func ContextConnPool(ctx context.Context) ConnPool
  • func Implementor() ConnPool

Constants

const (
	DefaultIssuer = "appootb"
)

Functions

func ContextWithConnPool

func ContextWithConnPool(ctx context.Context) context.Context

func RegisterImplementor

func RegisterImplementor(cp ConnPool)

RegisterImplementor registers the gRPC connection pool 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, product ...string) context.Context

func WithMetadata

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

Types

type ConnPool

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

ConnPool is gRPC client connection pool interface.

func ContextConnPool

func ContextConnPool(ctx context.Context) ConnPool

func Implementor

func Implementor() ConnPool

Implementor returns the gRPC connection pool service implementor.