Packages

req_managed_agents

0.9.1
0.10.0 0.9.1 0.9.0 0.8.0 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.2 0.4.1 0.4.0 0.3.0 0.2.1 0.2.0 0.1.0

Provider-agnostic Elixir client for agent runtimes — one Session loop, any loop host: server-side (Anthropic Claude Managed Agents, AWS Bedrock AgentCore) or in-process (Local, over any OpenAI-compatible chat endpoint). Your tools run locally.

HexDocs

Current section

Files

Jump to
Readme
17 Versions
7 Dependencies
Dependants
Files
Activity
req_managed_agents lib req_managed_agents session state.ex
Raw

lib/req_managed_agents/session/state.ex 

defmodule ReqManagedAgents.Session.State do

  @moduledoc false



  alias ReqManagedAgents.{SessionInfo, Tools, ToolUse, Usage}



  defstruct [

    :provider,

    :mode,

    :conn,

    :info,

    :opts,

    :handler,

    :context,

    :caller,

    :notify,

    :meta,

    :ref,

    :consumer,

    :poll_task,

    :turn_guard,

    :enforced_terminal_tool,

    :pending_user_message,

    delta?: false,

    kicked_off: false,

    seen: nil,

    reconnect_attempts: 0,

    events: [],

    turn_events: [],

    live_forwarded: 0,

    turns: 0,

    max_turns: 50,

    custom_tool_uses: [],

    server_tool_uses: [],

    max_reprompts: 2,

    reprompts_left: 2,

    usage: nil

  ]



  @type t :: %__MODULE__{

          provider: module(),

          mode: :streaming | :request_response,

          conn: term(),

          info: SessionInfo.t(),

          opts: keyword(),

          handler: module() | Tools.handler_fun(),

          context: term() | nil,

          caller: pid() | nil,

          notify: pid() | nil,

          meta: map(),

          ref: reference() | nil,

          consumer: pid() | nil,

          poll_task: Task.t() | nil,

          turn_guard: (map() -> :cont | {:halt, term()}) | nil,

          enforced_terminal_tool: String.t() | nil,

          pending_user_message: String.t() | nil,

          delta?: boolean(),

          kicked_off: boolean(),

          seen: MapSet.t(),

          reconnect_attempts: non_neg_integer(),

          events: [map()],

          turn_events: [map()],

          live_forwarded: non_neg_integer(),

          turns: non_neg_integer(),

          max_turns: pos_integer(),

          custom_tool_uses: [ToolUse.t()],

          server_tool_uses: [ToolUse.t()],

          max_reprompts: non_neg_integer(),

          reprompts_left: non_neg_integer(),

          usage: Usage.t()

        }

end