Documentation ¶
Index ¶
Constants ¶
View Source
const (
// OperatorPriority is used to give precedence to calls coming from web UI or tctl
OperatorPriority = 0
)
Variables ¶
View Source
var ( APIToPriority = map[string]int{ "AddActivityTask": 1, "AddWorkflowTask": 1, "CancelOutstandingPoll": 1, "DescribeTaskQueue": 1, "ListTaskQueuePartitions": 1, "PollActivityTaskQueue": 1, "PollWorkflowTaskQueue": 1, "QueryWorkflow": 1, "RespondQueryTaskCompleted": 1, "GetWorkerBuildIdCompatibility": 1, "UpdateWorkerBuildIdCompatibility": 1, "GetTaskQueueUserData": 1, "ApplyTaskQueueUserDataReplicationEvent": 1, "GetBuildIdTaskQueueMapping": 1, "ForceUnloadTaskQueue": 1, "UpdateTaskQueueUserData": 1, "ReplicateTaskQueueUserData": 1, } APIPrioritiesOrdered = []int{0, 1} )
Functions ¶
func NewPriorityRateLimiter ¶
func NewPriorityRateLimiter( rateFn quotas.RateFn, operatorRPSRatio dynamicconfig.FloatPropertyFn, ) quotas.RequestRateLimiter
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.