bulk-cdk-core-load/io.airbyte.cdk.load.state/SyncManager

SyncManager

@Singleton
class SyncManager(val catalog: DestinationCatalog)

Constructors

Link copied to clipboard
constructor(catalog: DestinationCatalog)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
suspend fun allStreamsComplete(): Boolean

Whether we received stream complete messages for all streams in the catalog from upstream.

Link copied to clipboard
suspend fun awaitAllStreamsProcessedSuccessfully(): Boolean

Suspend until all streams are processed successfully. Returns false if processing failed for any stream.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun awaitSetupComplete()
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun getStreamManager(stream: DestinationStream.Descriptor): StreamManager

Get the manager for the given stream. Throws an exception if the stream is not found.

Link copied to clipboard
fun isActive(): Boolean
Link copied to clipboard
suspend fun markCheckpointsProcessed()
Link copied to clipboard
Link copied to clipboard
suspend fun markDestinationSucceeded()
Link copied to clipboard
suspend fun markInputConsumed()
Link copied to clipboard
suspend fun markSetupComplete()
Link copied to clipboard
fun registerStartedStreamLoader(streamDescriptor: DestinationStream.Descriptor, streamLoaderResult: Result<StreamLoader>)