@spec add_engine(GenServer.server(), map() | atom()) :: :ok

Adds an engine to the routing pool.

@spec attempt_engine_recovery(GenServer.server(), atom()) :: :ok | {:error, term()}

Attempts to recover a failed engine.

Returns a specification to start this module under a supervisor.

See Supervisor.

@spec configure_batch_strategy(
  GenServer.server(),
  keyword()
) :: :ok

Configures batch processing strategy.

@spec configure_engines(
  GenServer.server(),
  keyword()
) :: :ok | {:error, term()}

Configures engine settings.

@spec configure_health_check(
  GenServer.server(),
  keyword()
) :: :ok

Configures health check settings.

@spec get_engine_health(GenServer.server()) :: map()

Gets engine health information.

@spec get_stats(GenServer.server()) :: map()

Gets routing statistics and engine health.

@spec mark_engine_healthy(GenServer.server(), atom()) :: :ok | {:error, term()}

Marks an engine as healthy.

@spec mark_engine_unhealthy(GenServer.server(), atom(), term()) ::
  :ok | {:error, term()}

Marks an engine as unhealthy.

@spec remove_engine(GenServer.server(), atom()) :: :ok

Removes an engine from the routing pool.

@spec route_batch(GenServer.server(), [map()], keyword()) ::
  {:ok, list()} | {:error, term()}

Routes multiple requests as a batch.

Parameters

• router - Router PID or name
• requests - List of request specifications
• opts - Routing options

Examples

requests = [
  %{type: :get, target: "device1", oid: "sysDescr.0"},
  %{type: :get, target: "device2", oid: "sysUpTime.0"}
]

{:ok, results} = SnmpKit.SnmpMgr.Router.route_batch(router, requests)

@spec route_request(GenServer.server(), map(), keyword()) ::
  {:ok, term()} | {:error, term()}

Routes a request to the best available engine.

Parameters

• router - Router PID or name
• request - Request specification
• opts - Routing options

Examples

request = %{
  type: :get,
  target: "192.168.1.1",
  oid: "sysDescr.0"
}

{:ok, result} = SnmpKit.SnmpMgr.Router.route_request(router, request)

@spec set_engine_weights(GenServer.server(), map() | keyword()) ::
  :ok | {:error, term()}

Sets engine weights for weighted routing.

@spec set_strategy(GenServer.server(), atom()) :: :ok

Updates routing strategy.

@spec start_link(keyword()) :: GenServer.on_start()

Starts the request router.

Options

• :strategy - Routing strategy (:round_robin, :least_connections, :weighted, :affinity)
• :engines - List of engine specifications
• :health_check_interval - Health check interval in ms (default: 30000)
• :max_retries - Maximum retry attempts (default: 3)

Examples

{:ok, router} = SnmpKit.SnmpMgr.Router.start_link(
  strategy: :least_connections,
  engines: [
    %{name: :engine1, weight: 2, max_load: 100},
    %{name: :engine2, weight: 1, max_load: 50}
  ]
)