Module manager

Re-exports

pub use event_log::EventLogManagerRef;

Modules

diagnose

env 🔒

event_log

idle 🔒

license 🔒

metadata 🔒

notification 🔒

notification_version 🔒

prelude

sink_coordination

streaming_job 🔒

Structs

ActiveStreamingWorkerNodes

IdleManager

IdleManager keeps track of latest activity and report whether the meta service has been idle for long time.

MetaOpts

Options shared by all meta service instances

MetaSrvEnv

MetaSrvEnv is the global environment in Meta service. The instance will be shared by all kind of managers inside Meta.

MetadataManager

NotificationManager

NotificationManager is used to send notification to frontends and compute nodes.

WorkerKey

Enums

LocalNotification

StreamingJob

StreamingJobType

Constants

IGNORED_NOTIFICATION_VERSION

NOTE(kwannoel): This is just ignored, used in background DDL

META_NODE_ID

The id preserved for the meta node. Note that there’s no such entry in cluster manager.

Functions

get_referred_connection_ids_from_sink

get_referred_connection_ids_from_source

get_referred_secret_ids_from_sink

get_referred_secret_ids_from_source

Type Aliases

IdleManagerRef

MessageStatus

Notification

NotificationManagerRef

NotificationVersion