AshOnetime.Telemetry (ash_onetime v0.2.0)

Copy Markdown View Source

Emits the closed, value-free telemetry surface for keyed-effect admission.

Summary

Functions

admission(duration, strategy, resource, action, result_class)

@spec admission(non_neg_integer(), atom(), module(), atom(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

cache(strategy, resource, action, result_class)

@spec cache(atom(), module(), atom(), atom()) :: :ok | {:error, AshOnetime.Error.t()}

cleanup(strategy, resource, action, count, result_class)

@spec cleanup(atom(), module(), atom(), non_neg_integer(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

conflict(strategy, resource, action, result_class)

@spec conflict(atom(), module(), atom(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

encoding(duration, strategy, resource, action, result_class)

@spec encoding(non_neg_integer(), atom(), module(), atom(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

external_recovery(duration, strategy, resource, action, result_class)

@spec external_recovery(non_neg_integer(), atom(), module(), atom(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

fingerprint_mismatch(strategy, resource, action)

@spec fingerprint_mismatch(atom(), module(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

reap(strategy, resource, action, count, result_class)

@spec reap(atom(), module(), atom(), non_neg_integer(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

replay(duration, strategy, resource, action, result_class)

@spec replay(non_neg_integer(), atom(), module(), atom(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

store_uncertainty(strategy, resource, action, result_class)

@spec store_uncertainty(atom(), module(), atom(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

untracked_execution(strategy, resource, action)

@spec untracked_execution(atom(), module(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}

verification(duration, strategy, resource, action, result_class)

@spec verification(non_neg_integer(), atom(), module(), atom(), atom()) ::
  :ok | {:error, AshOnetime.Error.t()}