middleware

type BackoffType ¶ added in v0.3.0

type BackoffType int

BackoffType represents backoff strategy

const (
	// BackoffConstant is a backoff strategy with constant delay
	BackoffConstant BackoffType = iota
	// BackoffLinear is a backoff strategy with linear delay
	BackoffLinear
	// BackoffExponential is a backoff strategy with exponential delay
	BackoffExponential
)

type CacheEntry ¶ added in v0.3.0

type CacheEntry struct {
	// contains filtered or unexported fields
}

CacheEntry represents a cached response with metadata

type CacheMiddleware ¶ added in v0.3.0

type CacheMiddleware struct {
	// contains filtered or unexported fields
}

CacheMiddleware implements in-memory cache for HTTP responses with TTL-based eviction

func (c *CacheMiddleware) RoundTrip(req *http.Request) (*http.Response, error)

type CacheOption ¶ added in v0.3.0

type CacheOption func(c *CacheMiddleware)

CacheOption represents cache middleware options

func CacheMethods(methods ...string) CacheOption

func CacheSize(size int) CacheOption

func CacheStatuses(codes ...int) CacheOption

func CacheTTL(ttl time.Duration) CacheOption

func CacheWithHeaders(headers ...string) CacheOption

type CircuitBreakerFunc ¶

type CircuitBreakerFunc func(req func() (interface{}, error)) (interface{}, error)

CircuitBreakerFunc is an adapter to allow the use of ordinary functions as CircuitBreakerSvc.

func (c CircuitBreakerFunc) Execute(req func() (interface{}, error)) (interface{}, error)

type CircuitBreakerSvc ¶

type CircuitBreakerSvc interface {
	Execute(req func() (interface{}, error)) (interface{}, error)
}

CircuitBreakerSvc is an interface wrapping any function to send a request with circuit breaker. can be used with github.com/sony/gobreaker or any similar implementations

type RepeaterSvc ¶

type RepeaterSvc interface {
	Do(ctx context.Context, fun func() error, errs ...error) (err error)
}

RepeaterSvc defines repeater interface

type RetryMiddleware ¶ added in v0.3.0

type RetryMiddleware struct {
	// contains filtered or unexported fields
}

RetryMiddleware implements a retry mechanism for http requests with configurable backoff strategies. It supports constant, linear and exponential backoff with optional jitter for better load distribution. By default retries on network errors and 5xx responses. Can be configured to retry on specific status codes or to exclude specific codes from retry.

For requests with bodies (POST, PUT, PATCH), the middleware handles body replay: - If req.GetBody is set (automatic for strings.Reader, bytes.Buffer, bytes.Reader), it uses that - If req.GetBody is nil and body buffering is disabled (default), requests won't be retried - If body buffering is enabled with RetryBufferBodies(true), bodies up to maxBufferSize are buffered

Default configuration:

• 3 attempts
• Initial delay: 100ms
• Max delay: 30s
• Exponential backoff
• 10% jitter
• Retries on 5xx status codes
• Body buffering disabled (preserves streaming, no retries for bodies without GetBody)

func (r *RetryMiddleware) RoundTrip(req *http.Request) (*http.Response, error)

type RetryOption ¶ added in v0.3.0

type RetryOption func(r *RetryMiddleware)

RetryOption represents option type for retry middleware

func RetryBufferBodies(enabled bool) RetryOption

func RetryExcludeCodes(codes ...int) RetryOption

func RetryMaxBufferSize(size int64) RetryOption

func RetryMaxDelay(d time.Duration) RetryOption

func RetryOnCodes(codes ...int) RetryOption

func RetryWithBackoff(t BackoffType) RetryOption

func RetryWithJitter(f float64) RetryOption

type RoundTripperFunc ¶

type RoundTripperFunc func(*http.Request) (*http.Response, error)

RoundTripperFunc is a functional adapter for RoundTripperHandler

func (rt RoundTripperFunc) RoundTrip(r *http.Request) (*http.Response, error)

type RoundTripperHandler ¶

type RoundTripperHandler func(http.RoundTripper) http.RoundTripper

RoundTripperHandler is a type for middleware handler

func Cache(opts ...CacheOption) RoundTripperHandler

func CircuitBreaker(svc CircuitBreakerSvc) RoundTripperHandler

func Repeater(repeater RepeaterSvc, failOnCodes ...int) RoundTripperHandler

func Retry(attempts int, initialDelay time.Duration, opts ...RetryOption) RoundTripperHandler