Electric.Shapes.DynamicConsumerSupervisor (electric v1.4.13)

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(name)
start_link(opts)
start_materializer(supervisor_ref, config)
start_shape_consumer(supervisor_ref, config)
start_snapshotter(supervisor_ref, 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(name)

start_link(opts)

start_materializer(supervisor_ref, config)

start_shape_consumer(supervisor_ref, config)

start_snapshotter(supervisor_ref, config)