bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.factory.object_storage/ObjectLoaderQueueBeanFactory/fileLoadedPartQueue

fileLoadedPartQueue

@Singleton

@Named(value = "fileLoadedPartQueue")

@Requires(condition = IsFileTransferCondition::class)

fun <T : RemoteObject<*>> fileLoadedPartQueue(): PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>

Queue between upload file parts and the upload completer. It will hold the fact of upload completion only, so in theory it can be Channel.UNLIMITED, but to be safe we'll limit it to 10,000 queued completions.