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{
		"/temporal.server.api.matchingservice.v1.MatchingService/AddActivityTask":                        1,
		"/temporal.server.api.matchingservice.v1.MatchingService/AddWorkflowTask":                        1,
		"/temporal.server.api.matchingservice.v1.MatchingService/CancelOutstandingPoll":                  1,
		"/temporal.server.api.matchingservice.v1.MatchingService/DescribeTaskQueue":                      1,
		"/temporal.server.api.matchingservice.v1.MatchingService/ListTaskQueuePartitions":                1,
		"/temporal.server.api.matchingservice.v1.MatchingService/PollActivityTaskQueue":                  1,
		"/temporal.server.api.matchingservice.v1.MatchingService/PollWorkflowTaskQueue":                  1,
		"/temporal.server.api.matchingservice.v1.MatchingService/QueryWorkflow":                          1,
		"/temporal.server.api.matchingservice.v1.MatchingService/RespondQueryTaskCompleted":              1,
		"/temporal.server.api.matchingservice.v1.MatchingService/GetWorkerBuildIdCompatibility":          1,
		"/temporal.server.api.matchingservice.v1.MatchingService/UpdateWorkerBuildIdCompatibility":       1,
		"/temporal.server.api.matchingservice.v1.MatchingService/GetTaskQueueUserData":                   1,
		"/temporal.server.api.matchingservice.v1.MatchingService/ApplyTaskQueueUserDataReplicationEvent": 1,
		"/temporal.server.api.matchingservice.v1.MatchingService/GetBuildIdTaskQueueMapping":             1,
		"/temporal.server.api.matchingservice.v1.MatchingService/ForceUnloadTaskQueue":                   1,
		"/temporal.server.api.matchingservice.v1.MatchingService/UpdateTaskQueueUserData":                1,
		"/temporal.server.api.matchingservice.v1.MatchingService/ReplicateTaskQueueUserData":             1,
		"/temporal.server.api.matchingservice.v1.MatchingService/PollNexusTaskQueue":                     1,
		"/temporal.server.api.matchingservice.v1.MatchingService/RespondNexusTaskCompleted":              1,
		"/temporal.server.api.matchingservice.v1.MatchingService/RespondNexusTaskFailed":                 1,
		"/temporal.server.api.matchingservice.v1.MatchingService/DispatchNexusTask":                      1,
		"/temporal.server.api.matchingservice.v1.MatchingService/CreateNexusEndpoint":                    1,
		"/temporal.server.api.matchingservice.v1.MatchingService/UpdateNexusEndpoint":                    1,
		"/temporal.server.api.matchingservice.v1.MatchingService/ListNexusEndpoints":                     1,
		"/temporal.server.api.matchingservice.v1.MatchingService/DeleteNexusEndpoint":                    1,
		"/temporal.server.api.matchingservice.v1.MatchingService/UpdateWorkerVersioningRules":            1,
		"/temporal.server.api.matchingservice.v1.MatchingService/GetWorkerVersioningRules":               1,
		"/temporal.server.api.matchingservice.v1.MatchingService/DescribeTaskQueuePartition":             1,
	}

	APIPrioritiesOrdered = []int{0, 1}
)

Functions

func NewPriorityRateLimiter

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