risingwave_common_service

Module observer_manager

source

Structs§

  • ObserverManager
    ObserverManager is used to update data based on notification from meta. Call start to spawn a new asynchronous task We can write the notification logic by implementing ObserverNodeImpl.
  • RpcNotificationClient

Enums§

Constants§

Traits§