View Source Electric.LogItems (electric v1.0.1)

Defines the structure and how to create the items in the log that the electric client reads.

The log_item() data structure is a map for ease of consumption in the Elixir code, however when JSON encoded (not done in this module) it's the format that the electric client accepts.

Summary

Types

log_item()

Functions

from_change(change, txids, pk_cols, replica)

keep_generic_headers(item)

merge_updates(u1, u2)

Types

log_item()

@type log_item() ::
  {Electric.Replication.LogOffset.t(),
   %{key: String.t(), value: map(), headers: map()}}

Functions

from_change(change, txids, pk_cols, replica)

@spec from_change(
  Electric.Replication.Changes.data_change(),
  txids :: nil | non_neg_integer() | [non_neg_integer(), ...],
  pk_cols :: [String.t()],
  replica :: Electric.Shapes.Shape.replica()
) :: [log_item(), ...]

keep_generic_headers(item)