echo

Documentation

Index

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

Types

type Filter

type Filter struct{}

Filter health check RPCService need a Echo method in consumer, if you want to use Filter eg:

Echo func(ctx context.Context, arg interface{}, rsp *Xxx) error

func (*Filter) Invoke

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

Invoke response to the callers with its first argument.

func (*Filter) OnResponse

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

OnResponse dummy process, returns the result directly