-
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 |
protected void |
StorageChannelTask.Abstract.cleanUp(StorageChannel channel) |
|
protected void |
StorageRequestTaskExportEntitiesByType.Default.cleanUp(StorageChannel channel) |
|
protected void |
StorageRequestTaskStoreEntities.Default.cleanUp(StorageChannel channel) |
|
protected void |
StorageChannelSynchronizingTask.AbstractCompletingTask.complete(StorageChannel channel,
R result) |
|
protected abstract void |
StorageChannelTask.Abstract.complete(StorageChannel channel,
R value) |
|
protected void |
StorageRequestTaskLoad.Abstract.complete(StorageChannel channel,
ChunksBuffer result) |
|
void |
StorageRequestTaskStoreEntities.Default.DEBUG_Print(StorageChannel channel) |
|
static void |
StorageExceptionHandler.defaultHandleException(Throwable exception,
StorageChannel channel) |
|
protected void |
StorageChannelSynchronizingTask.AbstractCompletingTask.fail(StorageChannel channel,
R result) |
|
protected void |
StorageChannelTaskInitialize.Default.fail(StorageChannel channel,
StorageInventory[] result) |
|
protected void |
StorageChannelTaskShutdown.Default.fail(StorageChannel channel,
Void result) |
|
protected void |
StorageRequestTaskGarbageCollection.Default.fail(StorageChannel channel,
Boolean result) |
|
protected void |
StorageRequestTaskImportData.Default.fail(StorageChannel channel,
Void result) |
|
protected void |
StorageRequestTaskStoreEntities.Default.fail(StorageChannel channel,
KeyValue<ByteBuffer[],long[]> result) |
|
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) |
|
protected R |
StorageChannelSynchronizingTask.AbstractCompletingTask.internalProcessBy(StorageChannel channel) |
|
protected abstract R |
StorageChannelTask.Abstract.internalProcessBy(StorageChannel channel) |
|
protected StorageInventory[] |
StorageChannelTaskInitialize.Default.internalProcessBy(StorageChannel channel) |
|
protected Void |
StorageChannelTaskShutdown.Default.internalProcessBy(StorageChannel channel) |
|
protected Void |
StorageRequestTaskCacheCheck.Default.internalProcessBy(StorageChannel channel) |
|
protected StorageRawFileStatistics.ChannelStatistics |
StorageRequestTaskCreateStatistics.Default.internalProcessBy(StorageChannel channel) |
|
protected Void |
StorageRequestTaskExportChannels.Default.internalProcessBy(StorageChannel channel) |
|
protected StorageEntityTypeExportStatistics.ChannelStatistic |
StorageRequestTaskExportEntitiesByType.Default.internalProcessBy(StorageChannel channel) |
|
protected Void |
StorageRequestTaskFileCheck.Default.internalProcessBy(StorageChannel channel) |
|
protected Boolean |
StorageRequestTaskGarbageCollection.Default.internalProcessBy(StorageChannel channel) |
|
protected Void |
StorageRequestTaskImportData.Default.internalProcessBy(StorageChannel channel) |
|
protected ChunksBuffer |
StorageRequestTaskLoadByOids.Default.internalProcessBy(StorageChannel channel) |
|
protected ChunksBuffer |
StorageRequestTaskLoadByTids.Default.internalProcessBy(StorageChannel channel) |
|
protected ChunksBuffer |
StorageRequestTaskLoadRoots.Default.internalProcessBy(StorageChannel channel) |
|
protected KeyValue<ByteBuffer[],long[]> |
StorageRequestTaskStoreEntities.Default.internalProcessBy(StorageChannel channel) |
|
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.Default.logDisruption(StorageChannel channel,
Throwable t) |
|
default void |
StorageEventLogger.logDisruption(StorageChannel channel,
Throwable t) |
Note that not all Throwables are Exceptions.
|
protected void |
StorageChannelSynchronizingTask.AbstractCompletingTask.postCompletionSuccess(StorageChannel channel,
R result) |
|
protected void |
StorageRequestTaskImportData.Default.postCompletionSuccess(StorageChannel channel,
Void result) |
|
protected void |
StorageRequestTaskStoreEntities.Default.postCompletionSuccess(StorageChannel channel,
KeyValue<ByteBuffer[],long[]> result) |
|
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) |
Provides a newly created, yet unstarted Thread instance wrapping the passed
StorageChannel instance.
|
Thread |
StorageChannelThreadProvider.provideChannelThread(StorageChannel storageChannel,
StorageThreadNameProvider threadNameProvider) |
|
Thread |
StorageThreadProvider.Wrapper.provideChannelThread(StorageChannel storageChannel) |
|
Thread |
StorageThreadProvider.Wrapper.provideChannelThread(StorageChannel storageChannel,
StorageThreadNameProvider threadNameProvider) |
|
protected void |
StorageChannelSynchronizingTask.AbstractCompletingTask.succeed(StorageChannel channel,
R result) |
|
protected void |
StorageChannelTaskInitialize.Default.succeed(StorageChannel channel,
StorageInventory[] result) |
|
protected void |
StorageChannelTaskShutdown.Default.succeed(StorageChannel channel,
Void result) |
|
protected void |
StorageRequestTaskCreateStatistics.Default.succeed(StorageChannel channel,
StorageRawFileStatistics.ChannelStatistics result) |
|
protected void |
StorageRequestTaskExportEntitiesByType.Default.succeed(StorageChannel channel,
StorageEntityTypeExportStatistics.ChannelStatistic result) |
|
protected void |
StorageRequestTaskGarbageCollection.Default.succeed(StorageChannel channel,
Boolean completedSweep) |
|
protected void |
StorageRequestTaskImportData.Default.succeed(StorageChannel channel,
Void result) |
|
protected void |
StorageRequestTaskStoreEntities.Default.succeed(StorageChannel channel,
KeyValue<ByteBuffer[],long[]> result) |
|
static String |
StorageEventLogger.Default.toChannelIdentifier(StorageChannel channel) |
|