Bedrock.DataPlane.CommitProxy.Finalization.FinalizationPlan (bedrock v0.7.0)

View Source

Pipeline state for transaction finalization using unified transaction storage for maximum efficiency and clarity.

Summary

Types

t()

@type t() :: %Bedrock.DataPlane.CommitProxy.Finalization.FinalizationPlan{
  aborted_count: non_neg_integer(),
  commit_version: Bedrock.version(),
  error: term() | nil,
  known_committed_version: Bedrock.version() | nil,
  last_commit_version: Bedrock.version(),
  replied_indices: MapSet.t(non_neg_integer()),
  routing_data: Bedrock.DataPlane.CommitProxy.RoutingData.t() | nil,
  stage: atom(),
  transaction_count: non_neg_integer(),
  transactions: %{
    required(non_neg_integer()) =>
      {non_neg_integer(), Bedrock.DataPlane.CommitProxy.Batch.reply_fn(),
       Bedrock.DataPlane.Transaction.encoded(),
       Bedrock.DataPlane.CommitProxy.Batch.commit_mode()}
  },
  transactions_by_log: %{
    required(Bedrock.DataPlane.Log.id()) =>
      Bedrock.DataPlane.Transaction.encoded()
  }
}