Module stream_manager

Structs

• CreateStreamingJobContext
  CreateStreamingJobContext carries one-time infos for creating a streaming job.
• CreateStreamingJobOption
• CreatingStreamingJobInfo 🔒
• GlobalStreamManager
  GlobalStreamManager manages all the streams in the system.
• ReplaceStreamJobContext
  ReplaceStreamJobContext carries one-time infos for replacing the plan of an existing stream job.
• StreamingJobExecution 🔒

Enums

• CreatingState

Type Aliases

• CreatingStreamingJobInfoRef 🔒
• GlobalStreamManagerRef