transport

Documentation

Index

• func FromContext(ctx context.Context) *rolling.Aggregate
• func New(l loadshed.Doer, options ...Option) func(c http.RoundTripper) http.RoundTripper
• func NewContext(ctx context.Context, val *rolling.Aggregate) context.Context
• func NewErrCodes(errorCodes []int) func(http.RoundTripper) http.RoundTripper
• type Option
  • func Callback(cb func(*http.Request) (*http.Response, error)) Option
  • func ErrorCodes(errorCodes []int) Option
• type Transport
  • func (c *Transport) RoundTrip(r *http.Request) (*http.Response, error)

Functions

func FromContext

func FromContext(ctx context.Context) *rolling.Aggregate

FromContext extracts an aggregate from the context after a request has been rejected.

func New

func New(l loadshed.Doer, options ...Option) func(c http.RoundTripper) http.RoundTripper

New takes in a loadshed Doer and transport options and returns a RoundTripper wrapper

func NewContext

func NewContext(ctx context.Context, val *rolling.Aggregate) context.Context

NewContext inserts an aggregate into the context after a request has been rejected.

func NewErrCodes

func NewErrCodes(errorCodes []int) func(http.RoundTripper) http.RoundTripper

NewErrCodes returns a transport wrapper around the error codes transport

Types

type Option

type Option func(*Transport) *Transport

Option is a wrapper around the transport modifying its behavior

func Callback

func Callback(cb func(*http.Request) (*http.Response, error)) Option

Callback option adds a callback for error

func ErrorCodes

func ErrorCodes(errorCodes []int) Option

ErrorCodes option wraps the errorcodes transport

type Transport

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

Transport is an HTTP client wrapper that provides circuit breaker functionality for the outgoing request.

func (*Transport) RoundTrip

func (c *Transport) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip circuit breaks the outgoing request if needed and calls the wrapped Client.