Electric.Shapes.Consumer (electric v1.4.11)

View Source

Summary

Functions

activate_mocked_functions_from_test_process()
await_snapshot_start(stack_id, shape_handle, timeout \\ 45000)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

name(stack_id, shape_handle)
process_buffered_txn_fragments(state)
register_for_changes(stack_id, shape_handle)
start_link(config)
stop(pid, reason)
stop(stack_id, shape_handle, reason)
subscribe_materializer(stack_id, shape_handle, pid)
whereis(stack_id, shape_handle)

Functions

activate_mocked_functions_from_test_process()

await_snapshot_start(stack_id, shape_handle, timeout \\ 45000)

@spec await_snapshot_start(Electric.stack_id(), Electric.shape_handle(), timeout()) ::
  :started | {:error, any()}

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

name(stack_id, shape_handle)

process_buffered_txn_fragments(state)

register_for_changes(stack_id, shape_handle)

start_link(config)

stop(pid, reason)

stop(stack_id, shape_handle, reason)

subscribe_materializer(stack_id, shape_handle, pid)

@spec subscribe_materializer(Electric.stack_id(), Electric.shape_handle(), pid()) ::
  {:ok, Electric.Replication.LogOffset.t()}

whereis(stack_id, shape_handle)

@spec whereis(Electric.stack_id(), Electric.shape_handle()) :: pid() | nil