Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.