MCPcopy
hub / github.com/IBM/sarama / Partition

Method Partition

partitioner.go:16–16  ·  view source on GitHub ↗

Partition takes a message and partition count and chooses a partition

(message *ProducerMessage, numPartitions int32)

Source from the content-addressed store, hash-verified

14type Partitioner interface {
15 // Partition takes a message and partition count and chooses a partition
16 Partition(message *ProducerMessage, numPartitions int32) (int32, error)
17
18 // RequiresConsistency indicates to the user of the partitioner whether the
19 // mapping of key->partition is consistent or not. Specifically, if a

Callers 15

assertPartitioningConsistentFunction · 0.65
partitionAndAssertFunction · 0.65
TestRandomPartitionerFunction · 0.65
TestRoundRobinPartitionerFunction · 0.65
TestNewHashPartitionerWithHasherFunction · 0.65
TestHashPartitionerWithHasherMinInt32Function · 0.65
TestHashPartitionerFunction · 0.65
TestHashPartitionerMinInt32Function · 0.65
TestCustomPartitionerWithConsistentHashingFunction · 0.65
TestManualPartitionerFunction · 0.65
TestWithCustomFallbackPartitionerFunction · 0.65
TestMurmur2PartitionerFunction · 0.65

Implementers 6

manualPartitionerpartitioner.go
randomPartitionerpartitioner.go
roundRobinPartitionerpartitioner.go
hashPartitionerpartitioner.go
murmur2Partitionerpartitioner.go
brokePartitionermocks/async_producer_test.go

Calls

no outgoing calls

Tested by 12

assertPartitioningConsistentFunction · 0.52
partitionAndAssertFunction · 0.52
TestRandomPartitionerFunction · 0.52
TestRoundRobinPartitionerFunction · 0.52
TestNewHashPartitionerWithHasherFunction · 0.52
TestHashPartitionerWithHasherMinInt32Function · 0.52
TestHashPartitionerFunction · 0.52
TestHashPartitionerMinInt32Function · 0.52
TestCustomPartitionerWithConsistentHashingFunction · 0.52
TestManualPartitionerFunction · 0.52
TestWithCustomFallbackPartitionerFunction · 0.52
TestMurmur2PartitionerFunction · 0.52