Struct GenericBatcher 

pub struct GenericBatcher<T: ClickInsertable, C: ClickTypeTransport> { /* private fields */ }

The main entry point for batch ingestion.

GenericBatcher is responsible for configuring and spawning the background worker. It is generic over the transport implementation C.

Implementations

impl<T, C> GenericBatcher<T, C>

where T: ClickInsertable + ClickTable + Send + Sync + 'static, C: ClickTypeTransport + Send + Sync + 'static,

pub fn new(client: C, config: BatchConfig) -> Self

Create a new batcher instance.

Arguments

• client - Configured ClickType client (or mock)
• config - Batching configuration

pub fn spawn(self) -> (BatcherHandle<T>, JoinHandle<()>)

Spawn the batcher worker task.

Returns a tuple containing:

1. BatcherHandle: Used to insert data.
2. JoinHandle: Used to supervise the worker task (detect panics or wait for completion).

Example

let (handle, worker) = batcher.spawn();
handle.insert(data).await?;
handle.close().await?;
worker.await?; // Ensure clean exit