Barramento de eventos :id=event-bus

Publique e inscreva-se em eventos para observabilidade — monitoramento de atividade do runtime e da aplicação e reação a ela.

Carregamento

local events = require("events")

Inscrevendo-se em Eventos

Uma assinatura pode filtrar sistema e tipo, por exemplo, events.subscribe("users", "user.created"); omitir o tipo aceita todos os eventos do sistema.

Inscreva-se em eventos do event bus:

-- 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

Retorna: Subscription, error

Enviando Eventos

Enviar um evento para o event bus:

-- 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

Retorna: boolean, error

Um retorno bem-sucedido confirma apenas que o runtime aceitou o envio. Ele não confirma que algum subscriber recebeu ou processou o evento.

Métodos de Subscription

Obtendo o Channel

Obter o channel para receber 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 contém system, kind e path. O campo data só está presente quando o publisher fornece um payload não nulo.

Fechando Subscription

O fechamento é idempotente. Depois que o channel fecha e os eventos em buffer são drenados, receive() retorna nil, false.

Cancelar inscrição e fechar o channel:

local closed = sub:close() -- true

Permissões

Erros

Veja Tratamento de Erros para trabalhar com erros.