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

Function getPartitionForRangeHash

common/persistence/sql/task_util.go:12–17  ·  view source on GitHub ↗
(rangeHash uint32, totalPartitions uint32)

Source from the content-addressed store, hash-verified

10)
11
12func getPartitionForRangeHash(rangeHash uint32, totalPartitions uint32) uint32 {
13 if totalPartitions == 0 {
14 return 0
15 }
16 return rangeHash / getPartitionBoundaryStart(1, totalPartitions)
17}
18
19func getPartitionBoundaryStart(partition uint32, totalPartitions uint32) uint32 {
20 if totalPartitions == 0 {

Callers 1

ListTaskQueueMethod · 0.85

Calls 1

Tested by

no test coverage detected