Packages

beam_weaver

0.1.9
0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Elixir-native LangChain, LangGraph, and DeepAgents for traceable LLM apps: OTP workflows, tools, memory, human-in-the-loop, streaming, custom clients/adapters, minimal deps, and WeaveScope tracing.

Current section

Files

Jump to
Readme
14 Versions
7 Dependencies
Dependants
Files
Activity
beam_weaver lib beam_weaver agent server.ex
Raw

lib/beam_weaver/agent/server.ex 

defmodule BeamWeaver.Agent.Server do

  @moduledoc false



  use GenServer



  def start_link(agent_module, opts \\ []) do

    GenServer.start_link(__MODULE__, {agent_module, opts}, name: opts[:name])

  end



  def invoke(server, input, opts \\ []) do

    GenServer.call(server, {:invoke, input, opts}, Keyword.get(opts, :timeout, 300_000))

  end



  def stream_events(server, input, opts \\ []) do

    GenServer.call(server, {:stream_events, input, opts}, Keyword.get(opts, :timeout, 300_000))

  end



  @impl true

  def init({agent_module, opts}) do

    {:ok, %{agent_module: agent_module, opts: opts}}

  end



  @impl true

  def handle_call({:invoke, input, opts}, _from, state) do

    {:reply, BeamWeaver.Agent.invoke(state.agent_module, input, Keyword.merge(state.opts, opts)), state}

  end



  def handle_call({:stream_events, input, opts}, _from, state) do

    {:reply, BeamWeaver.Agent.stream_events(state.agent_module, input, Keyword.merge(state.opts, opts)), state}

  end

end