httpclient

package module

Go to main page

Versions in this module

v1

v1.3.1

Jan 3, 2026

Changes in this version

type ClientOption

+ func WithCustomJsonMarshaler(marshal JSONMarshal) ClientOption

+ func WithCustomJsonUnmarshaler(unmarshal JSONUnmarshal) ClientOption

+ type JSONMarshal func(v interface{}) ([]byte, error)

+ type JSONUnmarshal func(data []byte, v interface{}) error

v1.3.0

Jan 3, 2026

Changes in this version

+ type AdaptiveThrottlerConfig struct

+ Enabled bool

+ FailureRateThreshold float64

+ MaxRejectionRate float64

+ MinExecutions uint

+ Period time.Duration

+ type BulkheadConfig struct

+ Enabled bool

+ MaxConcurrency uint

+ MaxWaitTime time.Duration

+ type CacheConfig struct

+ Cache cachepolicy.Cache[*http.Response]

+ Enabled bool

+ Key string

+ type HedgeConfig struct

+ CancelOnResult bool

+ Delay time.Duration

+ Enabled bool

+ MaxHedges int

+ type RateLimiterConfig struct

+ Enabled bool

+ IsBursty bool

+ MaxExecutions uint

+ MaxWaitTime time.Duration

+ Period time.Duration

type ResilienceBuilder

+ func (rb *ResilienceBuilder) WithAdaptiveThrottler(cfg *AdaptiveThrottlerConfig) *ResilienceBuilder

+ func (rb *ResilienceBuilder) WithBulkhead(cfg *BulkheadConfig) *ResilienceBuilder

+ func (rb *ResilienceBuilder) WithCache(cfg *CacheConfig) *ResilienceBuilder

+ func (rb *ResilienceBuilder) WithHedge(cfg *HedgeConfig) *ResilienceBuilder

+ func (rb *ResilienceBuilder) WithRateLimiter(cfg *RateLimiterConfig) *ResilienceBuilder

type ResilienceConfig

+ AdaptiveThrottler *AdaptiveThrottlerConfig

+ Bulkhead *BulkheadConfig

+ Cache *CacheConfig

+ Hedge *HedgeConfig

+ RateLimiter *RateLimiterConfig

v1.2.0

Jan 3, 2026

v1.1.5

Dec 24, 2025

v1.1.4

Dec 24, 2025

v1.1.3

Dec 24, 2025

Changes in this version

+ type MockErrorResponseParser struct

+ func NewMockErrorResponseParser(t interface{ ... }) *MockErrorResponseParser

+ func (_m *MockErrorResponseParser) EXPECT() *MockErrorResponseParser_Expecter

+ func (_mock *MockErrorResponseParser) CanParse(body []byte) bool

+ func (_mock *MockErrorResponseParser) Parse(body []byte) (*ParsedErrorResponse, error)

+ type MockErrorResponseParser_CanParse_Call struct

+ func (_c *MockErrorResponseParser_CanParse_Call) Return(b bool) *MockErrorResponseParser_CanParse_Call

+ func (_c *MockErrorResponseParser_CanParse_Call) Run(run func(body []byte)) *MockErrorResponseParser_CanParse_Call

+ func (_c *MockErrorResponseParser_CanParse_Call) RunAndReturn(run func(body []byte) bool) *MockErrorResponseParser_CanParse_Call

+ type MockErrorResponseParser_Expecter struct

+ func (_e *MockErrorResponseParser_Expecter) CanParse(body interface{}) *MockErrorResponseParser_CanParse_Call

+ func (_e *MockErrorResponseParser_Expecter) Parse(body interface{}) *MockErrorResponseParser_Parse_Call

+ type MockErrorResponseParser_Parse_Call struct

+ func (_c *MockErrorResponseParser_Parse_Call) Return(parsedErrorResponse *ParsedErrorResponse, err error) *MockErrorResponseParser_Parse_Call

+ func (_c *MockErrorResponseParser_Parse_Call) Run(run func(body []byte)) *MockErrorResponseParser_Parse_Call

