configs

Documentation

Index

• Constants
• Variables
• func NewPriorityRateLimiter(rateFn quotas.RateFn, operatorRPSRatio dynamicconfig.FloatPropertyFn) quotas.RequestRateLimiter

Constants

const (
	// OperatorPriority is used to give precedence to calls coming from web UI or tctl
	OperatorPriority = 0
)

Variables

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