bulk-cdk-core-extract/io.airbyte.cdk.read/StreamStatusManager

StreamStatusManager

class StreamStatusManager(feeds: List<Feed>, emit: (AirbyteStreamStatusTraceMessage) -> Unit)(source)

StreamStatusManager emits AirbyteStreamStatusTraceMessages in response to Feed activity events, via notifyStarting, notifyComplete and notifyFailure.

Constructors

StreamStatusManager

constructor(feeds: List<Feed>, emit: (AirbyteStreamStatusTraceMessage) -> Unit)

Types

enum State : Enum<StreamStatusManager.State>

data class StreamState(val id: StreamIdentifier, val feeds: Set<Feed>, val state: AtomicReference<StreamStatusManager.State> = AtomicReference(State.PENDING), val stoppedFeeds: ConcurrentHashSet<Feed> = ConcurrentHashSet(), val numStoppedFeeds: AtomicInteger = AtomicInteger())

Functions

fun notifyComplete(feed: Feed)

Notify that the feed has completed running.

fun notifyFailure(feed: Feed)

Notify that the feed has stopped running due to a failure.

fun notifyStarting(feed: Feed)

Notify that the feed is about to start running.