middleware

Documentation

Index

• type DoFunc
  • func (df DoFunc) Do(ctx context.Context, request *types.Request) (*types.Response, error)
• type LogLevelType
• type LogMiddleware
  • func NewLogMiddleware(name string, meta types.Metadata) (*LogMiddleware, error)
• type MetadataMiddleware
  • func NewMetadataMiddleware(meta types.Metadata) (*MetadataMiddleware, error)
• type MetricsMiddleware
  • func NewMetricsMiddleware(cfg config.BindingConfig, exporter *metrics.Exporter) (*MetricsMiddleware, error)
• type Middleware
  • func Chain(md Middleware, list ...MiddlewareFunc) Middleware
• type MiddlewareFunc
  • func Log(log *LogMiddleware) MiddlewareFunc
  • func Metadata(m *MetadataMiddleware) MiddlewareFunc
  • func Metric(m *MetricsMiddleware) MiddlewareFunc
  • func RateLimiter(rl *RateLimitMiddleware) MiddlewareFunc
  • func Retry(r *RetryMiddleware) MiddlewareFunc
• type RateLimitMiddleware
  • func NewRateLimitMiddleware(meta types.Metadata) (*RateLimitMiddleware, error)
  • func (rl *RateLimitMiddleware) Take()
• type RetryMiddleware
  • func NewRetryMiddleware(meta types.Metadata, log *logger.Logger) (*RetryMiddleware, error)

Types

type DoFunc

type DoFunc func(ctx context.Context, request *types.Request) (*types.Response, error)

func (DoFunc) Do

func (df DoFunc) Do(ctx context.Context, request *types.Request) (*types.Response, error)

type LogLevelType

type LogLevelType string

const (
	LogLevelTypeNoLog LogLevelType = ""
	LogLevelTypeDebug LogLevelType = "debug"
	LogLevelTypeInfo  LogLevelType = "info"
	LogLevelTypeError LogLevelType = "error"
)

type LogMiddleware

type LogMiddleware struct {
	*logger.Logger
	// contains filtered or unexported fields
}

func NewLogMiddleware

func NewLogMiddleware(name string, meta types.Metadata) (*LogMiddleware, error)

type MetadataMiddleware

type MetadataMiddleware struct {
	Metadata map[string]string
}

func NewMetadataMiddleware

func NewMetadataMiddleware(meta types.Metadata) (*MetadataMiddleware, error)

type MetricsMiddleware

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

func NewMetricsMiddleware

func NewMetricsMiddleware(cfg config.BindingConfig, exporter *metrics.Exporter) (*MetricsMiddleware, error)

type Middleware

type Middleware interface {
	Do(ctx context.Context, request *types.Request) (*types.Response, error)
}

func Chain

func Chain(md Middleware, list ...MiddlewareFunc) Middleware

type MiddlewareFunc

type MiddlewareFunc func(Middleware) Middleware

func Log

func Log(log *LogMiddleware) MiddlewareFunc

func Metadata

func Metadata(m *MetadataMiddleware) MiddlewareFunc

func Metric

func Metric(m *MetricsMiddleware) MiddlewareFunc

func RateLimiter

func RateLimiter(rl *RateLimitMiddleware) MiddlewareFunc

func Retry

func Retry(r *RetryMiddleware) MiddlewareFunc

type RateLimitMiddleware

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

func NewRateLimitMiddleware

func NewRateLimitMiddleware(meta types.Metadata) (*RateLimitMiddleware, error)

func (*RateLimitMiddleware) Take

func (rl *RateLimitMiddleware) Take()

type RetryMiddleware

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

func NewRetryMiddleware

func NewRetryMiddleware(meta types.Metadata, log *logger.Logger) (*RetryMiddleware, error)