pipeline

type AfterChannel ¶

type AfterChannel struct {
	Handlers []AfterHandlerTempl
}

AfterChannel contains the functions to be called after the handler method is executed

func NewAfterChannel() *AfterChannel

func (p *AfterChannel) Clear()

func (p *AfterChannel) ExecuteAfterPipeline(ctx context.Context, res interface{}, err error) (interface{}, error)

func (p *AfterChannel) PushBack(h AfterHandlerTempl)

func (p *AfterChannel) PushFront(h AfterHandlerTempl)

type AfterHandlerTempl ¶

type AfterHandlerTempl func(ctx context.Context, out interface{}, err error) (interface{}, error)

AfterHandlerTempl is a function for the after handler, receives both the handler response and the error returned

type Channel ¶

type Channel struct {
	Handlers []HandlerTempl
}

Channel contains the functions to be called before the handler method is executed

func NewChannel() *Channel

func (p *Channel) Clear()

func (p *Channel) ExecuteBeforePipeline(ctx context.Context, data interface{}) (context.Context, interface{}, error)

func (p *Channel) PushBack(h HandlerTempl)

func (p *Channel) PushFront(h HandlerTempl)

type HandlerHooks ¶

type HandlerHooks struct {
	Hooks
}

func NewHandlerHooks() *HandlerHooks

type HandlerTempl ¶

type HandlerTempl func(ctx context.Context, in interface{}) (c context.Context, out interface{}, err error)

HandlerTempl is a function that has the same signature as a handler and will be called before or after handler methods

type Hooks ¶ added in v2.8.0

type Hooks struct {
	BeforeHandler *Channel
	AfterHandler  *AfterChannel
}

Hooks contains before and after channels

type RemoteHooks ¶ added in v2.8.0

type RemoteHooks struct {
	Hooks
}

func NewRemoteHooks() *RemoteHooks