http

package module

Go to main page

Versions in this module

v0

v0.9.0

Aug 25, 2026

v0.8.0

Aug 21, 2026

Changes in this version

+ const RetrySuppressedReasonBudgetExhausted

type RequestResultEvent

+ RetrySuppressedReason string

+ type RetryBudgetFile struct

+ Capacity *int

+ Enabled *bool

+ RetryCost *int

+ SuccessIncrement *int

type RetryConfigFile

+ RetryBudget *RetryBudgetFile

v0.7.0

Aug 17, 2026

v0.6.0

Aug 7, 2026

Changes in this version

type RetryConfigMatchFile

+ Callers []string

+ Classes []string

+ Downstreams []string

+ Hosts []string

+ Methods []string

+ Operations []string

+ Paths []string

v0.5.1

Aug 6, 2026

v0.5.0

Aug 6, 2026

Changes in this version

+ func DeleteWithHeaders(ctx context.Context, url, contentType string, body any, expectedPtr any, ...) error

+ func GetWithHeaders(ctx context.Context, url string, expectedPtr any, ...) error

+ func MultipartFormWithHeaders(ctx context.Context, method, url string, mf MultipartFormData, expectedPtr any, ...) error

+ func PostMultipartFormWithHeaders(ctx context.Context, url string, mf MultipartFormData, expectedPtr any, ...) error

+ func PostWithHeaders(ctx context.Context, url, contentType string, body any, expectedPtr any, ...) error

+ func PutMultipartFormWithHeaders(ctx context.Context, url string, mf MultipartFormData, expectedPtr any, ...) error

+ func PutWithHeaders(ctx context.Context, url, contentType string, body any, expectedPtr any, ...) error

+ func SendWithHeaders(ctx context.Context, method, url, contentType string, body any, ...) error

+ type RequestHeaderSetter func(request *http.Request) error

v0.4.0

Aug 4, 2026

v0.3.0

Aug 4, 2026

Changes in this version

+ func SetBodyLogLimit(limit int64) error

v0.2.1

Aug 4, 2026

v0.2.0

Aug 4, 2026

Changes in this version

+ const HeaderNoMoreRetry

+ const HeaderRequestDeadline

+ const HeaderRetryAttempt

+ const HeaderRetryReason

+ var ErrUrlNotFound = errors.New("request URL not found")

+ var HealthcheckSkipper = SkipperFunc(func(req *http.Request) bool { ... })

+ func CallerServiceName() string

+ func ClearRequestClassResolver()

+ func ContextWithRetryConstraints(ctx context.Context, headers stdhttp.Header) (context.Context, context.CancelFunc)

+ func Delete(ctx context.Context, url, contentType string, body any, expectedPtr any) error

+ func Do(req *http.Request, expectedPtr any) error

+ func Get(ctx context.Context, url string, expectedPtr any) error

+ func GetInstance() *http.Client

+ func Head(ctx context.Context, url string, expectedPtr any) error

+ func Instance() *http.Client

+ func InternalDelete(ctx context.Context, url, contentType string, body any, expectedPtr any, ...) error

+ func InternalGet(ctx context.Context, url string, expectedPtr any, ...) error

+ func InternalMultipartForm(ctx context.Context, method, url string, mf MultipartFormData, expectedPtr any, ...) error

+ func InternalPost(ctx context.Context, url, contentType string, body any, expectedPtr any, ...) error

+ func InternalPostMultipartForm(ctx context.Context, url string, mf MultipartFormData, expectedPtr any, ...) error

+ func InternalPut(ctx context.Context, url, contentType string, body any, expectedPtr any, ...) error

+ func InternalPutMultipartForm(ctx context.Context, url string, mf MultipartFormData, expectedPtr any, ...) error

+ func InternalWithMethod(ctx context.Context, url, method, contentType string, body any, ...) error

+ func NewClient() *http.Client

+ func NewClientWithOptions(options ClientOptions) *http.Client

+ func NoMoreRetryFromContext(ctx context.Context) bool

+ func Post(ctx context.Context, url, contentType string, body any, expectedPtr any) error

+ func PostMultipartForm(ctx context.Context, url string, mf MultipartFormData, expectedPtr any) error

+ func Put(ctx context.Context, url, contentType string, body any, expectedPtr any) error

+ func PutMultipartForm(ctx context.Context, url string, mf MultipartFormData, expectedPtr any) error

