log_store::kafka

Module worker

Source

Modules§

dump_index 🔒
fetch_latest_offset 🔒
flush 🔒
produce 🔒

Structs§

BackgroundProducerWorker 🔒
DumpIndexRequest 🔒
PendingRequest 🔒
ProduceRequest 🔒
ProduceResultHandle 🔒
Receives the committed offsets when data has been committed to Kafka or an unrecoverable error has been encountered.
ProduceResultReceiver 🔒
TruncateIndexRequest 🔒

Enums§

WorkerRequest 🔒