Jido.Messaging.BridgeSupervisor (Jido Messaging v1.0.0)

Copy Markdown View Source

Dynamic supervisor for bridge runtime workers.

Bridge workers are reconciled against ConfigStore bridge configs.

Summary

Functions

Returns a specification to start this module under a supervisor.

Lists status snapshots for all running bridges.

Reconciles running bridge workers against enabled bridge configs.

Starts a bridge worker for a resolved bridge config.

Starts the dynamic supervisor that owns bridge runtime workers.

Stops the running bridge worker for bridge_id.

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

list_bridges(instance_module)

@spec list_bridges(module()) :: [Jido.Messaging.BridgeStatus.t()]

Lists status snapshots for all running bridges.

reconcile(instance_module)

@spec reconcile(module()) :: :ok | {:error, term()}

Reconciles running bridge workers against enabled bridge configs.

start_bridge(instance_module, config)

@spec start_bridge(module(), Jido.Messaging.BridgeConfig.t()) ::
  {:ok, pid()} | {:error, term()}

Starts a bridge worker for a resolved bridge config.

start_link(opts)

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

Starts the dynamic supervisor that owns bridge runtime workers.

stop_bridge(instance_module, bridge_id)

@spec stop_bridge(module(), String.t()) :: :ok | {:error, :not_found | term()}

Stops the running bridge worker for bridge_id.