MCPcopy Create free account
hub / github.com/temporalio/temporal / PickWritePartition

Method PickWritePartition

client/matching/loadbalancer.go:24–24  ·  view source on GitHub ↗

PickWritePartition returns the task queue partition for adding an activity or workflow task. The input is the name of the original task queue (with no partition info). When forwardedFrom is non-empty, this call is forwardedFrom from a child partition to a parent partition in which case, no load bala

(
			taskQueue *tqid.TaskQueue,
			pc PartitionCounts,
		)

Source from the content-addressed store, hash-verified

22 // to a parent partition in which case, no load balancing should be
23 // performed
24 PickWritePartition(
25 taskQueue *tqid.TaskQueue,
26 pc PartitionCounts,
27 ) *tqid.NormalPartition

Callers 1

pickClientForWriteMethod · 0.65

Implementers 1

defaultLoadBalancerclient/matching/loadbalancer.go

Calls

no outgoing calls

Tested by

no test coverage detected