krabka_client_streams/runtime/
mod.rs

1//! Broker-backed execution runtime for built streams topologies.
2//!
3//! The I/O traits, the global-store manager and the `IQv2` query types build
4//! for every target. The stream thread, its tasks, the broker adapters and the
5//! `KafkaStreams` supervisor drive Kafka network clients, so they exist only on
6//! native targets; on `wasm32-unknown-unknown` an embedder drives a task's graph
7//! through [`EmbeddedTask`](crate::EmbeddedTask) instead.
8
9#[cfg(not(target_family = "wasm"))]
10mod app;
11#[cfg(not(target_family = "wasm"))]
12pub(crate) mod clock;
13#[cfg(not(target_family = "wasm"))]
14pub(crate) mod eos;
15pub(crate) mod global;
16pub mod io;
17#[cfg(not(target_family = "wasm"))]
18mod io_broker;
19#[cfg(not(target_family = "wasm"))]
20pub(crate) mod iq;
21#[cfg(not(target_family = "wasm"))]
22mod iq_view;
23pub mod iqv2;
24#[cfg(not(target_family = "wasm"))]
25mod task;
26#[cfg(not(target_family = "wasm"))]
27mod thread;
28
29#[cfg(not(target_family = "wasm"))]
30pub use app::{
31    DEFAULT_STREAMS_COMMIT_INTERVAL, DEFAULT_STREAMS_INTERACTIVE_QUERY_QUEUE_CAPACITY,
32    DEFAULT_STREAMS_POLL_INTERVAL, DEFAULT_STREAMS_STATE_STORE_CACHE_MAX_BYTES, KafkaStreams,
33    MAX_STREAMS_STATE_STORE_CACHE_MAX_BYTES, StreamsCommitInterval,
34    StreamsInteractiveQueryQueueCapacity, StreamsPollInterval, StreamsStateStoreCacheMaxBytes,
35};
36pub use io::{FetchBatch, FetchedRec, IsolationLevel, OffsetStore, RecordFetcher, RecordProducer};
37#[cfg(not(target_family = "wasm"))]
38pub use iq_view::{ReadOnlyKeyValueStore, ReadOnlySessionStore, ReadOnlyWindowStore};
krabka_client_streams/runtime/mod.rs

krabka_client_streams/runtime/
mod.rs
