Docket.Runtime.Graph.Channel (docket v0.1.0)

Copy Markdown View Source

Internal runtime channel definition.

v0.1 channel types:

  • :last_value - input and state channels; stores the last committed value
  • :ephemeral - generated edge activation channels; visible for one step
  • :barrier - activation channels for edges declared with a list-form from; fires when every source in sources has completed since the last firing

Summary

Types

t()
type()

Types

t()

@type t() :: %Docket.Runtime.Graph.Channel{
  default: term(),
  id: String.t(),
  metadata: map(),
  reducer: Docket.Reducer.t() | nil,
  required: boolean(),
  sources: [String.t()],
  type: type(),
  value_schema: Docket.Schema.t() | nil
}

type()

@type type() :: :last_value | :ephemeral | :barrier