Versions in this module Expand all Collapse all v0 v0.7.1 Aug 16, 2018 v0.5.1 May 31, 2018 Changes in this version + const DefaultRate + func GetQPSRate(rateConfig string) (int, bool) + func GetSpecificKey(sourceName, serviceType, serviceName, schemaID, OperationID string) string + type OperationMeta struct + MicroServiceName string + OperationQualifiedName string + SchemaQualifiedName string + func InitSchemaOperations(i *invocation.Invocation) *OperationMeta + func (op *OperationMeta) GetMicroServiceName() string + func (op *OperationMeta) GetMicroServiceSchemaOpQualifiedName() string + func (op *OperationMeta) GetSchemaQualifiedName() string + type QPSLimiterMap struct + KeyMap map[string]ratelimit.Limiter + func GetQPSTrafficLimiter() *QPSLimiterMap + func (qpsL *QPSLimiterMap) DeleteRateLimiter(key string) + func (qpsL *QPSLimiterMap) GetQPSRateWithPriority(op *OperationMeta) (int, string) + func (qpsL *QPSLimiterMap) ProcessDefaultRateRpsTokenReq(key string, qpsRate int) + func (qpsL *QPSLimiterMap) ProcessQPSTokenReq(key string, qpsRate int) + func (qpsL *QPSLimiterMap) UpdateRateLimit(key string, value interface{})
Go to main page