active

Documentation

Index

• type Filter
  • func (f *Filter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result
  • func (f *Filter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, ...) protocol.Result

Types

type Filter

type Filter struct{}

Filter tracks the requests status

func (*Filter) Invoke

func (f *Filter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result

Invoke starts to record the requests status

func (*Filter) OnResponse

func (f *Filter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result

OnResponse update the active count base on the request result.