Broker

Central de Controle da Fila

ao vivo
Documentaçã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
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).
Endpoints (integracoes externas)
IDLabelBase URLStatusIngestão HTTP
Usuários do dashboard
UsuárioPerfilCriado em
Testar fluxo de ponta a ponta

Enfileira 10 jobs de teste em cada endpoint habilitado — equivalente a node scripts/seed.js 10, sem depender de uma API externa real.

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.

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)