link-common 0.5.2-rc.2

Shared Rust implementation for KalamDB link crates
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Kafka-style topic consumer support shared by the KalamDB SDK.

pub mod http_wire;
/// Data models (always available — serializable structs, no tokio dependency).
pub mod models;

#[cfg(all(feature = "tokio-runtime", feature = "consumer"))]
pub mod core;
#[cfg(all(feature = "tokio-runtime", feature = "consumer"))]
pub mod utils;

#[cfg(all(feature = "tokio-runtime", feature = "consumer"))]
pub use core::{ConsumerBuilder, TopicConsumer};

pub use http_wire::{
    decode_ack_response, decode_consume_response, AckRequestContext, ConsumeRequestContext,
};
#[cfg(feature = "tokio-runtime")]
pub use models::ConsumerConfig;
pub use models::{
    AckResponse, AutoOffsetReset, CommitMode, CommitResult, ConsumeMessage, ConsumeRequest,
    ConsumeResponse, ConsumerOffsets, ConsumerRecord, PayloadMode, TopicOp,
};