misha_cafex v0.0.6 Cafex.Partitioner.Hashed

Hashed partitioner implementation.

Read Cafex.Partitioner behaviour.

Summary

Functions

init(partitions)

Callback implementation for Cafex.Partitioner.init/1

partition(message, partitions)

Callback implementation for Cafex.Partitioner.partition/2

Functions

init(partitions)

Callback implementation for Cafex.Partitioner.init/1.

partition(message, partitions)

Callback implementation for Cafex.Partitioner.partition/2.