Versions in this module Expand all Collapse all v5 v5.0.0 Dec 18, 2020 Changes in this version + const Version + const VersionHeader + var DefaultCircuitBreakerSettings = CircuitBreakerSettings + func WithRetryPolicy(ctx context.Context, retryPolicy RetryPolicy) context.Context + type CircuitBreakerSettings struct + ErrorPercentThreshold int + MaxConcurrentRequests int + RequestVolumeThreshold int + SleepWindow int + type Client interface + NilCheck func(ctx context.Context, i *models.NilCheckInput) error + type ExponentialRetryPolicy struct + func (ExponentialRetryPolicy) Backoffs() []time.Duration + func (ExponentialRetryPolicy) Retry(req *http.Request, resp *http.Response, err error) bool + type HystrixSSEEvent struct + CurrentConcurrentExecutionCount int + ErrorCount int + ErrorPercentage int + IsCircuitBreakerOpen bool + LatencyTotalMean int + Name string + RequestCount int + RollingCountFailure int + RollingCountFallbackFailure int + RollingCountFallbackSuccess int + RollingCountShortCircuited int + RollingCountSuccess int + RollingCountThreadPoolRejected int + RollingCountTimeout int + Type string + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *MockClient + func (m *MockClient) EXPECT() *MockClientMockRecorder + func (m *MockClient) NilCheck(ctx context.Context, i *models.NilCheckInput) error + type MockClientMockRecorder struct + func (mr *MockClientMockRecorder) NilCheck(ctx, i interface{}) *gomock.Call + type NoRetryPolicy struct + func (NoRetryPolicy) Backoffs() []time.Duration + func (NoRetryPolicy) Retry(*http.Request, *http.Response, error) bool + type RetryPolicy interface + Backoffs func() []time.Duration + Retry func(*http.Request, *http.Response, error) bool + type SingleRetryPolicy struct + func (SingleRetryPolicy) Backoffs() []time.Duration + func (SingleRetryPolicy) Retry(req *http.Request, resp *http.Response, err error) bool + type WagClient struct + func New(basePath string) *WagClient + func NewFromDiscovery() (*WagClient, error) + func (c *WagClient) NilCheck(ctx context.Context, i *models.NilCheckInput) error + func (c *WagClient) SetCircuitBreakerDebug(b bool) + func (c *WagClient) SetCircuitBreakerSettings(settings CircuitBreakerSettings) + func (c *WagClient) SetLogger(logger logger.KayveeLogger) + func (c *WagClient) SetRetryPolicy(retryPolicy RetryPolicy) + func (c *WagClient) SetTimeout(timeout time.Duration) + func (c *WagClient) SetTransport(t http.RoundTripper) Other modules containing this package github.com/Clever/wag github.com/Clever/wag/v6
Go to main page