Package com.illumon.iris.binarystore

Class RollingFileManager

java.lang.Object

io.deephaven.enterprise.binlog.channels.RollingFileManagerBase<ExpirationType,ExtraType>

com.illumon.iris.binarystore.RollingFileManagerBase<String,Void>

com.illumon.iris.binarystore.RollingFileManager

All Implemented Interfaces:

io.deephaven.enterprise.binlog.channels.ChannelManager, io.deephaven.enterprise.binlog.channels.ChannelManagerStandard

public class RollingFileManager
extends RollingFileManagerBase<String,Void>

This class maintains the file channels, with the appropriate roll interval for BinaryStoreWriters. Each call to getChannel() evaluates the current time, and might re-initialize the channel. This class adds a time suffix to the configured location and file prefix. For example, "/db/TempFiles/irisadmin/logs", "DbInternal.UpdatePerformanceLog.localhost.bin.2018-04-16." to specify the log directory and file prefix or "/db/TempFiles/irisadmin/logs/DbInternal.UpdatePerformanceLog.localhost.bin.2018-04-16." to specify the directory and prefix together.

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.binarystore.RollingFileManagerBase

RollingFileManagerBase.ExistingFilePolicy

Field Summary

Fields inherited from class com.illumon.iris.binarystore.RollingFileManagerBase

FORCE_BEFORE_CLOSE, log

Fields inherited from class io.deephaven.enterprise.binlog.channels.RollingFileManagerBase

baseDir, expiration, headerBuffer, writeChannel

Constructor Summary

Constructors

Constructor	Description
RollingFileManager(com.fishlib.io.logger.Logger log, String baseDirName, String filenamePrefix, ByteBuffer headerBuffer, RollingFileManagerBase.ExistingFilePolicy existingFilePolicy, io.deephaven.enterprise.binlog.channels.ExpirationManager<String> expirationManager)
RollingFileManager(com.fishlib.io.logger.Logger log, String baseDirName, String filenamePrefix, ByteBuffer headerBuffer, DateFormat rollFormat, RollingFileManagerBase.ExistingFilePolicy existingFilePolicy)	Create a ChannelManager that will change files on the hour.
RollingFileManager(String basePath, ByteBuffer headerBuffer, DateFormat rollFormat, RollingFileManagerBase.ExistingFilePolicy existingFilePolicy, com.fishlib.io.logger.Logger log)	Deprecated. Use RollingFileManager(Logger, String, String, ByteBuffer, DateFormat, ExistingFilePolicy)

Method Summary

Modifier and Type	Method	Description
GatheringByteChannel	getChannel()
protected String	makeFilename(String value, Void ignored)

Methods inherited from class io.deephaven.enterprise.binlog.channels.RollingFileManagerBase

close, flush, getChannelNow, initChannel, isChannelValid, reopenChannel, writeHeader

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.enterprise.binlog.channels.ChannelManager

close, flush

Constructor Details

RollingFileManager

public RollingFileManager(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 String baseDirName,
 @NotNull
 String filenamePrefix,
 @NotNull
 ByteBuffer headerBuffer,
 @Nullable
 DateFormat rollFormat,
 @NotNull
 RollingFileManagerBase.ExistingFilePolicy existingFilePolicy)

Create a ChannelManager that will change files on the hour.

Parameters:

log - the Logger

baseDirName - log files will be placed in this directory

filenamePrefix - log files will begin with this prefix and end with the time according to rollFormat

headerBuffer - this buffer will be written to all new files

rollFormat - the current time will be formatted according to this formatter

existingFilePolicy - determines how existing files will be treated

RollingFileManager

public RollingFileManager(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 String baseDirName,
 @NotNull
 String filenamePrefix,
 @NotNull
 ByteBuffer headerBuffer,
 @NotNull
 RollingFileManagerBase.ExistingFilePolicy existingFilePolicy,
 @NotNull
 io.deephaven.enterprise.binlog.channels.ExpirationManager<String> expirationManager)

RollingFileManager

@Deprecated
public RollingFileManager(String basePath,
 ByteBuffer headerBuffer,
 DateFormat rollFormat,
 RollingFileManagerBase.ExistingFilePolicy existingFilePolicy,
 com.fishlib.io.logger.Logger log)

Deprecated.

Use RollingFileManager(Logger, String, String, ByteBuffer, DateFormat, ExistingFilePolicy)

Translating constructor for backward compatibility.

Method Details

makeFilename

protected String makeFilename(String value,
 Void ignored)

Specified by:

makeFilename in class io.deephaven.enterprise.binlog.channels.RollingFileManagerBase<String,Void>

getChannel

public GatheringByteChannel getChannel()
                                throws IOException

Throws:

IOException