@type t() :: %Electric.Postgres.ReplicationClient.State{
  applied_wal: non_neg_integer(),
  connection_manager: pid(),
  display_settings: [String.t()],
  origin: String.t(),
  publication_name: String.t(),
  relation_received: {module(), atom(), [term()]},
  slot_name: String.t(),
  slot_temporary?: boolean(),
  stack_id: String.t(),
  start_streaming?: boolean(),
  step: Electric.Postgres.ReplicationClient.step(),
  transaction_received: {module(), atom(), [term()]},
  try_creating_publication?: boolean(),
  txn_collector: Electric.Postgres.ReplicationClient.Collector.t()
}