Skip to main content

krabka_client_streams/membership/
mod.rs

1//! Streams group membership: the `StreamsGroupHeartbeat` lifecycle and the
2//! assignments.
3//!
4//! The heartbeat client is a Kafka network client and exists only on native
5//! targets. The assignment value types build everywhere, so an embedder on
6//! `wasm32-unknown-unknown` can describe the tasks its own membership logic
7//! assigns.
8
9#[cfg(not(target_family = "wasm"))]
10mod assignment;
11#[cfg(not(target_family = "wasm"))]
12mod client;
13#[cfg(not(target_family = "wasm"))]
14pub(crate) mod coordinator;
15#[cfg(not(target_family = "wasm"))]
16mod status;
17mod types;
18
19#[cfg(not(target_family = "wasm"))]
20pub use client::{
21    DEFAULT_STREAMS_JOIN_RETRY_BACKOFF, DEFAULT_STREAMS_LEAVE_HEARTBEAT_TIMEOUT,
22    DEFAULT_STREAMS_REBALANCE_TIMEOUT, SchemaPrewarm, StreamsJoinRetryBackoff,
23    StreamsLeaveHeartbeatTimeout, StreamsMembership, StreamsRebalanceTimeout,
24};
25pub use types::{
26    StreamsAssignment, StreamsEvent, StreamsStatus, TaskAssignment, TaskOffsetTracker,
27    TopicPartition,
28};