AgentSessionManager.Persistence.ExecutionState (AgentSessionManager v0.8.0)

Copy Markdown View Source

In-memory execution state used while a run is in progress.

Summary

Types

execution_result()
t()

Functions

append_event(state, event)
cache_provider_metadata(state, metadata)
finalized_events(state)
new(session, run)
to_result(state)
update_run(state, fun)
update_session(state, fun)

Types

execution_result()

@type execution_result() :: %{
  session: AgentSessionManager.Core.Session.t(),
  run: AgentSessionManager.Core.Run.t(),
  events: [AgentSessionManager.Core.Event.t()],
  provider_metadata: map()
}

t()

@type t() :: %AgentSessionManager.Persistence.ExecutionState{
  events: [AgentSessionManager.Core.Event.t()],
  provider_metadata: map(),
  run: AgentSessionManager.Core.Run.t(),
  sequence_counter: non_neg_integer(),
  session: AgentSessionManager.Core.Session.t()
}

Functions

append_event(state, event)

@spec append_event(t(), AgentSessionManager.Core.Event.t()) :: t()

cache_provider_metadata(state, metadata)

@spec cache_provider_metadata(t(), map()) :: t()

finalized_events(state)

@spec finalized_events(t()) :: [AgentSessionManager.Core.Event.t()]

new(session, run)

@spec new(AgentSessionManager.Core.Session.t(), AgentSessionManager.Core.Run.t()) ::
  t()

to_result(state)

@spec to_result(t()) :: execution_result()

update_run(state, fun)

@spec update_run(t(), (AgentSessionManager.Core.Run.t() ->
                   AgentSessionManager.Core.Run.t())) :: t()

update_session(state, fun)

@spec update_session(t(), (AgentSessionManager.Core.Session.t() ->
                       AgentSessionManager.Core.Session.t())) ::
  t()