ExecutionPlane.Contracts.StreamBackpressure.V1 (execution_plane v0.1.0)

Copy Markdown View Source

Deterministic stream pressure and termination evidence.

Summary

Types

t()

@type t() :: %ExecutionPlane.Contracts.StreamBackpressure.V1{
  authority_packet_ref: term(),
  budget_ref: term(),
  contract_version: term(),
  correlation_id: term(),
  diagnostics_ref: term(),
  environment_ref: term(),
  idempotency_key: term(),
  installation_ref: term(),
  last_heartbeat_at: term(),
  permission_decision_ref: term(),
  pressure_class: term(),
  principal_ref: term(),
  project_ref: term(),
  release_manifest_ref: term(),
  resource_ref: term(),
  stream_ref: term(),
  system_actor_ref: term(),
  tenant_ref: term(),
  termination_reason: term(),
  trace_id: term(),
  workspace_ref: term()
}

Functions

contract_version()

@spec contract_version() :: String.t()

dump(event)

@spec dump(t()) :: map()

new(value)

@spec new(map() | keyword() | t()) :: {:ok, t()} | {:error, Exception.t()}

new!(value)

@spec new!(map() | keyword() | t()) :: t()