Package io.deephaven.io.log.impl

Class LogSinkImpl<T extends LogSink.Element>

java.lang.Object

io.deephaven.io.log.impl.LogSinkImpl<T>

All Implemented Interfaces:

LogSink<T>

public class LogSinkImpl<T extends LogSink.Element>
extends Object
implements LogSink<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LogSinkImpl.BigWriterThread

Nested classes/interfaces inherited from interface io.deephaven.io.log.LogSink

LogSink.Element, LogSink.Factory<T extends LogSink.Element>, LogSink.Interceptor<T extends LogSink.Element>, LogSink.LogSinkWriter<S extends LogSink<? extends LogSink.Element>>, LogSink.Null, LogSink.Shutdown

Field Summary

Fields

Modifier and Type	Field	Description
static final DateFormat	DATE_FORMAT
static final LogSinkImpl.BigWriterThread	globalWriterThread
static final int	ROLL_INTERVAL

Fields inherited from interface io.deephaven.io.log.LogSink

NULL

Constructor Summary

Constructors

Constructor	Description
LogSinkImpl(String basePath, long rollIntervalMillis, Pool<T> elementPool)	Constructor
LogSinkImpl(String basePath, long rollIntervalMillis, Pool<T> elementPool, boolean append)	Constructor
LogSinkImpl(String basePath, long rollIntervalMillis, Pool<T> elementPool, boolean append, LogOutput outputBuffer)	Constructor
LogSinkImpl(String basePath, long rollIntervalMillis, Pool<T> elementPool, LogOutput outputBuffer)	Constructor
LogSinkImpl(String basePath, long rollIntervalMillis, DateFormat rollFormat, Pool<T> elementPool, boolean append)	Constructor
LogSinkImpl(String basePath, long rollIntervalMillis, DateFormat rollFormat, Pool<T> elementPool, boolean append, LogOutput outputBuffer, String header)	Constructor
LogSinkImpl(String basePath, long rollIntervalMillis, DateFormat rollFormat, Pool<T> elementPool, boolean append, LogOutput outputBuffer, String header, LogSink.LogSinkWriter<LogSinkImpl<T>> maybeWriter)	Constructor

Method Summary

Modifier and Type	Method	Description
void	addInterceptor(LogSink.Interceptor<T> interceptor)	Add an interceptor
static <T extends LogSink.Element> LogSink.Factory<T>	FACTORY()
void	shutdown()	Shutdown the sink - does not return until all entries have been written.
void	terminate()	Terminate the sink - does not guarantee entries will ever be written, but will not block shutdown() calls.
String	toString()	Return a string representation
void	write(T e)	add a buffer to the output queue

Methods inherited from class java.lang.Object

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

Field Details

ROLL_INTERVAL

public static final int ROLL_INTERVAL

See Also:

• Constant Field Values

DATE_FORMAT

public static final DateFormat DATE_FORMAT

globalWriterThread

public static final LogSinkImpl.BigWriterThread globalWriterThread

Constructor Details

LogSinkImpl

public LogSinkImpl(String basePath,
 long rollIntervalMillis,
 Pool<T> elementPool)

Constructor

LogSinkImpl

public LogSinkImpl(String basePath,
 long rollIntervalMillis,
 Pool<T> elementPool,
 LogOutput outputBuffer)

Constructor

LogSinkImpl

public LogSinkImpl(String basePath,
 long rollIntervalMillis,
 Pool<T> elementPool,
 boolean append)

Constructor

LogSinkImpl

public LogSinkImpl(String basePath,
 long rollIntervalMillis,
 Pool<T> elementPool,
 boolean append,
 LogOutput outputBuffer)

Constructor

LogSinkImpl

public LogSinkImpl(String basePath,
 long rollIntervalMillis,
 DateFormat rollFormat,
 Pool<T> elementPool,
 boolean append)

Constructor

LogSinkImpl

public LogSinkImpl(String basePath,
 long rollIntervalMillis,
 DateFormat rollFormat,
 Pool<T> elementPool,
 boolean append,
 LogOutput outputBuffer,
 String header)

Constructor

LogSinkImpl

public LogSinkImpl(String basePath,
 long rollIntervalMillis,
 DateFormat rollFormat,
 Pool<T> elementPool,
 boolean append,
 LogOutput outputBuffer,
 String header,
 LogSink.LogSinkWriter<LogSinkImpl<T>> maybeWriter)

Constructor

Method Details

FACTORY

public static <T extends LogSink.Element>
LogSink.Factory<T> FACTORY()

toString

public String toString()

Return a string representation

Overrides:

toString in class Object

write

public void write(T e)

add a buffer to the output queue

Specified by:

write in interface LogSink<T extends LogSink.Element>

shutdown

public void shutdown()

Shutdown the sink - does not return until all entries have been written.

Specified by:

shutdown in interface LogSink<T extends LogSink.Element>

terminate

public void terminate()

Terminate the sink - does not guarantee entries will ever be written, but will not block shutdown() calls.

Specified by:

terminate in interface LogSink<T extends LogSink.Element>

addInterceptor

public void addInterceptor(LogSink.Interceptor<T> interceptor)

Add an interceptor

Specified by:

addInterceptor in interface LogSink<T extends LogSink.Element>