retry

Jun 13, 2023

Changes in this version

+ const AttemptMetadataKey

+ var DefaultRetriableCodes = []codes.Code

+ func StreamClientInterceptor(optFuncs ...CallOption) grpc.StreamClientInterceptor

+ func UnaryClientInterceptor(optFuncs ...CallOption) grpc.UnaryClientInterceptor

+ func UnaryClientInterceptorRE(optFuncs ...CallOption) grpc.UnaryClientInterceptor

+ type BackoffFunc func(ctx context.Context, attempt uint) time.Duration

+ func BackoffExponential(scalar time.Duration) BackoffFunc

+ func BackoffLinear(waitBetween time.Duration) BackoffFunc

+ func BackoffLinearWithJitter(waitBetween time.Duration, jitterFraction float64) BackoffFunc

+ type CallOption struct

+ func WithBackoff(bf BackoffFunc) CallOption

+ func WithCodes(retryCodes ...codes.Code) CallOption

+ func WithMax(maxRetries uint) CallOption

+ func WithOnRetryCallback(fn OnRetryCallback) CallOption

+ func WithPerRetryTimeout(timeout time.Duration) CallOption

+ type OnRetryCallback func(ctx context.Context, attempt uint, err error)