gshutdown

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
  • func (f *Filter) Set(name string, conf interface{})

Types

type Filter

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

func (*Filter) Invoke

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

Invoke adds the requests count and block the new requests if application is closing

func (*Filter) OnResponse

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

OnResponse reduces the number of active processes then return the process result

func (*Filter) Set

func (f *Filter) Set(name string, conf interface{})