pipeline

package

v1.2.1 Latest Latest Go to latest Published: Aug 11, 2024 License: BSD-3-Clause Imports: 2 Imported by: 3

Details

This section is empty.

This section is empty.

func MiddlewareChain(mid ...RequestMiddleware) middlewareChain

type FuncMiddleware struct {
	HandleFunc PipeFunc
}

func (fm FuncMiddleware) Handle(r contracts.RequestContract, next PipeHandler) contracts.ResponseContract

type MiddlewareGroup map[string][]RequestMiddleware

type PipeFunc func(request contracts.RequestContract, next PipeHandler) contracts.ResponseContract

PipeFunc request middleware function

type PipeHandler func(r contracts.RequestContract) contracts.ResponseContract

PipeHandler destination handler

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

Pipeline is request pipeline prepare for request middleware

func (p *Pipeline) Send(r contracts.RequestContract) *Pipeline

Send request to pipeline

func (p *Pipeline) Then(handler PipeHandler) contracts.ResponseContract

Then final destination

func (p *Pipeline) Through(pipe interface{}) *Pipeline

Through middleware

func (p *Pipeline) ThroughFunc(pipe PipeFunc) *Pipeline

ThroughFunc through middleware function

func (p *Pipeline) ThroughMiddleware(pipe RequestMiddleware) *Pipeline

ThroughMiddleware through middleware struct

type RequestMiddleware interface {
	Handle(request contracts.RequestContract, next PipeHandler) contracts.ResponseContract
}

RequestMiddleware request middleware

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

func NewResponsePipe() *ResponsePipe

func (rp *ResponsePipe) Handle(r contracts.RequestContract, next PipeHandler) contracts.ResponseContract

func (rp *ResponsePipe) Pipe(pipeFunc PipeFunc) *ResponsePipe