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 make specific stream retry on error
func NewUnaryRetry ¶
func NewUnaryRetry(retryOpts RetryOptions) grpc.UnaryClientInterceptor
NewUnaryRetry makes unary RPC retry on error
Types ¶
Click to show internal directories.
Click to hide internal directories.