Documentation
¶
Index ¶
- Constants
- func NewClient(timeout time.Duration, client operatorservice.OperatorServiceClient) operatorservice.OperatorServiceClient
- func NewMetricClient(client operatorservice.OperatorServiceClient, metricsHandler metrics.Handler, ...) operatorservice.OperatorServiceClient
- func NewRetryableClient(client operatorservice.OperatorServiceClient, policy backoff.RetryPolicy, ...) operatorservice.OperatorServiceClient
Constants ¶
View Source
const ( // DefaultTimeout is the default timeout used to make calls DefaultTimeout = 10 * time.Second * debug.TimeoutMultiplier )
Variables ¶
This section is empty.
Functions ¶
func NewClient ¶
func NewClient( timeout time.Duration, client operatorservice.OperatorServiceClient, ) operatorservice.OperatorServiceClient
NewClient creates a new operator service gRPC client
func NewMetricClient ¶
func NewMetricClient( client operatorservice.OperatorServiceClient, metricsHandler metrics.Handler, throttledLogger log.Logger, ) operatorservice.OperatorServiceClient
NewMetricClient creates a new instance of operatorservice.OperatorServiceClient that emits metrics
func NewRetryableClient ¶
func NewRetryableClient(client operatorservice.OperatorServiceClient, policy backoff.RetryPolicy, isRetryable backoff.IsRetryable) operatorservice.OperatorServiceClient
NewRetryableClient creates a new instance of operatorservice.OperatorServiceClient with retry policy
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.