misha_cafex v0.0.6 Cafex.Consumer.WorkerPartition

The partitions and their corresponding worker pids

{
  #Map{worker_pid => partition},
  #Map{partition => worker_pid}
}

Summary

Functions

delete(arg, partition, worker)

delete_by_partition(index, partition)

delete_by_worker(index, worker)

new()

partition(arg, worker)

partitions(arg)

update(index, partition, worker)

worker(arg, partition)

workers(arg)

Functions

delete(arg, partition, worker)

delete_by_partition(index, partition)

delete_by_worker(index, worker)

new()

partition(arg, worker)

partitions(arg)

update(index, partition, worker)

worker(arg, partition)

workers(arg)