pipeline

Documentation

Index

• type Pl
  • func NewPipeline(log *zap.Logger, ch chain.ChainHandler) *Pl
  • func (pp *Pl) Add(w *Worker)
  • func (pp *Pl) Async(a bool)
  • func (pp *Pl) Error() types.ErrorHandlerFunc
  • func (pp *Pl) ErrorHandler(ff types.ErrorHandlerFunc)
  • func (pp *Pl) Handler() http.Handler
• type Worker

Types

type Pl

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

func NewPipeline

func NewPipeline(log *zap.Logger, ch chain.ChainHandler) *Pl

func (*Pl) Add

func (pp *Pl) Add(w *Worker)

Add filter

func (*Pl) Async

func (pp *Pl) Async(a bool)

func (*Pl) Error

func (pp *Pl) Error() types.ErrorHandlerFunc

func (*Pl) ErrorHandler

func (pp *Pl) ErrorHandler(ff types.ErrorHandlerFunc)

ErrorHandler adds error handler

func (*Pl) Handler

func (pp *Pl) Handler() http.Handler

Handler is the main operating entry point for requests that handles filter groups

type Worker

type Worker struct {
	Weight  int
	Async   bool
	Name    string
	Type    types.FilterKind
	Handler func(rw http.ResponseWriter, r *http.Request) error
}