View Source Electric.Postgres.ReplicationClient.Collector (electric v0.9.5)

Conversion of incoming Postgres logical replication messages to internal change representation.

Summary

Functions

Handle incoming logical replication message by either building up a transaction or returning a complete built up transaction.

Types

@type t() :: %Electric.Postgres.ReplicationClient.Collector{
  relations: %{
    optional(Electric.Postgres.LogicalReplication.Messages.relation_id()) =>
      Electric.Postgres.LogicalReplication.Messages.Relation.t()
  },
  transaction: nil | Electric.Replication.Changes.Transaction.t(),
  tx_op_index: nil | non_neg_integer()
}

Functions

Link to this function

handle_message(msg, state)

View Source

Handle incoming logical replication message by either building up a transaction or returning a complete built up transaction.