+ func (_c *MockErrorResponseParser_Parse_Call) RunAndReturn(run func(body []byte) (*ParsedErrorResponse, error)) *MockErrorResponseParser_Parse_Call

+ type MockExecutor struct

+ func NewMockExecutor(t interface{ ... }) *MockExecutor

+ func (_m *MockExecutor) EXPECT() *MockExecutor_Expecter

+ func (_mock *MockExecutor) Delete(ctx context.Context, path string) (*http.Response, error)

+ func (_mock *MockExecutor) DeleteJSON(ctx context.Context, path string, result any) error

+ func (_mock *MockExecutor) Do(ctx context.Context, method string, path string, body any) (*http.Response, error)

+ func (_mock *MockExecutor) DoWithResponse(ctx context.Context, method string, path string, body any, result any) error

+ func (_mock *MockExecutor) Get(ctx context.Context, path string) (*http.Response, error)

+ func (_mock *MockExecutor) GetErrorParser() *ErrorParserChain

+ func (_mock *MockExecutor) GetHTTPClient() *http.Client

+ func (_mock *MockExecutor) GetJSON(ctx context.Context, path string, result any) error

+ func (_mock *MockExecutor) Patch(ctx context.Context, path string, body any) (*http.Response, error)

+ func (_mock *MockExecutor) PatchJSON(ctx context.Context, path string, body any, result any) error

+ func (_mock *MockExecutor) Post(ctx context.Context, path string, body any) (*http.Response, error)

+ func (_mock *MockExecutor) PostJSON(ctx context.Context, path string, body any, result any) error

+ func (_mock *MockExecutor) Put(ctx context.Context, path string, body any) (*http.Response, error)

+ func (_mock *MockExecutor) PutJSON(ctx context.Context, path string, body any, result any) error

+ func (_mock *MockExecutor) RemoveHeader(key string)

+ func (_mock *MockExecutor) SetBaseURL(baseURL string)

+ func (_mock *MockExecutor) SetErrorParser(parser *ErrorParserChain)

+ func (_mock *MockExecutor) SetHTTPClient(httpClient *http.Client)

+ func (_mock *MockExecutor) SetHeader(key string, value string)

+ func (_mock *MockExecutor) SetHeaders(headers map[string]string)

+ type MockExecutor_DeleteJSON_Call struct

+ func (_c *MockExecutor_DeleteJSON_Call) Return(err error) *MockExecutor_DeleteJSON_Call

+ func (_c *MockExecutor_DeleteJSON_Call) Run(run func(ctx context.Context, path string, result any)) *MockExecutor_DeleteJSON_Call

+ func (_c *MockExecutor_DeleteJSON_Call) RunAndReturn(run func(ctx context.Context, path string, result any) error) *MockExecutor_DeleteJSON_Call

+ type MockExecutor_Delete_Call struct

+ func (_c *MockExecutor_Delete_Call) Return(response *http.Response, err error) *MockExecutor_Delete_Call

+ func (_c *MockExecutor_Delete_Call) Run(run func(ctx context.Context, path string)) *MockExecutor_Delete_Call

+ func (_c *MockExecutor_Delete_Call) RunAndReturn(run func(ctx context.Context, path string) (*http.Response, error)) *MockExecutor_Delete_Call

+ type MockExecutor_DoWithResponse_Call struct

+ func (_c *MockExecutor_DoWithResponse_Call) Return(err error) *MockExecutor_DoWithResponse_Call

+ func (_c *MockExecutor_DoWithResponse_Call) Run(...) *MockExecutor_DoWithResponse_Call

+ func (_c *MockExecutor_DoWithResponse_Call) RunAndReturn(...) *MockExecutor_DoWithResponse_Call

+ type MockExecutor_Do_Call struct

+ func (_c *MockExecutor_Do_Call) Return(response *http.Response, err error) *MockExecutor_Do_Call

