port

Documentation

Index

• func Delegate[T any, R any](ctx context.Context, request *T, doer endpoint.Endpoint) (*R, error)
• func InstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware
• func LoggingMiddleware(logger *zap.Logger) endpoint.Middleware
• func MakeEndpoint[T any, R any](does func(ctx context.Context, request *T) (*R, error), ...) endpoint.Endpoint

Functions

func Delegate

func Delegate[T any, R any](ctx context.Context, request *T, doer endpoint.Endpoint) (*R, error)

func InstrumentingMiddleware

func InstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware

func LoggingMiddleware

func LoggingMiddleware(logger *zap.Logger) endpoint.Middleware

func MakeEndpoint

func MakeEndpoint[T any, R any](
	does func(ctx context.Context, request *T) (*R, error),
	middlewares ...endpoint.Middleware,
) endpoint.Endpoint