Управление процессами

Создание, мониторинг и коммуникация с дочерними процессами. Реализует паттерны акторной модели с передачей сообщений, супервизией и управлением жизненным циклом.

Глобальная переменная process всегда доступна — она не требует require() и не должна быть указана в modules:.

Информация о процессе

Получить текущий frame ID или process ID:

local frame_id = process.id()  -- Идентификатор цепочки вызовов
local pid = process.pid()       -- ID процесса

Отправка сообщений

Отправить сообщение(я) процессу по PID или зарегистрированному имени:

local ok, err = process.send(destination, topic, ...)

Разрешение: process.send на целевой PID

Создание процессов

-- Базовый spawn
local pid, err = process.spawn(id, host, ...)

-- С мониторингом (получать события EXIT)
local pid, err = process.spawn_monitored(id, host, ...)

-- Со связыванием (получать LINK_DOWN при аварийном завершении)
local pid, err = process.spawn_linked(id, host, ...)

-- И связанный, и мониторящий
local pid, err = process.spawn_linked_monitored(id, host, ...)

Разрешения:

• process.spawn на id процесса
• process.host на id хоста
• process.spawn.monitored на id процесса (для вариантов с мониторингом)
• process.spawn.linked на id процесса (для связанных вариантов)

Управление процессами

-- Принудительно завершить процесс
local ok, err = process.terminate(destination)

-- Запросить корректную отмену с опциональной причиной
local ok, err = process.cancel(destination, "shutting down")

Разрешения: process.terminate, process.cancel на целевой PID

Мониторинг и связывание

Мониторинг или связывание с существующим процессом:

-- Мониторинг: получать события EXIT при завершении цели
local ok, err = process.monitor(destination)
local ok, err = process.unmonitor(destination)

-- Связывание: двунаправленное, получать LINK_DOWN при аварийном завершении
local ok, err = process.link(destination)
local ok, err = process.unlink(destination)

Разрешения: process.monitor, process.unmonitor, process.link, process.unlink на целевой PID

Опции процесса

local options = process.get_options()
local ok, err = process.set_options({trap_links = true})

Inbox и Events

Получить каналы для приёма сообщений и событий жизненного цикла:

local inbox = process.inbox()    -- Объекты Message из топика @inbox
local events = process.events()  -- События жизненного цикла из топика @events

Типы событий

Поля событий

Подписка на топики

Подписка на пользовательские топики:

local ch = process.listen(topic, options)
process.unlisten(ch)

Объекты Message

При получении из inbox или с {message = true}:

local msg = inbox:receive()

msg:topic()            -- string: имя топика
msg:from()             -- string|nil: PID отправителя
msg:payload()          -- Payload: обёртка (вызовите :data() для извлечения)
msg:payload():data()   -- any: фактическое значение payload

Синхронный вызов

Создать процесс, дождаться результата и вернуть:

local result, err = process.exec(id, host, ...)

Разрешения: process.exec на id процесса, process.host на id хоста

Обновление процесса

Обновить текущий процесс на новое определение с сохранением PID:

-- Обновить на новую версию, передать состояние
process.upgrade(id, ...)

-- Оставить то же определение, перезапустить с новым состоянием
process.upgrade(nil, preserved_state)

Контекстный Spawner

Создать spawner с пользовательским контекстом для дочерних процессов:

local spawner = process.with_context({request_id = "123"})

Разрешение: process.context на "context"

Spawner с опциями

process.with_options(options) создаёт spawner, который несёт опции времени spawn (например, селектор сети) вместо значений контекста:

local spawner = process.with_options({network = "app:tor_proxy"})

Разрешение: process.context на "context"; выбор сети дополнительно требует network.select на этом ID сети.

Методы SpawnBuilder

SpawnBuilder иммутабелен — каждый метод возвращает новый экземпляр:

spawner:with_context(values)      -- Добавить значения контекста
spawner:with_actor(actor)         -- Установить актора безопасности
spawner:with_scope(scope)         -- Установить область безопасности
spawner:with_name(name)           -- Установить имя процесса
spawner:with_message(topic, ...)  -- Поставить в очередь сообщение для отправки после spawn
spawner:with_options(options)     -- Объединить опции времени spawn (например, network)

Разрешение: process.security на "security" для :with_actor() и :with_scope()

Методы spawn у Spawner

spawner:spawn(id, host, ...)
spawner:spawn_monitored(id, host, ...)
spawner:spawn_linked(id, host, ...)
spawner:spawn_linked_monitored(id, host, ...)

Те же разрешения, что и у функций spawn на уровне модуля.

Реестр имён

Регистрация процесса под именем и достижение его по имени вместо raw PID. Любая функция, принимающая destination (send, terminate, cancel, monitor, link, ...), принимает зарегистрированное имя вместо PID.

local ok, err = process.registry.register(name)               -- self, local scope
local pid, err = process.registry.lookup(name)
local ok, err = process.registry.unregister(name)

Область

Опциональный аргумент scope выбирает гарантию согласованности имени. По умолчанию LOCAL. Четыре области и их гарантии описаны в Руководстве по кластеру; кратко:

На автономной ноде значим только LOCAL; кластерные области требуют кластеризации.

register

local ok, err = process.registry.register(name, pid, scope)

Возвращает true при успехе, или nil, error при ошибке. Конфликты (имя уже зарегистрировано на другой PID в кластерной области) возвращают errors.ALREADY_EXISTS. Регистрация того же имени на тот же PID идемпотентна. Регистрация STRONG блокируется до подтверждения каждой живой нодой или истечения дедлайна; при таймауте возвращает ошибку.

Регистрация от имени другого PID дополнительно требует разрешения process.registry.foreign на целевой PID.

lookup

local pid, err = process.registry.lookup(name)

Возвращает строку зарегистрированного PID или nil, error с kind errors.NOT_FOUND, если имя не зарегистрировано.

unregister

local ok, err = process.registry.unregister(name, scope)

scope по умолчанию LOCAL и должен совпадать с областью, под которой имя было зарегистрировано. Для CONSISTENT и STRONG снятие регистрации разрешено только владеющему процессу; попытка снять регистрацию имени другого PID возвращает false. Имена также освобождаются автоматически при выходе владеющего процесса (и, для кластерных областей, при уходе его ноды), поэтому явное unregister нужно только для досрочного освобождения.

Разрешения

Разрешения контролируют, что вызывающий процесс может делать. Все проверки используют контекст безопасности (актор) вызывающего против целевого ресурса.

Вычисление политики

Политики могут разрешать/запрещать на основе:

• Actor: Принципал безопасности, делающий запрос
• Action: Выполняемая операция (например, process.send)
• Resource: Цель (PID, id процесса, id хоста или имя)
• Attributes: Дополнительный контекст, включая pid (ID процесса вызывающего)

Справочник разрешений

Кластерные области имён авторизуются суффиксными вариантами этих действий (process.registry.register.eventual, .consistent, .strong и соответствующими unregister), поэтому политика может разрешать локальное именование отдельно от кластерного.

Множественные разрешения

Некоторые операции требуют нескольких разрешений:

Ошибки

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

См. также

• Каналы — межпроцессная коммуникация
• Очереди сообщений — сообщения через очереди
• Функции — вызов функций
• Супервизия — управление жизненным циклом процессов
• Кластер — области имён и кластерное именование