+ func (_c *MockExecutor_Do_Call) Run(run func(ctx context.Context, method string, path string, body any)) *MockExecutor_Do_Call

+ func (_c *MockExecutor_Do_Call) RunAndReturn(...) *MockExecutor_Do_Call

+ type MockExecutor_Expecter struct

+ func (_e *MockExecutor_Expecter) Delete(ctx interface{}, path interface{}) *MockExecutor_Delete_Call

+ func (_e *MockExecutor_Expecter) DeleteJSON(ctx interface{}, path interface{}, result interface{}) *MockExecutor_DeleteJSON_Call

+ func (_e *MockExecutor_Expecter) Do(ctx interface{}, method interface{}, path interface{}, body interface{}) *MockExecutor_Do_Call

+ func (_e *MockExecutor_Expecter) DoWithResponse(ctx interface{}, method interface{}, path interface{}, body interface{}, ...) *MockExecutor_DoWithResponse_Call

+ func (_e *MockExecutor_Expecter) Get(ctx interface{}, path interface{}) *MockExecutor_Get_Call

+ func (_e *MockExecutor_Expecter) GetErrorParser() *MockExecutor_GetErrorParser_Call

+ func (_e *MockExecutor_Expecter) GetHTTPClient() *MockExecutor_GetHTTPClient_Call

+ func (_e *MockExecutor_Expecter) GetJSON(ctx interface{}, path interface{}, result interface{}) *MockExecutor_GetJSON_Call

+ func (_e *MockExecutor_Expecter) Patch(ctx interface{}, path interface{}, body interface{}) *MockExecutor_Patch_Call

+ func (_e *MockExecutor_Expecter) PatchJSON(ctx interface{}, path interface{}, body interface{}, result interface{}) *MockExecutor_PatchJSON_Call

+ func (_e *MockExecutor_Expecter) Post(ctx interface{}, path interface{}, body interface{}) *MockExecutor_Post_Call

+ func (_e *MockExecutor_Expecter) PostJSON(ctx interface{}, path interface{}, body interface{}, result interface{}) *MockExecutor_PostJSON_Call

+ func (_e *MockExecutor_Expecter) Put(ctx interface{}, path interface{}, body interface{}) *MockExecutor_Put_Call

+ func (_e *MockExecutor_Expecter) PutJSON(ctx interface{}, path interface{}, body interface{}, result interface{}) *MockExecutor_PutJSON_Call

+ func (_e *MockExecutor_Expecter) RemoveHeader(key interface{}) *MockExecutor_RemoveHeader_Call

+ func (_e *MockExecutor_Expecter) SetBaseURL(baseURL interface{}) *MockExecutor_SetBaseURL_Call

+ func (_e *MockExecutor_Expecter) SetErrorParser(parser interface{}) *MockExecutor_SetErrorParser_Call

+ func (_e *MockExecutor_Expecter) SetHTTPClient(httpClient interface{}) *MockExecutor_SetHTTPClient_Call

+ func (_e *MockExecutor_Expecter) SetHeader(key interface{}, value interface{}) *MockExecutor_SetHeader_Call

+ func (_e *MockExecutor_Expecter) SetHeaders(headers interface{}) *MockExecutor_SetHeaders_Call

+ type MockExecutor_GetErrorParser_Call struct

+ func (_c *MockExecutor_GetErrorParser_Call) Return(errorParserChain *ErrorParserChain) *MockExecutor_GetErrorParser_Call

+ func (_c *MockExecutor_GetErrorParser_Call) Run(run func()) *MockExecutor_GetErrorParser_Call

+ func (_c *MockExecutor_GetErrorParser_Call) RunAndReturn(run func() *ErrorParserChain) *MockExecutor_GetErrorParser_Call

+ type MockExecutor_GetHTTPClient_Call struct

+ func (_c *MockExecutor_GetHTTPClient_Call) Return(client *http.Client) *MockExecutor_GetHTTPClient_Call

+ func (_c *MockExecutor_GetHTTPClient_Call) Run(run func()) *MockExecutor_GetHTTPClient_Call

