Struct NoSinkCommitCoordinator

pub struct NoSinkCommitCoordinator(!);

👎Deprecated

A place holder struct of SinkCommitCoordinator for sink without coordinator.

It can never be constructed because it holds a never type, and therefore it’s safe to mark all its methods as unreachable.

Explicitly mark this struct as deprecated so that when developers accidentally declare it explicitly as the associated type Coordinator when implementing Sink trait, they can be warned, and remove the explicit declaration.

Note: When we implement a sink without coordinator, don’t explicitly write type Coordinator = NoSinkCommitCoordinator. Just remove the explicit declaration and use the default associated type, and besides, don’t explicitly implement fn new_coordinator(...) and use the default implementation.

Tuple Fields

0: !

👎Deprecated

Trait Implementations

impl SinkCommitCoordinator for NoSinkCommitCoordinator

fn init<'life0, 'async_trait>( &'life0 mut self, _subscriber: SinkCommittedEpochSubscriber, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initialize the sink committer coordinator, return the log store rewind start offset.

fn commit<'life0, 'async_trait>( &'life0 mut self, _epoch: u64, _metadata: Vec<SinkMetadata>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

After collecting the metadata from each sink writer, a coordinator will call commit with the set of metadata. The metadata is serialized into bytes, because the metadata is expected to be passed between different gRPC node, so in this general trait, the metadata is serialized bytes.