Electric.Shapes.Consumer (electric v1.2.4)

View Source

Summary

Functions

activate_mocked_functions_from_test_process()
await_snapshot_start(consumer, timeout \\ 30000)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

initial_state(consumer)
name(map)
name(stack_id, shape_handle)
start_link(config)
subscribe_materializer(consumer)
whereis(stack_id, shape_handle)

Functions

activate_mocked_functions_from_test_process()

await_snapshot_start(consumer, timeout \\ 30000)

@spec await_snapshot_start(pid() | map(), timeout()) :: :started | {:error, any()}

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

initial_state(consumer)

name(map)

name(stack_id, shape_handle)

start_link(config)

subscribe_materializer(consumer)

whereis(stack_id, shape_handle)

@spec whereis(String.t(), Electric.ShapeCache.shape_handle()) :: pid() | nil