Spectre.Operation.Progress (Spectre v0.3.0)

Copy Markdown View Source

Revision-fenced, rate-limited progress emitted by a temporary Runner.

Summary

Types

t()

@type t() :: %Spectre.Operation.Progress{
  at: non_neg_integer(),
  attempt_id: String.t(),
  context_revision: non_neg_integer(),
  control_generation: non_neg_integer(),
  epoch: String.t(),
  fencing_token: String.t(),
  id: String.t(),
  loop_id: String.t(),
  metadata: map(),
  sequence: pos_integer(),
  trigger_generation: non_neg_integer(),
  value: term()
}

Functions

validate(progress)

@spec validate(t()) :: :ok | {:error, term()}