interceptors

Documentation

Index

• type GrpcRetry
  • func NewGrpcRetry(options ...RetryOption) *GrpcRetry
  • func (g *GrpcRetry) StreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)
  • func (g *GrpcRetry) UnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• type RetryOption
  • func RetryCodes(codes ...int) RetryOption

Types

type GrpcRetry

type GrpcRetry struct {
	// contains filtered or unexported fields
}

func NewGrpcRetry

func NewGrpcRetry(options ...RetryOption) *GrpcRetry

func (*GrpcRetry) StreamClientInterceptor

func (g *GrpcRetry) StreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

func (*GrpcRetry) UnaryClientInterceptor

func (g *GrpcRetry) UnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

type RetryOption

type RetryOption func(r *GrpcRetry)

func RetryCodes

func RetryCodes(codes ...int) RetryOption