1#![deny(clippy::unwrap_used)]
2#![deny(clippy::expect_used)]
3
4mod client;
5pub mod connection;
6mod consumer;
7mod error;
8pub mod grouped;
9pub mod offset;
10pub mod producer;
11pub mod record;
12pub mod standalone;
13pub mod tls;
14
15pub use client::{
16 AuthConfig, ClientConfig, ClientStream, CommitResult, FetchResult, LanceClient,
17 SubscribeResult, TopicInfo,
18};
19pub use connection::{
20 ClusterClient, ConnectionPool, ConnectionPoolConfig, PoolStats, PooledClient,
21 ReconnectingClient,
22};
23pub use consumer::{
24 Consumer, ConsumerConfig, PollResult, SeekPosition, StreamingConsumer, StreamingConsumerConfig,
25};
26pub use error::{ClientError, parse_not_leader_error};
27pub use grouped::{
28 AssignmentStrategy, GroupConfig, GroupCoordinator, GroupedConsumer, WorkerConfig,
29};
30pub use offset::{
31 CollectingCommitHook, CommitInfo, HookedOffsetStore, LockFileOffsetStore, LoggingCommitHook,
32 MemoryOffsetStore, OffsetStore, PostCommitHook,
33};
34pub use producer::{MetricsSnapshot, Producer, ProducerConfig, ProducerMetrics, SendAck};
35pub use record::{
36 Record, RecordIterator, RecordParseError, RecordParserConfig, RecordType, TLV_HEADER_SIZE,
37 encode_record, parse_record, parse_records,
38};
39pub use standalone::{StandaloneConfig, StandaloneConsumer, StandaloneConsumerBuilder};
40pub use tls::TlsClientConfig;
41
42#[cfg(test)]
43#[allow(clippy::unwrap_used)]
44mod tests;