singleflight

Documentation

Index

• Variables
• type SingleFlightMiddleware
  • func New() *SingleFlightMiddleware
  • func (m *SingleFlightMiddleware) Process(ctx context.Context, httpClient *http.Client, req *http.Request, ...) (*http.Response, error)
  • func (m *SingleFlightMiddleware) SetLogger(l logger.Logger)

Variables

var (
	ErrKeyGeneration = errors.New("failed to generate request key")
	ErrHashMethod    = errors.New("failed to hash method and URL")
	ErrHashHeader    = errors.New("failed to hash header")
	ErrReadBody      = errors.New("failed to read request body")
	ErrHashBody      = errors.New("failed to hash body")
)

Types

type SingleFlightMiddleware

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

SingleFlightMiddleware implements the singleflight pattern to deduplicate concurrent identical requests.

func New

func New() *SingleFlightMiddleware

New creates a new SingleFlightMiddleware instance.

func (*SingleFlightMiddleware) Process

func (m *SingleFlightMiddleware) Process(ctx context.Context, httpClient *http.Client, req *http.Request, next middleware.NextFunc) (*http.Response, error)

Process applies the singleflight pattern before passing the request to the next middleware.

func (*SingleFlightMiddleware) SetLogger

func (m *SingleFlightMiddleware) SetLogger(l logger.Logger)

SetLogger sets the logger for the middleware.