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
@spec handle_message(Electric.Postgres.LogicalReplication.Messages.message(), t()) :: t() | {Electric.Replication.Changes.Transaction.t() | Electric.Replication.Changes.Relation.t(), t()}
Handle incoming logical replication message by either building up a transaction or returning a complete built up transaction.