+ func RespHandler(resp *http.Response, expectedPtr any) error

+ func RetryConfigAutoReloadInterval() time.Duration

+ func SetBodyLogLevel(level slog.Level)

+ func SetCallerServiceName(name string)

+ func SetHealthcheckSkipper()

+ func SetRequestClassResolver(resolver RequestClassResolver)

+ func SetRetryConfigAutoReloadInterval(interval time.Duration)

+ func SetRetryConfigProvider(provider RetryConfigProvider)

+ func SetRetryObserver(observer RetryObserver)

+ func SetRetryPolicyResolver(resolver RetryPolicyResolver)

+ func SetRetryResultObserver(observer RetryResultObserver)

+ func SetSkipper(skipper SkipperFunc)

+ func Setup() error

+ func SetupWithOptions(options SetupOptions) error

+ func StartRetryConfigAutoReloadFromConsul(provider *ManagedRetryConfigProvider, env, appName, endpoint string) error

+ func StopRetryConfigAutoReload()

+ func WithExternalRead(ctx context.Context) context.Context

+ func WithExternalWrite(ctx context.Context) context.Context

+ func WithInternalRead(ctx context.Context) context.Context

+ func WithInternalWrite(ctx context.Context) context.Context

+ func WithNoMoreRetry(ctx context.Context) context.Context

+ func WithRequestClass(ctx context.Context, class RequestClass) context.Context

+ func WithRetryConfigScope(ctx context.Context, scope RetryConfigScope) context.Context

+ func WithRetryPolicy(ctx context.Context, policy RetryPolicy) context.Context

+ type AuthorizationInHeaderSetter interface

+ SetAuthorizationInHeader func(request *http.Request) error

+ type AuthorizationInHeaderSetterFunc func(request *http.Request) error

+ func (fn AuthorizationInHeaderSetterFunc) SetAuthorizationInHeader(request *http.Request) error

+ type ClientOptions struct

+ CheckRedirect func(req *http.Request, via []*http.Request) error

+ ConfigProvider RetryConfigProvider

+ Jar http.CookieJar

+ Observer RetryObserver

+ RequestTimeout time.Duration

+ ResolvePolicy RetryPolicyResolver

+ ResultObserver RetryResultObserver

+ RoundTripper http.RoundTripper

+ Skipper SkipperFunc

+ type ManagedRetryConfigProvider struct

+ func NewManagedRetryConfigProvider() *ManagedRetryConfigProvider

+ func NewManagedRetryConfigProviderFromConsul(env, appName, endpoint string) (*ManagedRetryConfigProvider, error)

+ func NewManagedRetryConfigProviderFromYAML(data []byte) (*ManagedRetryConfigProvider, error)

+ func SetRetryConfigProviderFromConsul(env, appName, endpoint string) (*ManagedRetryConfigProvider, error)

+ func SetRetryConfigProviderFromYAML(data []byte) (*ManagedRetryConfigProvider, error)

+ func (p *ManagedRetryConfigProvider) ResolveRequestClass(req *http.Request) (RequestClass, bool)

+ func (p *ManagedRetryConfigProvider) ResolveRetryConfigScope(req *http.Request, scope RetryConfigScope) RetryConfigScope

+ func (p *ManagedRetryConfigProvider) ResolveRetryPolicy(ctx context.Context, scope RetryConfigScope, base RetryPolicy) RetryPolicy

+ func (p *ManagedRetryConfigProvider) Update(file RetryConfigFile) error

+ func (p *ManagedRetryConfigProvider) UpdateFromConsul(env, appName, endpoint string) error

+ func (p *ManagedRetryConfigProvider) UpdateFromYAML(data []byte) error

+ type MultipartFormData struct

+ File *multipart.FileHeader

+ FileName string

+ Form interface{}

+ type RequestClass string

+ const RequestClassExternalRead

+ const RequestClassExternalWrite

+ const RequestClassInternalRead

+ const RequestClassInternalWrite

+ type RequestClassResolver interface

+ ResolveRequestClass func(req *http.Request) (RequestClass, bool)

+ type RequestResultEvent struct

+ AttemptCount int

+ Caller string

+ Class RequestClass

+ Downstream string

+ Duration time.Duration

+ FinalError string

+ FinalFailed bool

+ FinalReason string

