middleware

Documentation

Index

• func FromContext(ctx context.Context) *rolling.Aggregate
• func New(l loadshed.Doer, options ...Option) func(http.Handler) http.Handler
• func NewContext(ctx context.Context, val *rolling.Aggregate) context.Context
• type Middleware
  • func (m *Middleware) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Option
  • func Callback(cb http.Handler) Option
  • func ErrCodes(errCodes []int) Option

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(http.Handler) http.Handler

New takes in options and returns a wrapped middleware

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.

Types

type Middleware

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

Middleware struct represents a loadshed middleware

func (*Middleware) ServeHTTP

func (m *Middleware) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Option

type Option func(*Middleware) *Middleware

Option is a wrapper for middleware

func Callback

func Callback(cb http.Handler) Option

Callback Option adds a callback to the middleware

func ErrCodes

func ErrCodes(errCodes []int) Option

ErrCodes Option adds errcode check to the middleware