Minga.Extension.Supervisor (Minga v0.1.0)

Public extension lifecycle facade.

Per-extension ordering and policy live exclusively in Extension.Instance. This module retains bulk Git/Hex prerequisites, declaration reconciliation, iteration/error aggregation, pending-restart queries, and list projection.

Summary

Types

start_failure()

start_opts()

Injected lifecycle collaborators.

stop_failure()

Functions

cleanup_extension_contributions(name, command_registry, keymap, opts)

Removes command, keymap, and callback contributions owned by an extension.

implements_extension?(module)

Returns whether a module exports the required extension callbacks.

list_extensions(registry \\ ExtRegistry)

Returns compatible {name, version, status} list projection.

pending_artifact_restarts(registry, opts \\ [])

Reports path/Git sources changed since current-generation admission.

register_and_validate_options(name, module, config)

Registers and validates an extension module's declared options.

register_lazy_extension(supervisor, registry, name, entry, opts \\ [])

Registers one lazy declaration and its activation stubs through its stable authority.

start_all()

Starts all declared extensions after bulk source prerequisites.

start_all(supervisor, registry)

start_all(supervisor, registry, opts)

start_deferred_extension(supervisor, registry, name, entry, opts \\ [])

Starts a captured deferred declaration through the same Instance.

start_extension(supervisor, registry, name, entry, opts \\ [])

Starts one extension through its stable authority and returns the runtime PID.

start_link(opts \\ [])

Starts an isolated root supervisor for tests and embedded callers.

stop_all()

Stops all declared extension authorities, aggregating failures.

stop_all(supervisor, registry)

stop_all(supervisor, registry, opts)

stop_extension(supervisor, registry, name, entry, opts \\ [])

Stops one extension authority. Stop is idempotent.

validate_behaviour(module, name)

Validates that an extension module exports every required callback.

Types

start_failure()

@type start_failure() :: %{extension: atom(), reason: term()}

start_opts()

@type start_opts() :: [
  command_registry: GenServer.server(),
  keymap: GenServer.server(),
  callbacks: %{required(atom()) => function()},
  code_lease: GenServer.server(),
  callback_registry: atom(),
  artifact_admission: GenServer.server(),
  runtime_application: atom(),
  runtime_owned_modules: [module()],
  instance_registry: atom(),
  slow_lifecycle_threshold_ms: non_neg_integer(),
  transition_timeout_ms: pos_integer(),
  callback_timeout_ms: pos_integer(),
  runtime_query_timeout_ms: pos_integer(),
  drain_timeout_ms: pos_integer()
]

Injected lifecycle collaborators.

stop_failure()

@type stop_failure() :: %{extension: atom(), reason: term()}

Functions

cleanup_extension_contributions(name, command_registry, keymap, opts)

@spec cleanup_extension_contributions(
  atom(),
  GenServer.server(),
  GenServer.server(),
  start_opts()
) :: :ok | {:error, [map()]}

Removes command, keymap, and callback contributions owned by an extension.

implements_extension?(module)

@spec implements_extension?(module()) :: boolean()

Returns whether a module exports the required extension callbacks.

list_extensions(registry \\ ExtRegistry)

@spec list_extensions(GenServer.server()) :: [
  {atom(), String.t(), Minga.Extension.extension_status()}
]

Returns compatible {name, version, status} list projection.

pending_artifact_restarts(registry, opts \\ [])

@spec pending_artifact_restarts(GenServer.server(), start_opts()) :: [atom()]

Reports path/Git sources changed since current-generation admission.

register_and_validate_options(name, module, config)

@spec register_and_validate_options(atom(), module(), keyword()) ::
  :ok | {:error, term()}

Registers and validates an extension module's declared options.

register_lazy_extension(supervisor, registry, name, entry, opts \\ [])

@spec register_lazy_extension(
  GenServer.server(),
  GenServer.server(),
  atom(),
  Minga.Extension.Registry.entry(),
  start_opts()
) :: :ok | {:error, term()}

Registers one lazy declaration and its activation stubs through its stable authority.

start_all()

@spec start_all() :: :ok | {:error, [start_failure()]}

Starts all declared extensions after bulk source prerequisites.

start_all(supervisor, registry)

@spec start_all(GenServer.server(), GenServer.server()) ::
  :ok | {:error, [start_failure()]}

start_all(supervisor, registry, opts)

@spec start_all(GenServer.server(), GenServer.server(), start_opts()) ::
  :ok | {:error, [start_failure()]}

start_deferred_extension(supervisor, registry, name, entry, opts \\ [])

@spec start_deferred_extension(
  GenServer.server(),
  GenServer.server(),
  atom(),
  Minga.Extension.Registry.entry(),
  start_opts()
) :: :ok

Starts a captured deferred declaration through the same Instance.

start_extension(supervisor, registry, name, entry, opts \\ [])

@spec start_extension(
  GenServer.server(),
  GenServer.server(),
  atom(),
  Minga.Extension.Registry.entry(),
  start_opts()
) :: {:ok, pid()} | {:error, term()}

Starts one extension through its stable authority and returns the runtime PID.

start_link(opts \\ [])

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

Starts an isolated root supervisor for tests and embedded callers.

stop_all()

@spec stop_all() :: :ok | {:error, [stop_failure()]}

Stops all declared extension authorities, aggregating failures.

stop_all(supervisor, registry)

@spec stop_all(GenServer.server(), GenServer.server()) ::
  :ok | {:error, [stop_failure()]}

stop_all(supervisor, registry, opts)

@spec stop_all(GenServer.server(), GenServer.server(), start_opts()) ::
  :ok | {:error, [stop_failure()]}

stop_extension(supervisor, registry, name, entry, opts \\ [])

@spec stop_extension(
  GenServer.server(),
  GenServer.server(),
  atom(),
  Minga.Extension.Registry.entry(),
  start_opts()
) :: :ok | {:error, term()}

Stops one extension authority. Stop is idempotent.

validate_behaviour(module, name)

@spec validate_behaviour(module(), atom()) :: :ok | {:error, String.t()}

Validates that an extension module exports every required callback.