+ func (_c *MockExecutor_GetHTTPClient_Call) RunAndReturn(run func() *http.Client) *MockExecutor_GetHTTPClient_Call

+ type MockExecutor_GetJSON_Call struct

+ func (_c *MockExecutor_GetJSON_Call) Return(err error) *MockExecutor_GetJSON_Call

+ func (_c *MockExecutor_GetJSON_Call) Run(run func(ctx context.Context, path string, result any)) *MockExecutor_GetJSON_Call

+ func (_c *MockExecutor_GetJSON_Call) RunAndReturn(run func(ctx context.Context, path string, result any) error) *MockExecutor_GetJSON_Call

+ type MockExecutor_Get_Call struct

+ func (_c *MockExecutor_Get_Call) Return(response *http.Response, err error) *MockExecutor_Get_Call

+ func (_c *MockExecutor_Get_Call) Run(run func(ctx context.Context, path string)) *MockExecutor_Get_Call

+ func (_c *MockExecutor_Get_Call) RunAndReturn(run func(ctx context.Context, path string) (*http.Response, error)) *MockExecutor_Get_Call

+ type MockExecutor_PatchJSON_Call struct

+ func (_c *MockExecutor_PatchJSON_Call) Return(err error) *MockExecutor_PatchJSON_Call

+ func (_c *MockExecutor_PatchJSON_Call) Run(run func(ctx context.Context, path string, body any, result any)) *MockExecutor_PatchJSON_Call

+ func (_c *MockExecutor_PatchJSON_Call) RunAndReturn(run func(ctx context.Context, path string, body any, result any) error) *MockExecutor_PatchJSON_Call

+ type MockExecutor_Patch_Call struct

+ func (_c *MockExecutor_Patch_Call) Return(response *http.Response, err error) *MockExecutor_Patch_Call

+ func (_c *MockExecutor_Patch_Call) Run(run func(ctx context.Context, path string, body any)) *MockExecutor_Patch_Call

+ func (_c *MockExecutor_Patch_Call) RunAndReturn(run func(ctx context.Context, path string, body any) (*http.Response, error)) *MockExecutor_Patch_Call

+ type MockExecutor_PostJSON_Call struct

+ func (_c *MockExecutor_PostJSON_Call) Return(err error) *MockExecutor_PostJSON_Call

+ func (_c *MockExecutor_PostJSON_Call) Run(run func(ctx context.Context, path string, body any, result any)) *MockExecutor_PostJSON_Call

+ func (_c *MockExecutor_PostJSON_Call) RunAndReturn(run func(ctx context.Context, path string, body any, result any) error) *MockExecutor_PostJSON_Call

+ type MockExecutor_Post_Call struct

+ func (_c *MockExecutor_Post_Call) Return(response *http.Response, err error) *MockExecutor_Post_Call

+ func (_c *MockExecutor_Post_Call) Run(run func(ctx context.Context, path string, body any)) *MockExecutor_Post_Call

+ func (_c *MockExecutor_Post_Call) RunAndReturn(run func(ctx context.Context, path string, body any) (*http.Response, error)) *MockExecutor_Post_Call

+ type MockExecutor_PutJSON_Call struct

+ func (_c *MockExecutor_PutJSON_Call) Return(err error) *MockExecutor_PutJSON_Call

+ func (_c *MockExecutor_PutJSON_Call) Run(run func(ctx context.Context, path string, body any, result any)) *MockExecutor_PutJSON_Call

+ func (_c *MockExecutor_PutJSON_Call) RunAndReturn(run func(ctx context.Context, path string, body any, result any) error) *MockExecutor_PutJSON_Call

+ type MockExecutor_Put_Call struct

+ func (_c *MockExecutor_Put_Call) Return(response *http.Response, err error) *MockExecutor_Put_Call

+ func (_c *MockExecutor_Put_Call) Run(run func(ctx context.Context, path string, body any)) *MockExecutor_Put_Call

