List of all items

Structs

• batch_coordinator::BatchInfo
• batch_coordinator::BatchMetadata
• batch_coordinator::CommitBatchResponse
• batch_coordinator::CreateTopicAndPartitionsRequest
• batch_coordinator::DeleteFilesRequest
• batch_coordinator::DeleteRecordsRequest
• batch_coordinator::DeleteRecordsResponse
• batch_coordinator::FileToDelete
• batch_coordinator::FindBatchRequest
• batch_coordinator::FindBatchResponse
• batch_coordinator::ListOffsetsRequest
• batch_coordinator::ListOffsetsResponse
• batch_coordinator::TopicIdPartition
• batch_coordinator::simple::SimpleBatchCoordinator
• messages::BatchCoordinate
• messages::CommitBatchRequest
• messages::CommittedBatch
• messages::ConsumeBatch
• messages::ConsumeRequest
• messages::ConsumeResponse
• messages::DeleteRecordsRequest
• messages::DeleteRecordsResponse
• messages::ProduceRequest
• messages::ProduceRequestCollection
• messages::ProduceResponse

Enums

• batch_coordinator::TimestampType
• error::RisklessError

Traits

• batch_coordinator::CommitFile
• batch_coordinator::CreateTopicAndPartitions
• batch_coordinator::DeleteFiles
• batch_coordinator::FindBatches

Functions

• consume
• delete_record
• flush
• scan_and_permanently_delete_records

Type Aliases

• error::RisklessResult