Bus de eventos

El bus de eventos publica actividad del runtime y la aplicación para monitorización, logs, métricas y efectos secundarios reactivos. Esta página es una referencia de API; los fragmentos presuponen una entrada Lua ejecutable con el módulo y permisos indicados.

Carga

local events = require("events")

Suscribirse a Eventos

Suscríbete a un sistema o patrón de sistema, con un filtro opcional por tipo de evento:

-- Subscribe to all order events
local sub, err = events.subscribe("orders.*")
if err then
    return nil, err
end

-- Process events
local ch = sub:channel()
while true do
    local evt, ok = ch:receive()
    if not ok then break end

    print(evt.system, evt.kind, evt.path)
    -- Process evt.data when the publisher supplied a payload.
end

Pasa un segundo argumento para limitar la entrega a un tipo, por ejemplo events.subscribe("users", "user.created"). Si se omite, se aceptan todos los tipos del sistema coincidente.

Devuelve: Subscription, error

Publicar eventos

Enviar un evento al bus de eventos:

-- Send order created event
local ok, err = events.send("orders", "order.created", "/orders/123", {
    order_id = "123",
    customer_id = "456",
    total = 99.99
})
if err then
    return nil, err
end

-- Send without data
local heartbeat_sent, heartbeat_err = events.send("system", "heartbeat", "/health")
if heartbeat_err then
    return nil, heartbeat_err
end

Devuelve: boolean, error

Un retorno correcto confirma que el runtime aceptó el envío. No confirma que algún suscriptor haya recibido o procesado el evento.

Métodos de Suscripción

Obtener el Canal

Obtener el canal para recibir eventos:

local json = require("json")
local ch = sub:channel()

local evt, ok = ch:receive()
if ok then
    print("System:", evt.system)
    print("Kind:", evt.kind)
    print("Path:", evt.path)
    local encoded, encode_err = json.encode(evt.data)
    if encode_err then return nil, encode_err end
    print("Data:", encoded)
end

Cada evento contiene system, kind y path. El campo data solo está presente cuando el publicador proporcionó un payload distinto de nil.

Cerrar Suscripción

Desuscribirse y cerrar el canal:

local closed = sub:close() -- true

El cierre es idempotente. Después de cerrar el canal, receive() devuelve nil, false cuando se agotan los eventos almacenados.

Permisos

Errores

Consulta Manejo de errores para trabajar con errores.