Struct PollMerger 

pub struct PollMerger { /* private fields */ }

Poll merger for cross-shard aggregation.

Implementations

impl PollMerger

pub fn new(adapter: Arc<dyn Adapter>, shard_ids: Vec<u16>) -> Self

Create a new poll merger.

shard_ids should be the snapshot of currently-active shard IDs (e.g. ShardManager::shard_ids()). Passing 0..num_shards is only correct when ids are guaranteed dense from 0 — i.e. the static-shards path with no scaling.

pub async fn poll( &self, request: ConsumeRequest, ) -> Result<ConsumeResponse, ConsumerError>

Poll events according to the request.