Spectre.Operation.Wait (Spectre v0.3.0)

Copy Markdown View Source

Portable wait boundary retained by an operational loop without a live Runner.

Summary

Types

t()

Functions

new(kind, opts \\ [])
validate(wait)
validate!(wait)

Types

t()

@type t() :: %Spectre.Operation.Wait{
  due_at: non_neg_integer() | nil,
  generation: non_neg_integer() | nil,
  id: String.t(),
  key: term(),
  kind: atom(),
  metadata: map(),
  payload: term(),
  reason: term()
}

Functions

new(kind, opts \\ [])

@spec new(
  atom(),
  keyword()
) :: t()

validate(wait)

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

validate!(wait)

@spec validate!(t()) :: t()