client

Documentation

Index

• func ChainUnaryClientInterceptors(is ...grpc.UnaryClientInterceptor) grpc.UnaryClientInterceptor
• func LogUnaryClientInterceptor(logger *zap.Logger) grpc.UnaryClientInterceptor
• func MetricsUnaryClientInterceptor() grpc.UnaryClientInterceptor
• func NewClientConn(addr string, certPath string, opts ...Option) (*grpc.ClientConn, error)
• func NewPerRPCCredentials(tokenPath string) (credentials.PerRPCCredentials, error)
• func XRequestIDUnaryClientInterceptor() grpc.UnaryClientInterceptor
• type Option
  • func WithBlock() Option
  • func WithDialTimeout(d time.Duration) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMetrics(registerer metrics.Registerer) Option
  • func WithPerRPCCredentials(creds credentials.PerRPCCredentials) Option
  • func WithStatsHandler(handler stats.Handler) Option

Functions

func ChainUnaryClientInterceptors

func ChainUnaryClientInterceptors(is ...grpc.UnaryClientInterceptor) grpc.UnaryClientInterceptor

func LogUnaryClientInterceptor

func LogUnaryClientInterceptor(logger *zap.Logger) grpc.UnaryClientInterceptor

func MetricsUnaryClientInterceptor

func MetricsUnaryClientInterceptor() grpc.UnaryClientInterceptor

func NewClientConn

func NewClientConn(addr string, certPath string, opts ...Option) (*grpc.ClientConn, error)

func NewPerRPCCredentials

func NewPerRPCCredentials(tokenPath string) (credentials.PerRPCCredentials, error)

func XRequestIDUnaryClientInterceptor

func XRequestIDUnaryClientInterceptor() grpc.UnaryClientInterceptor

Types

type Option

type Option func(*options)

func WithBlock

func WithBlock() Option

func WithDialTimeout

func WithDialTimeout(d time.Duration) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMetrics

func WithMetrics(registerer metrics.Registerer) Option

func WithPerRPCCredentials

func WithPerRPCCredentials(creds credentials.PerRPCCredentials) Option

func WithStatsHandler

func WithStatsHandler(handler stats.Handler) Option