Arcane.Stream
Streaming: tópicos, partições, offsets, grupos de consumo e janelas de tempo.
Funções (17)#
| Assinatura |
|---|
atraso(corrente, topico, grupo) |
confirmar(corrente, topico, grupo, evento) |
confirmar_ate(corrente, topico, grupo, eventos) |
consumir(corrente, topico, grupo, quantos=0, particao=None) |
corrente(raiz) |
grupos(corrente, topico) |
informacao(corrente, topico) |
janela(eventos, segundos=60, campo='quando') |
ler_de(corrente, topico, desde=0, quantos=0, particao=None) |
offset(corrente, topico, grupo) |
publicar(corrente, topico, valor, chave=None) |
publicar_lote(corrente, topico, eventos) |
remover_topico(corrente, nome) |
reter(corrente, topico, segmentos=10) |
topico(corrente, nome, particoes=1) |
topicos(corrente) |
voltar(corrente, topico, grupo, para=0) |