+ func (_c *MockExecutor_Put_Call) RunAndReturn(run func(ctx context.Context, path string, body any) (*http.Response, error)) *MockExecutor_Put_Call

+ type MockExecutor_RemoveHeader_Call struct

+ func (_c *MockExecutor_RemoveHeader_Call) Return() *MockExecutor_RemoveHeader_Call

+ func (_c *MockExecutor_RemoveHeader_Call) Run(run func(key string)) *MockExecutor_RemoveHeader_Call

+ func (_c *MockExecutor_RemoveHeader_Call) RunAndReturn(run func(key string)) *MockExecutor_RemoveHeader_Call

+ type MockExecutor_SetBaseURL_Call struct

+ func (_c *MockExecutor_SetBaseURL_Call) Return() *MockExecutor_SetBaseURL_Call

+ func (_c *MockExecutor_SetBaseURL_Call) Run(run func(baseURL string)) *MockExecutor_SetBaseURL_Call

+ func (_c *MockExecutor_SetBaseURL_Call) RunAndReturn(run func(baseURL string)) *MockExecutor_SetBaseURL_Call

+ type MockExecutor_SetErrorParser_Call struct

+ func (_c *MockExecutor_SetErrorParser_Call) Return() *MockExecutor_SetErrorParser_Call

+ func (_c *MockExecutor_SetErrorParser_Call) Run(run func(parser *ErrorParserChain)) *MockExecutor_SetErrorParser_Call

+ func (_c *MockExecutor_SetErrorParser_Call) RunAndReturn(run func(parser *ErrorParserChain)) *MockExecutor_SetErrorParser_Call

+ type MockExecutor_SetHTTPClient_Call struct

+ func (_c *MockExecutor_SetHTTPClient_Call) Return() *MockExecutor_SetHTTPClient_Call

+ func (_c *MockExecutor_SetHTTPClient_Call) Run(run func(httpClient *http.Client)) *MockExecutor_SetHTTPClient_Call

+ func (_c *MockExecutor_SetHTTPClient_Call) RunAndReturn(run func(httpClient *http.Client)) *MockExecutor_SetHTTPClient_Call

+ type MockExecutor_SetHeader_Call struct

+ func (_c *MockExecutor_SetHeader_Call) Return() *MockExecutor_SetHeader_Call

+ func (_c *MockExecutor_SetHeader_Call) Run(run func(key string, value string)) *MockExecutor_SetHeader_Call

+ func (_c *MockExecutor_SetHeader_Call) RunAndReturn(run func(key string, value string)) *MockExecutor_SetHeader_Call

+ type MockExecutor_SetHeaders_Call struct

+ func (_c *MockExecutor_SetHeaders_Call) Return() *MockExecutor_SetHeaders_Call

+ func (_c *MockExecutor_SetHeaders_Call) Run(run func(headers map[string]string)) *MockExecutor_SetHeaders_Call

+ func (_c *MockExecutor_SetHeaders_Call) RunAndReturn(run func(headers map[string]string)) *MockExecutor_SetHeaders_Call

v1.1.2

Dec 24, 2025

Changes in this version

+ type Executor interface

+ Delete func(ctx context.Context, path string) (*http.Response, error)

+ DeleteJSON func(ctx context.Context, path string, result any) error

+ Do func(ctx context.Context, method, path string, body any) (*http.Response, error)

+ DoWithResponse func(ctx context.Context, method, path string, body, result any) error

+ Get func(ctx context.Context, path string) (*http.Response, error)

+ GetErrorParser func() *ErrorParserChain

+ GetHTTPClient func() *http.Client

+ GetJSON func(ctx context.Context, path string, result any) error

+ Patch func(ctx context.Context, path string, body any) (*http.Response, error)

+ PatchJSON func(ctx context.Context, path string, body, result any) error

+ Post func(ctx context.Context, path string, body any) (*http.Response, error)

+ PostJSON func(ctx context.Context, path string, body, result any) error

+ Put func(ctx context.Context, path string, body any) (*http.Response, error)

