ome.smuggler.core.service.imports.impl

Class ImportEnv

java.lang.Object

ome.smuggler.core.service.imports.impl.ImportEnv

public class ImportEnv
extends java.lang.Object

Provides access to import configuration and queues.

Constructor Summary

Constructors

Constructor and Description
ImportEnv(ImportConfigSource config, SessionService session, ImportService importer, ChannelSource<QueuedImport> queue, SchedulingSource<ProcessedImport> gcQueue, KeyValueStore<ImportBatchId,ImportBatchStatus> batchStore, TaskFileStore<ImportId> failedImportLogStore, MailRequestor mail, java.util.Optional<Email> sysAdminEmail, LogService logService)

Method Summary

Modifier and Type	Method and Description
BatchManager	batchManager()
KeyValueStore<ImportBatchId,ImportBatchStatus>	batchStore()
ImportConfigSource	config()
void	ensureDirectories()
TaskFileStore<ImportId>	failedImportLogStore()
Finaliser	finaliser()
SchedulingSource<ProcessedImport>	gcQueue()
ImportService	importer()
ImportLogPath	importLogPathFor(ImportId taskId)
FutureTimepoint	importLogRetentionFromNow()
ImportLogger	log()
MailRequestor	mail()
ChannelSource<QueuedImport>	queue()
SessionService	session()
java.util.Optional<Email>	sysAdminEmail()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ImportEnv

public ImportEnv(ImportConfigSource config,
                 SessionService session,
                 ImportService importer,
                 ChannelSource<QueuedImport> queue,
                 SchedulingSource<ProcessedImport> gcQueue,
                 KeyValueStore<ImportBatchId,ImportBatchStatus> batchStore,
                 TaskFileStore<ImportId> failedImportLogStore,
                 MailRequestor mail,
                 java.util.Optional<Email> sysAdminEmail,
                 LogService logService)

Method Detail

config

public ImportConfigSource config()

session

public SessionService session()

importer

public ImportService importer()

queue

public ChannelSource<QueuedImport> queue()

gcQueue

public SchedulingSource<ProcessedImport> gcQueue()

finaliser

public Finaliser finaliser()

batchStore

public KeyValueStore<ImportBatchId,ImportBatchStatus> batchStore()

batchManager

public BatchManager batchManager()

failedImportLogStore

public TaskFileStore<ImportId> failedImportLogStore()

mail

public MailRequestor mail()

sysAdminEmail

public java.util.Optional<Email> sysAdminEmail()

log

public ImportLogger log()

importLogPathFor

public ImportLogPath importLogPathFor(ImportId taskId)

importLogRetentionFromNow

public FutureTimepoint importLogRetentionFromNow()

ensureDirectories

public void ensureDirectories()