interceptor

Documentation

Index

• Variables
• func NewStreamRetry(retryOpts RetryOptions) grpc.StreamClientInterceptor
• func NewUnaryRetry(retryOpts RetryOptions) grpc.UnaryClientInterceptor
• type RetryOptions

Variables

var RPCNeedRetry = map[string]struct{}{
	"/pb.CoreRPC/WorkloadStatusStream": {},
	"/pb.CoreRPC/WatchServiceStatus":   {},
}

RPCNeedRetry records rpc stream methods to retry

Functions

func NewStreamRetry

func NewStreamRetry(retryOpts RetryOptions) grpc.StreamClientInterceptor

NewStreamRetry make specific stream retry on error

func NewUnaryRetry

func NewUnaryRetry(retryOpts RetryOptions) grpc.UnaryClientInterceptor

NewUnaryRetry makes unary RPC retry on error

Types

type RetryOptions

type RetryOptions struct {
	Max int
}

RetryOptions .