checkpointManager

@Singleton
fun checkpointManager(catalog: DestinationCatalog, syncManager: SyncManager, outputConsumer: suspend (Reserved<CheckpointMessage>, Long, Long, Long) -> Unit, timeProvider: TimeProvider, @Named(value = "dataChannelMedium") dataChannelMedium: DataChannelMedium, namespaceMapper: NamespaceMapper): CheckpointManager