+ MaxRetries int

+ Method string

+ Operation string

+ Retried bool

+ RetryCount int

+ RetrySucceeded bool

+ StatusCode int

+ TimedOut bool

+ URL string

+ type ResponsePtr struct

+ ExceptPtr any

+ ExpectedPtr any

+ StatusCode int

+ type RetryClassPolicyFile struct

+ ExternalRead *RetryPolicyPatchFile

+ ExternalWrite *RetryPolicyPatchFile

+ InternalRead *RetryPolicyPatchFile

+ InternalWrite *RetryPolicyPatchFile

+ type RetryConfigFile struct

+ Downstreams []RetryDownstreamFile

+ InternalHosts []string

+ Operations []RetryOperationRuleFile

+ Policies RetryClassPolicyFile

+ Rules []RetryConfigRuleFile

+ Version string

+ type RetryConfigMatchFile struct

+ Caller []string

+ Class []string

+ Downstream []string

+ Host []string

+ Method []string

+ Operation []string

+ Path []string

+ type RetryConfigProvider interface

+ ResolveRetryPolicy func(ctx context.Context, scope RetryConfigScope, base RetryPolicy) RetryPolicy

+ type RetryConfigProviderFunc func(ctx context.Context, scope RetryConfigScope, base RetryPolicy) RetryPolicy

+ func (fn RetryConfigProviderFunc) ResolveRetryPolicy(ctx context.Context, scope RetryConfigScope, base RetryPolicy) RetryPolicy

+ type RetryConfigRuleFile struct

+ Disabled bool

+ Match RetryConfigMatchFile

+ Name string

+ Policy RetryPolicyPatchFile

+ Priority int

+ type RetryConfigScope struct

+ Caller string

+ Class RequestClass

+ Downstream string

+ Host string

+ Method string

+ Operation string

+ Path string

+ type RetryConfigScopeDefaultsResolver interface

+ ResolveRetryConfigScope func(req *http.Request, scope RetryConfigScope) RetryConfigScope

+ type RetryDownstreamFile struct

+ Hosts []string

+ Name string

+ type RetryEvent struct

+ Attempt int

+ Class RequestClass

+ Delay time.Duration

+ MaxRetries int

+ Method string

+ Reason string

+ StatusCode int

+ URL string

+ WillRetry bool

+ type RetryObserver interface

+ ObserveRetry func(ctx context.Context, event RetryEvent)

+ type RetryOperationRuleFile struct

+ Downstreams []string

+ Hosts []string

+ Methods []string

+ Name string

+ Paths []string

+ Priority int

+ type RetryPolicy struct

+ InitialBackoff time.Duration

+ MaxBackoff time.Duration

+ MaxElapsedTime time.Duration

+ MaxRetries int

+ PerAttemptTimeout time.Duration

+ RetryOn429 bool

+ RetryOnStatuses map[int]struct{}

+ func DefaultRetryPolicyResolver(req *http.Request) RetryPolicy

+ type RetryPolicyPatch struct

+ DisableRetry *bool

+ InitialBackoff *time.Duration

+ MaxBackoff *time.Duration

+ MaxElapsedTime *time.Duration

+ MaxRetries *int

+ PerAttemptTimeout *time.Duration

+ RetryOn429 *bool

+ RetryOnStatuses []int

+ func (p RetryPolicyPatch) Apply(base RetryPolicy) RetryPolicy

+ type RetryPolicyPatchFile struct

+ DisableRetry *bool

+ InitialBackoff string

+ MaxBackoff string

+ MaxElapsedTime string

+ MaxRetries *int

+ PerAttemptTimeout string

+ RetryOn429 *bool

+ RetryOnStatuses []int

+ type RetryPolicyResolver func(req *http.Request) RetryPolicy

+ type RetryResultObserver interface

+ ObserveRequestResult func(ctx context.Context, event RequestResultEvent)

+ type SetupOptions struct

+ Consul string

+ Env string

+ Name string

+ type SkipperFunc func(req *http.Request) bool

+ type Transport struct

+ ConfigProvider RetryConfigProvider

+ Observer RetryObserver

+ ResolvePolicy RetryPolicyResolver

+ ResultObserver RetryResultObserver

+ Skipper SkipperFunc

+ func NewTransport() *Transport

+ func NewTransportWithOptions(options ClientOptions) *Transport

+ func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

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