Broker

Central de Controle

Integrações confiáveis entre sistemas, sem dor de cabeça.

Broker é o hub assíncrono que recebe, enfileira, transforma e entrega eventos para suas APIs externas — com retries automáticos, proteção contra falhas em cascata e controle total pelo painel.

🔁
Fila resilientepg-boss + Postgres, retries com backoff, circuit breaker e rate limiting nativos.
📊
Painel completoJobs, filas, métricas e alertas em tempo real, sem planilha nem log solto.
🧩
Fluxos visuaisRegras de negócio no estilo low-code antes de cada chamada externa, sem escrever código.
🧠
Agente de IAAssistente operacional que consulta a fila e age sobre ela por conversa.
🏗️
Arquitetura que escala horizontalmenteWorkers stateless por fila (pg-boss sobre Postgres) — basta subir mais instâncias para aumentar a capacidade, sem coordenação extra. Cada endpoint tem seu próprio rate limit e circuit breaker, então uma API externa instável nunca derruba as demais.

Entrar

Broker

Central de Controle da Fila

ao vivo
Documentação Swagger (API de ingestão)
Arquitetura, instalação e configuração
carregando...
Circuit Breaker
carregando...
 
Consumo da Fila
carregando...
controle manual, independe do circuit breaker
Todos os Endpoints
Overview
Jobs
Logs
Tabelas
Parametros
Admin
Arquitetura
Diagrama geral — volumetria e tempo de transmissao por endpoint
Job pendente mais antigo
carregando...
sinal de backlog acumulando — entre todos os endpoints
Taxa de erro (24h)
carregando...
 
Throughput
carregando...
 
Volume total (historico)
carregando...
 
Tempo medio de processamento
carregando...
 
Entrada x Saida (24h)
carregando...
criados vs. resolvidos (completed+failed) — todos os endpoints
Tempo de processamento (minimo / maximo)
carregando...
 
EndpointStatusCircuit BreakerWorkersPendenteActiveCompletedFailedErro (24h)Volume (24h)Total historicoLat. mediaP95
Job pendente mais antigo
carregando...
sinal de backlog acumulando
Taxa de erro (24h)
carregando...
 
Throughput
carregando...
 
Volume total (historico)
carregando...
 
Tempo medio de processamento
carregando...
 
Entrada x Saida (24h)
carregando...
criados vs. resolvidos (completed+failed)
Tempo de processamento (minimo / maximo)
carregando...
 
Diagnostico de gargalo
Espera na fila (antes de comecar)-
Processamento (chamada a API externa)-
Concorrencia em uso (Active / assinaturas paralelas)-
Carregando diagnostico...
 
Volume diario (ultimos 7 dias)
Completados Falhados
Completados x Falhados por hora (24h)
Completados Falhados
Criados x Resolvidos por hora (24h)
Criados (entrada) Resolvidos (saida)
Distribuicao de tentativas ate resolver
Completados Falhados
Ultimos jobs falhados
Fila Estado Buscar no conteudo
IDFilaEstadoTentativasData OutputCriado emIniciado emConcluido em
Fonte Linhas
Tabela
Nao precisa fazer nada alem de clicar em Salvar. O worker releem os parametros sozinho (a cada workerConfigPollMs, por padrao 3s) e aplica na hora — circuit breaker, rate limiter e alertas mudam imediatamente; mudar a concorrencia faz o worker re-assinar a fila sozinho, sem reiniciar. A unica excecao e retryLimit/retryDelay/retryBackoff: so valem para jobs enviados depois da mudanca (jobs ja na fila mantêm a config com que foram criados).
Manutencao (dados de teste)

Remove jobs ja finalizados (completed, failed, cancelled) da fila, mantendo o que ainda esta em andamento. Util para limpar ruido acumulado de testes.

Purgar TUDO — remove todos os jobs da fila, inclusive pendentes e em processamento. Destrutivo, use so em ambiente de teste/demo.

Área restrita a administradores — gestão de acesso, cadastro de endpoints, envio manual de carga de teste e configuração do agente de IA.
Endpoints (integrações externas)
IDLabelBase URLStatusIngestão HTTP
Usuários do dashboard
UsuárioPerfilCriado em
Mock-API (laboratório de testes)

Serviço local com 5 rotas — uma por tipo de credencial (API key, Bearer, Basic, HMAC, público) — que simulam sucesso/erro aleatórios. Nunca sobe em produção (src/mock-api/server.js).

verificando...
Enviar carga de teste para a fila

Enfileira jobs de teste (mesmo formato do scripts/seed.js) direto nos endpoints selecionados, sem depender de uma API externa real.

Endpoints de destino
Na fila agora
—
pendentes nos endpoints marcados
Modelos de IA cadastrados

O chat flutuante tenta o modelo de maior prioridade (número menor) primeiro; se a chamada falhar (instabilidade do provedor ou credencial inválida), cai automaticamente pro próximo habilitado — nunca no meio de uma ação em andamento, sempre recomeçando do zero com o próximo. Cadastre mais de um pra ter redundância.

PrioridadeProvedorModeloStatus
Instruções permanentes do agente

Textos curtos injetados em toda chamada ao LLM, pra ele ir ficando mais afiado sobre o seu ambiente (ex: "o endpoint orders representa pedidos do site X", "sempre confirme antes de pausar uma fila"). Cadastrar uma instrução com o mesmo título de uma existente substitui o conteúdo, não duplica.

TítuloInstruçãoAtualizado em
Fluxos (módulo opcional, tipo n8n)

Filtra e transforma o payload de um endpoint antes dele seguir pra API externa já configurada — sem código, montando visualmente. Um fluxo por endpoint. Publicar tem efeito no próximo job, sem reiniciar nada. Fora de escopo (de propósito): chamada HTTP dentro do fluxo, múltiplas saídas por job, loop/agendamento — ver documentação.

Endpoint

Arraste os nós pelo título pra reorganizar. Pra conectar um nó no outro (o payload de saída de um vira o payload de entrada do próximo), arraste da bolinha à direita de um nó até a bolinha à esquerda de outro — ou use o seletor "vai para" dentro do nó, os dois fazem a mesma coisa.

Fluxo
Controle de fluxo

As duas vias de um split precisam terminar no mesmo nó de merge. Em campo repetido, a via "b" vence.

Banco de dados

SQL sempre parametrizada — valor do payload nunca é concatenado na query.

Arquivos

Caminho travado dentro de um diretório fixo do servidor, mesmo vindo do payload.

Filas existentes
Simular / depurar passo a passo

Roda o rascunho atual (não precisa estar publicado) contra um JSON de exemplo, na hora, sem criar job nenhum na fila. Clique num passo abaixo pra ver exatamente o payload antes/depois daquele nó.

Execuções recentes (produção + testes)
QuandoTipoStatusJobDuraçãoDetalhe
Arquitetura ao vivo
Dashboard
servidor HTTP + SSE
consultas SQL
→
PostgreSQL
carregando...
jobs pendentes
→
Worker
carregando...
rate limit
→
API Externa
carregando...
slot de processamento ocupado circuit breaker fechado (fluindo) meio-aberto (testando) aberto (bloqueado)
Agente de IA