+ PutJSON func(ctx context.Context, path string, body, result any) error

+ RemoveHeader func(key string)

+ SetBaseURL func(baseURL string)

+ SetErrorParser func(parser *ErrorParserChain)

+ SetHTTPClient func(httpClient *http.Client)

+ SetHeader func(key, value string)

+ SetHeaders func(headers map[string]string)

v1.1.1

Dec 24, 2025

v1.1.0

Dec 24, 2025

Changes in this version

type Client

+ func (c *Client) GetErrorParser() *ErrorParserChain

+ func (c *Client) SetErrorParser(parser *ErrorParserChain)

type ClientOption

+ func WithErrorParser(parser ErrorResponseParser) ClientOption

type Error

+ CorrelationID string

+ Details map[string]interface{}

+ ErrorCode string

+ ResponseBody []byte

+ func (e *Error) GetDetail(key string) (interface{}, bool)

+ func (e *Error) HasDetail(key string) bool

+ type ErrorParserChain struct

+ func NewErrorParserChain() *ErrorParserChain

+ func (c *ErrorParserChain) AddParser(parser ErrorResponseParser)

+ func (c *ErrorParserChain) Parse(body []byte) (*ParsedErrorResponse, error)

+ type ErrorResponseParser interface

+ CanParse func(body []byte) bool

+ Parse func(body []byte) (*ParsedErrorResponse, error)

+ type GenericErrorParser struct

+ func (p *GenericErrorParser) CanParse(body []byte) bool

+ func (p *GenericErrorParser) Parse(body []byte) (*ParsedErrorResponse, error)

+ type ParsedErrorResponse struct

+ CorrelationID string

+ Details map[string]interface{}

+ ErrorCode string

+ Message string

+ type RFC7807ErrorParser struct

+ func (p *RFC7807ErrorParser) CanParse(body []byte) bool

+ func (p *RFC7807ErrorParser) Parse(body []byte) (*ParsedErrorResponse, error)

+ type StripeErrorParser struct

+ func (p *StripeErrorParser) CanParse(body []byte) bool

+ func (p *StripeErrorParser) Parse(body []byte) (*ParsedErrorResponse, error)

+ type SumsubErrorParser struct

+ func (p *SumsubErrorParser) CanParse(body []byte) bool

+ func (p *SumsubErrorParser) Parse(body []byte) (*ParsedErrorResponse, error)

v1.0.0

Dec 24, 2025

Changes in this version

+ func NewResilientClient(cfg *ResilienceConfig) *http.Client

+ func NewResilientTransport(baseTransport http.RoundTripper, cfg *ResilienceConfig) http.RoundTripper

+ type CircuitBreakerConfig struct

+ Delay time.Duration

+ Enabled bool

+ FailureThreshold uint

+ FailureThresholdRatio *ThresholdRatio

+ OnClose func(event circuitbreaker.StateChangedEvent)

+ OnHalfOpen func(event circuitbreaker.StateChangedEvent)

+ OnOpen func(event circuitbreaker.StateChangedEvent)

+ OnStateChanged func(event circuitbreaker.StateChangedEvent)

+ SuccessThreshold uint

+ SuccessThresholdRatio *ThresholdRatio

+ type Client struct

+ func NewClient(opts ...ClientOption) *Client

+ func NewDefaultClient(baseURL string) *Client

+ func (c *Client) Delete(ctx context.Context, path string) (*http.Response, error)

+ func (c *Client) DeleteJSON(ctx context.Context, path string, result interface{}) error

+ func (c *Client) Do(ctx context.Context, method, path string, body interface{}) (*http.Response, error)

+ func (c *Client) DoWithResponse(ctx context.Context, method, path string, body, result interface{}) error

+ func (c *Client) Get(ctx context.Context, path string) (*http.Response, error)

+ func (c *Client) GetHTTPClient() *http.Client

+ func (c *Client) GetJSON(ctx context.Context, path string, result interface{}) error

