Electric.Shapes.Consumer.ChangeHandling (electric v1.4.13)

View Source

Summary

Functions

do_process_changes(changes, state, ctx, acc, count)
process_changes(changes, state, ctx)

Functions

do_process_changes(changes, state, ctx, acc, count)

process_changes(changes, state, ctx)

@spec process_changes(
  [Electric.Replication.Changes.change()],
  Electric.Shapes.Consumer.State.t(),
  context
) ::
  {filtered_changes :: [Electric.Replication.Changes.change()],
   state :: Electric.Shapes.Consumer.State.t(), count :: non_neg_integer(),
   last_log_offset :: Electric.Replication.LogOffset.t() | nil}
  | :includes_truncate
when context: map()