Crate risingwave_common_service

Source

Modules§

metrics_manager 🔒
observer_manager 🔒
tracing 🔒

Structs§

MetricsManager
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
TracingExtractLayer
A layer that decorates the inner service with TracingExtract.

Enums§

ObserverError
Error type for ObserverManager.

Traits§

Channel
NotificationClient
ObserverState