Electric.Shapes.DynamicConsumerSupervisor (electric v1.2.4)

View Source

Responsible for managing shape consumer processes

Summary

Functions

child_spec(arg)

Returns a child spec for the PartitionSupervisor that starts a pool of DynamicConsumerSupervisor procecesses to shard child processes across.

name(stack_id)
start_link(opts)
start_shape_consumer(name, config)

Functions

child_spec(arg)

Returns a child spec for the PartitionSupervisor that starts a pool of DynamicConsumerSupervisor procecesses to shard child processes across.

The number of dynamic supervisors is equal to the number of CPU cores.

name(stack_id)

start_link(opts)

start_shape_consumer(name, config)