Crate risingwave_common_service 

Modules

await_tree_middleware 🔒

metrics_manager 🔒

observer_manager 🔒

tracing 🔒

Structs

AwaitTreeMiddleware

AwaitTreeMiddlewareLayer

GrpcCall

Await-tree key type for gRPC calls.

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

Type Aliases

AwaitTreeRegistryRef

Manages the await-trees of gRPC requests that are currently served by a node.