+ func (c *Client) Patch(ctx context.Context, path string, body interface{}) (*http.Response, error)

+ func (c *Client) PatchJSON(ctx context.Context, path string, body, result interface{}) error

+ func (c *Client) Post(ctx context.Context, path string, body interface{}) (*http.Response, error)

+ func (c *Client) PostJSON(ctx context.Context, path string, body, result interface{}) error

+ func (c *Client) Put(ctx context.Context, path string, body interface{}) (*http.Response, error)

+ func (c *Client) PutJSON(ctx context.Context, path string, body, result interface{}) error

+ func (c *Client) RemoveHeader(key string)

+ func (c *Client) SetBaseURL(baseURL string)

+ func (c *Client) SetHTTPClient(httpClient *http.Client)

+ func (c *Client) SetHeader(key, value string)

+ func (c *Client) SetHeaders(headers map[string]string)

+ type ClientOption func(*Client)

+ func WithBaseURL(baseURL string) ClientOption

+ func WithHTTPClient(httpClient *http.Client) ClientOption

+ func WithHeader(key, value string) ClientOption

+ func WithHeaders(headers map[string]string) ClientOption

+ func WithResilienceConfig(cfg *ResilienceConfig) ClientOption

+ func WithTimeout(timeout time.Duration) ClientOption

+ type Error struct

+ Err error

+ Message string

+ Method string

+ RequestID string

+ StatusCode int

+ Timestamp time.Time

+ Type ErrorType

+ URL string

+ func (e *Error) Error() string

+ func (e *Error) Unwrap() error

+ type ErrorType string

+ const ErrorTypeHTTP

+ const ErrorTypeNetwork

+ const ErrorTypeRetryExhausted

+ const ErrorTypeTimeout

+ const ErrorTypeUnknown

+ const ErrorTypeValidation

+ type FallbackConfig struct

+ Enabled bool

+ FallbackFunc func(exec failsafe.Execution[*http.Response]) (*http.Response, error)

+ OnFallbackExecuted func(event failsafe.ExecutionDoneEvent[*http.Response])

+ type ResilienceBuilder struct

+ func NewResilienceBuilder() *ResilienceBuilder

+ func (rb *ResilienceBuilder) Build() *ResilienceConfig

+ func (rb *ResilienceBuilder) WithCircuitBreaker(cfg *CircuitBreakerConfig) *ResilienceBuilder

+ func (rb *ResilienceBuilder) WithFallback(cfg *FallbackConfig) *ResilienceBuilder

+ func (rb *ResilienceBuilder) WithRetryPolicy(cfg *RetryPolicyConfig) *ResilienceBuilder

+ func (rb *ResilienceBuilder) WithTimeout(cfg *TimeoutConfig) *ResilienceBuilder

+ type ResilienceConfig struct

+ CircuitBreaker *CircuitBreakerConfig

+ Fallback *FallbackConfig

+ RetryPolicy *RetryPolicyConfig

+ Timeout *TimeoutConfig

+ func DefaultResilienceConfig() *ResilienceConfig

+ type RetryPolicyConfig struct

+ AbortOnStatus []int

+ BackoffInitial time.Duration

+ BackoffMax time.Duration

+ Delay time.Duration

+ Enabled bool

+ Jitter time.Duration

+ JitterFactor float64

+ MaxAttempts int

+ MaxDuration time.Duration

+ MaxRetries int

+ OnAbort func(event failsafe.ExecutionEvent[*http.Response])

+ OnRetriesExceeded func(event failsafe.ExecutionEvent[*http.Response])

+ OnRetry func(event failsafe.ExecutionEvent[*http.Response])

+ RandomDelayMax time.Duration

+ RandomDelayMin time.Duration

+ RetryableStatus []int

+ type ThresholdRatio struct

+ Failures uint

+ Total uint

+ type TimeoutConfig struct

+ Duration time.Duration

+ Enabled bool

+ OnTimeoutExceeded func(event failsafe.ExecutionDoneEvent[*http.Response])

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL