Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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 retries the stream methods listed in RPCNeedRetry.
func NewUnaryRetry ¶
func NewUnaryRetry(retryOpts RetryOptions) grpc.UnaryClientInterceptor
NewUnaryRetry makes unary RPC retry on error
Types ¶
type RetryOptions ¶
type RetryOptions struct {
Max uint64
}
Source Files
Click to show internal directories.
Click to hide internal directories.