Electric.Shapes.DynamicConsumerSupervisor (electric v1.2.4)

View Source

Responsible for managing shape consumer processes

Summary

Functions

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

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)