-
Methods in one.microstream.storage.types that return StorageChannel
Modifier and Type |
Method |
Description |
StorageChannel[] |
StorageChannelsCreator.createChannels(int channelCount,
StorageInitialDataFileNumberProvider initialDataFileNumberProvider,
StorageExceptionHandler exceptionHandler,
StorageDataFileEvaluator fileDissolver,
StorageLiveFileProvider liveFileProvider,
StorageEntityCacheEvaluator entityCacheEvaluator,
StorageTypeDictionary typeDictionary,
StorageTaskBroker taskBroker,
StorageOperationController operationController,
StorageHousekeepingBroker housekeepingBroker,
StorageHousekeepingController housekeepingController,
StorageTimestampProvider timestampProvider,
StorageWriteController writeController,
StorageFileWriter.Provider writerProvider,
StorageGCZombieOidHandler zombieOidHandler,
StorageRootOidSelector.Provider rootOidSelectorProvider,
StorageObjectIdMarkQueue.Creator oidMarkQueueCreator,
StorageEntityMarkMonitor.Creator entityMarkMonitorCreator,
StorageBackupHandler backupHandler,
StorageEventLogger eventLogger,
boolean switchByteOrder,
long rootTypeId) |
|
Methods in one.microstream.storage.types with parameters of type StorageChannel
Modifier and Type |
Method |
Description |
void |
StorageRequestTaskStoreEntities.Default.DEBUG_Print(StorageChannel channel) |
|
static void |
StorageExceptionHandler.defaultHandleException(Throwable exception,
StorageChannel channel) |
|
void |
StorageExceptionHandler.Default.handleException(Throwable exception,
StorageChannel channel) |
|
void |
StorageExceptionHandler.handleException(Throwable exception,
StorageChannel channel) |
|
boolean |
StorageEntityCache.Default.incrementalGarbageCollection(long nanoTimeBudgetBound,
StorageChannel channel) |
Returns true if there are no more oids to mark and false if time ran out.
|
boolean |
StorageEntityCache.incrementalGarbageCollection(long nanoTimeBudgetBound,
StorageChannel channel) |
|
StorageIdAnalysis |
StorageFileManager.Default.initializeStorage(long taskTimestamp,
long consistentStoreTimestamp,
StorageInventory storageInventory,
StorageChannel parent) |
|
StorageIdAnalysis |
StorageFileManager.initializeStorage(long taskTimestamp,
long consistentStoreTimestamp,
StorageInventory storageInventory,
StorageChannel parent) |
|
boolean |
StorageEntityCache.Default.issuedGarbageCollection(long nanoTimeBudgetBound,
StorageChannel channel) |
Returns true if there are no more oids to mark and false if time ran out.
|
boolean |
StorageEntityCache.issuedGarbageCollection(long nanoTimeBudgetBound,
StorageChannel channel) |
|
void |
StorageEventLogger.Debug.logChannelProcessingDisabled(StorageChannel channel) |
|
default void |
StorageEventLogger.logChannelProcessingDisabled(StorageChannel channel) |
|
void |
StorageEventLogger.Debug.logChannelStoppedWorking(StorageChannel channel) |
|
default void |
StorageEventLogger.logChannelStoppedWorking(StorageChannel channel) |
|
void |
StorageEventLogger.Debug.logDisruption(StorageChannel channel,
Throwable t) |
|
default void |
StorageEventLogger.logDisruption(StorageChannel channel,
Throwable t) |
Note that not all Throwables are Exceptions.
|
Throwable |
StorageChannelTask.Abstract.problemForChannel(StorageChannel channel) |
|
Throwable |
StorageTask.DummyTask.problemForChannel(StorageChannel channel) |
|
Throwable |
StorageTask.problemForChannel(StorageChannel channel) |
|
void |
StorageChannelTask.Abstract.processBy(StorageChannel storageChannel) |
|
void |
StorageTask.DummyTask.processBy(StorageChannel storageChannel) |
|
void |
StorageTask.processBy(StorageChannel storageChannel) |
|
Thread |
StorageChannelThreadProvider.Default.provideChannelThread(StorageChannel storageChannel,
StorageThreadNameProvider threadNameProvider) |
|
default Thread |
StorageChannelThreadProvider.provideChannelThread(StorageChannel storageChannel) |
|
Thread |
StorageChannelThreadProvider.provideChannelThread(StorageChannel storageChannel,
StorageThreadNameProvider threadNameProvider) |
|
Thread |
StorageThreadProvider.Wrapper.provideChannelThread(StorageChannel storageChannel) |
|
Thread |
StorageThreadProvider.Wrapper.provideChannelThread(StorageChannel storageChannel,
StorageThreadNameProvider threadNameProvider) |
|
static String |
StorageEventLogger.Debug.toChannelIdentifier(StorageChannel channel) |
|