Система

Получение информации о среде выполнения: использование памяти, статистика сборщика мусора, сведения о CPU и метаданные процесса.

Загрузка

local system = require("system")

Завершение работы

Инициировать завершение системы с кодом выхода. Полезно для терминальных приложений; вызов из работающих акторов завершит всю систему:

local ok, err = system.exit(0)

Возвращает: boolean, error

Список модулей

Получить все загруженные Lua-модули с метаданными:

local mods, err = system.modules()

Возвращает: table[], error

Каждая таблица модуля содержит:

Статистика памяти

Получить детальную статистику памяти:

local stats, err = system.memory.stats()

Возвращает: table, error

Таблица статистики содержит:

Текущее выделение

Получить количество выделенных байт:

local bytes, err = system.memory.allocated()

Возвращает: number, error

Объекты в куче

Получить количество объектов в куче:

local count, err = system.memory.heap_objects()

Возвращает: number, error

Лимит памяти

Установить лимит памяти (возвращает предыдущее значение):

local prev, err = system.memory.set_limit(1024 * 1024 * 100)

Возвращает: number, error

Получить текущий лимит памяти:

local limit, err = system.memory.get_limit()

Возвращает: number, error

Принудительный GC

Принудительно запустить сборку мусора:

local ok, err = system.gc.collect()

Возвращает: boolean, error

Процент GC

Установить целевой процент GC (возвращает предыдущее значение). Значение 100 означает, что GC срабатывает при удвоении кучи:

local prev, err = system.gc.set_percent(200)

Возвращает: number, error

Получить текущий процент GC:

local percent, err = system.gc.get_percent()

Возвращает: number, error

Количество горутин

Получить количество активных горутин:

local count, err = system.runtime.goroutines()

Возвращает: number, error

GOMAXPROCS

Получить или установить значение GOMAXPROCS:

-- Получить текущее значение
local current, err = system.runtime.max_procs()

-- Установить новое значение
local prev, err = system.runtime.max_procs(4)

Возвращает: number, error

Количество CPU

Получить количество логических CPU:

local cpus, err = system.runtime.cpu_count()

Возвращает: number, error

ID процесса

Получить ID текущего процесса:

local pid, err = system.process.pid()

Возвращает: number, error

Имя хоста

Получить имя хоста системы:

local hostname, err = system.process.hostname()

Возвращает: string, error

Рабочий каталог

Получить текущий рабочий каталог среды выполнения:

local dir, err = system.process.cwd()

Возвращает: string, error

Хосты процессов

Получить список всех хостов процессов со статистикой воркеров и очереди:

local hosts, err = system.hosts.list()

Возвращает: table[], error

Каждая таблица хоста содержит:

Получить список процессов, работающих на конкретном хосте:

local procs, err = system.hosts.processes("app:host")

Возвращает: table[], error

Каждая таблица процесса содержит:

Состояние сервиса

Получить состояние конкретного супервизируемого сервиса:

local state, err = system.supervisor.state("namespace:service")

Возвращает: table, error

Таблица состояния содержит:

Состояния всех сервисов

Получить состояния всех супервизируемых сервисов:

local states, err = system.supervisor.states()

Возвращает: table[], error

Каждая таблица состояния имеет тот же формат, что и system.supervisor.state().

Кластерные примитивы

Подтаблицы system.node, system.cluster, system.raft и system.lock открывают доступ к слою кластеризации. Наиболее полезны при включённой кластеризации; на автономной ноде деградируют предсказуемо — system.raft.* сообщает "raft not available", system.cluster сообщает только о локальной ноде, а system.lock требует глобального реестра, который обеспечивает кластеризация.

Все операции чтения локальны и дёшевы: они сообщают вид зафиксированного состояния этой ноды, никогда не блокируясь на сети.

Идентичность ноды

system.node сообщает собственную идентичность этой ноды в кластере.

local id, err = system.node.id()      -- ID этой ноды
local addr, err = system.node.addr()  -- рекламируемый сетевой адрес
local role, err = system.node.role()  -- "leader" | "voter" | "standby" | "non-member"

Разрешение: system.read на node.

Membership кластера

system.cluster сообщает вид кластера: кто члены и кто лидер.

local members, err = system.cluster.members()  -- массив таблиц нод
local leader, err = system.cluster.leader()    -- ID ноды-лидера, или "" если неизвестен
local n, err = system.cluster.size()           -- количество видимых членов

system.cluster.members() возвращает массив таблиц нод. Локальная нода включена один раз и сортируется первой.

Разрешение: system.read на cluster.

Состояние Raft

system.raft читает локальный вид ядра консенсуса Raft этой ноды. Каждая функция возвращает nil, error ("raft not available") когда Raft не запущен на этой ноде.

local leader, err = system.raft.is_leader()      -- boolean
local member, err = system.raft.is_member()      -- boolean: voter или standby
local role, err = system.raft.role()             -- те же значения что у system.node.role()
local term, err = system.raft.term()             -- текущий Raft term
local idx, err = system.raft.commit_index()      -- наибольший зафиксированный индекс лога
local stats, err = system.raft.stats()           -- сырая карта статистики (string -> string)

Разрешение: system.read на raft, за исключением system.raft.stats(), которая требует system.read на raft_stats.

Распределённые блокировки

system.lock обеспечивает кластерное взаимное исключение. Блокировка — это глобально уникальное имя, принадлежащее вызывающему процессу. Построена на области Strong, поэтому в кластере может существовать не более одного держателя, и блокировка автоматически освобождается при выходе держателя или уходе его ноды — зависших блокировок нет для очистки.

local ok, err = system.lock.acquire("orders.migration")
if ok then
  -- критическая секция: только один держатель в кластере
  system.lock.release("orders.migration")
end

Захват fail-fast: если блокировка уже занята, немедленно возвращает false, не блокируясь, поэтому вызывающие реализуют собственный retry и backoff. Только текущий держатель может освободить; освобождение блокировки, которой вы не владеете, — безопасная no-op.

Разрешение: system.lock на name блокировки (политика может ограничивать, какие имена вызывающий может блокировать).

Разрешения

Системные операции подчиняются вычислению политики безопасности.

Ошибки

См. Обработка ошибок для работы с ошибками.