> ## Documentation Index
> Fetch the complete documentation index at: https://docs.lerian.studio/llms.txt
> Use this file to discover all available pages before exploring further.

# O que é o Streaming Hub?

> O Streaming Hub é a borda de entrega gerenciada da Lerian. Ele consome o stream interno de eventos da plataforma e distribui os eventos para consumidores de webhook, de fila e de pull.

**Streaming Hub** é o serviço de entrega de eventos da Lerian. Ele fica na borda entre o stream interno de eventos da plataforma e os sistemas que você roda fora dela. Ele entrega cada evento que interessa a você para um destino seu: um webhook, uma fila na nuvem ou um cursor do qual você faz pull.

Os produtos Lerian publicam eventos de domínio (fatos de negócio no passado, como uma conta criada ou uma transação lançada) em um backbone de streaming compartilhado. O Streaming Hub se inscreve nesse backbone em seu nome, compara os eventos com as subscriptions que você registra e os entrega. Você descreve *quais eventos vão para onde*. O hub é dono do ciclo de consumir, comparar e entregar.

## O Streaming Hub na plataforma Lerian

***

O backbone de eventos da plataforma é um [stream baseado em CloudEvents](https://docs.lerian.studio/pt/reference/events/overview.md) compartilhado, transportado em Kafka/Redpanda. A entrega nesse stream é pelo menos uma vez, e os eventos de cada tenant trafegam nos mesmos tópicos. Para consumi-lo diretamente, você deve rodar seu próprio consumidor Kafka. Esse consumidor controla offsets, filtra tipos de evento, deduplica, refaz entregas que falharam e assina requisições de saída.

O Streaming Hub faz esse trabalho uma vez, como uma borda gerenciada. Ele consome o stream interno e nunca produz nele. Ele transforma um feed bruto de eventos em entrega por destino que você configura por uma única API.

Como o hub é a borda de entrega, as garantias sobre as quais você constrói são o contrato de entrega do hub, não o stream bruto. Seu endpoint de webhook verifica uma assinatura, deduplica por um id de evento estável e responde rápido. Veja [Como o Streaming Hub funciona](https://docs.lerian.studio/pt/platform/streaming-hub/how-streaming-hub-works.md) para o caminho completo que um evento percorre.

## Tipos de sink

***

Uma subscription entrega para exatamente um destino, chamado de **sink**. O Streaming Hub aceita cinco tipos de sink:

| Tipo de sink | Entrega | Destino |
| - | - | - |
| `webhook` | Push | Um endpoint `https://` seu. Cada requisição é assinada com HMAC e carrega headers de correlação CloudEvents. |
| `pull` | Pull | Um cursor no servidor. Seu consumidor lê uma página de eventos com `GET /v1/events`; a leitura também serve como confirmação. |
| `sqs` | Push | Uma fila Amazon SQS, acessada por uma credencial de saída verificada ou por um grant delegado da AWS. |
| `rabbitmq` | Push | Um exchange e uma routing key do RabbitMQ. |
| `eventbridge` | Push | Um event bus do Amazon EventBridge, acessado por uma credencial de saída verificada ou por um grant delegado da AWS. |

Sinks push (`webhook`, `sqs`, `rabbitmq`, `eventbridge`) entregam eventos para você à medida que eles correspondem. O sink `pull` inverte isso: o hub mantém os eventos em um cursor e seu consumidor os busca no próprio ritmo.

Uma subscription de webhook fica apta a receber entregas depois que uma sondagem assinada confirma que seu endpoint responde. Subscriptions de RabbitMQ exigem uma credencial de broker que o hub sonda antes da ativação. SQS e EventBridge podem ser ativados com uma credencial de saída que o hub sonda, ou com um grant delegado da AWS que não armazena credencial. Veja [Gerenciar subscriptions](https://docs.lerian.studio/pt/platform/streaming-hub/managing-subscriptions.md).

## Modelo de deploy

***

Em BYOC, a Lerian instala e atualiza o Streaming Hub na sua nuvem pelo [Lifecycle Management](https://docs.lerian.studio/pt/platform/lifecycle-management.md). Lá ele roda como um serviço single-tenant, com um tenant de control plane configurado e sem dependência da gestão de tenants hospedada pela Lerian.

Na Lerian Cloud, a Lerian opera o hub, e subscriptions, eventos e cursores ficam isolados por tenant.

## A API de control plane

***

Você gerencia subscriptions pela API de control plane `/v1`. Cada rota exige um token do Access Manager (`Authorization: Bearer <token>`). O hub nunca pega o tenant de um corpo de requisição, caminho ou query. Por ela, você:

* cria, lista, lê e exclui subscriptions.
* verifica um destino (`ping` / `verify`) e fornece credenciais de fila.
* rotaciona um segredo de assinatura de webhook.
* lê a saúde de entrega de uma subscription.
* lê o dashboard operacional das suas subscriptions.
* faz pull de eventos (`GET /v1/events`) para sinks `pull`.
* navega pelo [catálogo](https://docs.lerian.studio/pt/reference/events/overview.md) de eventos que o hub enxerga.

O conjunto completo de operações, os formatos de requisição e os tokens de erro estão na referência da API. Comece pela [introdução da referência](https://docs.lerian.studio/pt/reference/introduction.md).

## Próximos passos

***

> [card] [Como o Streaming Hub funciona](https://docs.lerian.studio/pt/platform/streaming-hub/how-streaming-hub-works.md)
>
> O caminho que um evento percorre: ingestão, correspondência, despacho, nova tentativa e desativação automática.

> [card] [Gerenciar subscriptions](https://docs.lerian.studio/pt/platform/streaming-hub/managing-subscriptions.md)
>
> Crie subscriptions de webhook e de fila, conecte grants da AWS e rotacione segredos.

> [card] [Consumir eventos](https://docs.lerian.studio/pt/platform/streaming-hub/consuming-events.md)
>
> Verifique assinaturas de webhook, deduplique entregas e faça pull de eventos.

> [card] [Visão geral do streaming de eventos](https://docs.lerian.studio/pt/reference/events/overview.md)
>
> O contrato CloudEvents compartilhado que cada evento Lerian segue.


This documentation is built and hosted on [Mintlify](https://mintlify.com), a developer documentation platform.