Struct fluvio_stream_dispatcher::store::ChangeListener

pub struct ChangeListener<S, C> where
    S: Spec,
    C: MetadataItem,  { /* fields omitted */ }

listen for changes local store

Implementations

impl<S, C> ChangeListener<S, C> where
    S: Spec,
    C: MetadataItem, 

pub fn new(store: Arc<LocalStore<S, C>>) -> ChangeListener<S, C>

pub fn event_publisher(&self) -> &EventPublisher

pub fn has_change(&mut self) -> bool

check if there should be any changes this should be done before event listener to ensure no events are missed

pub fn load_last(&mut self)

sync change to current change

pub fn set_last_change(&mut self, updated_change: i64)

pub fn last_change(&self) -> i64

pub fn current_change(&self) -> i64

pub async fn listen(&'_ mut self)

pub async fn sync_changes(
    &'_ mut self
) -> EpochChanges<MetadataStoreObject<S, C>>

find all changes derived from this listener

pub async fn sync_spec_changes(
    &'_ mut self
) -> EpochChanges<MetadataStoreObject<S, C>>

find all spec related changes

pub async fn sync_status_changes(
    &'_ mut self
) -> EpochChanges<MetadataStoreObject<S, C>>

all status related changes

pub async fn sync_meta_changes(
    &'_ mut self
) -> EpochChanges<MetadataStoreObject<S, C>>

all meta related changes

pub async fn sync_changes_with_filter(
    &'_ mut self,
    filter: &'_ ChangeFlag
) -> EpochChanges<MetadataStoreObject<S, C>>

all meta related changes

pub async fn wait_for_initial_sync(
    &'_ mut self
) -> Vec<MetadataStoreObject<S, C>, Global>

wait for initial loading and return all as expected

Trait Implementations

impl<S, C> Debug for ChangeListener<S, C> where
    S: Spec,
    C: MetadataItem, 

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.