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

objectLoaderLoadedPartQueue

@Singleton

@Named(value = "objectLoaderLoadedPartQueue")

@Requires(bean = ObjectLoader::class)

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

Queue between part 2 (upload parts) and part 3 (finish the upload). 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.