Module stream_manager 

Structs

AutoRefreshSchemaSinkContext

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 🔒

UpstreamSinkInfo

Constants

FOREGROUND_DDL_EARLY_FAILURE_TIMEOUT 🔒

A user is assumed to stay focused on a streaming-job creation for at most 30 seconds. If an error occurs during that time, cancel the job so that they can investigate the error. After that, prioritize eventual completion by continuing to wait through transient errors.

Functions

cleanup_dropped_sink_runtimes 🔒

Stop sink runtimes after catalog deletion, even when the drop barrier fails.

cleanup_dropped_streaming_jobs 🔒

Type Aliases

CreateStreamingJobResult

The error carries whether the caller should explicitly cancel the creating job and an optional notifier for an awaited cancellation request.

CreatingStreamingJobInfoRef 🔒

GlobalStreamManagerRef