risingwave_common_service::observer_manager

Trait ObserverState

source 
pub trait ObserverState: Send + 'static {
    // Required methods
    fn subscribe_type() -> SubscribeType;
    fn handle_notification(&mut self, resp: SubscribeResponse);
    fn handle_initialization_notification(&mut self, resp: SubscribeResponse);
}

Required Methods§

source

fn subscribe_type() -> SubscribeType

source

fn handle_notification(&mut self, resp: SubscribeResponse)

modify data after receiving notification from meta

source

fn handle_initialization_notification(&mut self, resp: SubscribeResponse)

Initialize data from the meta. It will be called at start or resubscribe

Object Safety§

This trait is not object safe.

Implementors§