tps

Documentation

Index

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

Types

type Filter

type Filter struct{}

Filter filters the requests by TPS *

• if you wish to use the TpsLimiter, please add the configuration into your service provider configuration:
• for example:
• "UserProvider":
• registry: "hangzhouzk"
• protocol : "dubbo"
• interface : "com.ikurento.user.UserProvider"
• ... # other configuration
• tps.limiter: "method-service", # it should be the name of limiter. if the value is 'default',
• # the MethodServiceTpsLimiter will be used.
• tps.limit.rejected.handler: "default", # optional, or the name of the implementation
• if the value of 'tps.limiter' is nil or empty string, the tps filter will do nothing

func (*Filter) Invoke

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

Invoke gets the configured limter to impose TPS limiting

func (*Filter) OnResponse

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

OnResponse dummy process, returns the result directly