Crate lnc_client 

Re-exports

pub use connection::ClusterClient;

pub use connection::ConnectionPool;

pub use connection::ConnectionPoolConfig;

pub use connection::PoolStats;

pub use connection::PooledClient;

pub use connection::ReconnectingClient;

pub use grouped::AssignmentStrategy;

pub use grouped::GroupConfig;

pub use grouped::GroupCoordinator;

pub use grouped::GroupedConsumer;

pub use grouped::WorkerConfig;

pub use offset::CollectingCommitHook;

pub use offset::CommitInfo;

pub use offset::HookedOffsetStore;

pub use offset::LockFileOffsetStore;

pub use offset::LoggingCommitHook;

pub use offset::MemoryOffsetStore;

pub use offset::OffsetStore;

pub use offset::PostCommitHook;

pub use producer::MetricsSnapshot;

pub use producer::Producer;

pub use producer::ProducerConfig;

pub use producer::ProducerMetrics;

pub use producer::SendAck;

pub use record::Record;

pub use record::RecordIterator;

pub use record::RecordParseError;

pub use record::RecordParserConfig;

pub use record::RecordType;

pub use record::TLV_HEADER_SIZE;

pub use record::encode_record;

pub use record::parse_record;

pub use record::parse_records;

pub use standalone::StandaloneConfig;

pub use standalone::StandaloneConsumer;

pub use standalone::StandaloneConsumerBuilder;

pub use tls::TlsClientConfig;

Modules

connection

Connection Management and Resilience

grouped

Grouped Consumer Mode

offset

Client-side offset persistence for LANCE consumers

producer

Producer Abstraction Layer

record

TLV Record Parsing

standalone

Standalone Consumer Mode

tls

TLS Support for LANCE Client

Structs

AuthConfig

ClientConfig

CommitResult

Result of a commit offset operation

Consumer

A consumer for reading records from a LANCE topic stream

ConsumerConfig

Configuration for a consumer

FetchResult

Result of a fetch operation

LanceClient

PollResult

Result of a poll operation

StreamingConsumer

A streaming consumer that uses subscribe/unsubscribe signals

StreamingConsumerConfig

Configuration for a streaming consumer

SubscribeResult

Result of a subscribe operation

TopicInfo

Enums

ClientError

ClientStream

Wrapper enum for TCP and TLS streams to avoid dynamic dispatch

SeekPosition

Position specifier for seeking within a stream

Functions

parse_not_leader_error

Parse a NOT_LEADER error message and extract the redirect address if present