pipeline

package

v1.0.3 Latest Latest Go to latest Published: Apr 9, 2022 License: BSD-3-Clause Imports: 1 Imported by: 3

Details

This section is empty.

This section is empty.

func MiddlewareChain(mid ...RequestMiddleware) middlewareChain

type MiddlewareGroup map[string][]RequestMiddleware

type PipeFunc func(r 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(r contracts.RequestContract, next PipeHandler) contracts.ResponseContract
}

RequestMiddleware request middleware