com.facebook.buck.util.network

Class AbstractBatchingLogger

java.lang.Object

com.facebook.buck.util.network.AbstractBatchingLogger

All Implemented Interfaces:

BatchingLogger

Direct Known Subclasses:

ScribeBatchingLogger

public abstract class AbstractBatchingLogger
extends Object
implements BatchingLogger

Common functionality for uploading log entries in batches.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractBatchingLogger.BatchEntry

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MIN_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
AbstractBatchingLogger()
AbstractBatchingLogger(int minBatchSize)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Unit>	forceFlush() Signals to upload whatever remaining information is buffered.
Optional<com.google.common.util.concurrent.ListenableFuture<Unit>>	log(String logLine)
protected abstract com.google.common.util.concurrent.ListenableFuture<Unit>	logMultiple(com.google.common.collect.ImmutableCollection<AbstractBatchingLogger.BatchEntry> data)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MIN_BATCH_SIZE

public static final int DEFAULT_MIN_BATCH_SIZE

See Also:

Constant Field Values

Constructor Detail

AbstractBatchingLogger

public AbstractBatchingLogger(int minBatchSize)

AbstractBatchingLogger

public AbstractBatchingLogger()

Method Detail

log

public Optional<com.google.common.util.concurrent.ListenableFuture<Unit>> log(String logLine)

Specified by:

log in interface BatchingLogger

Parameters:

logLine - data to upload.

Returns:

Optional.empty() if the data has merely been buffered, a ListenableFuture representing the upload otherwise.

forceFlush

public com.google.common.util.concurrent.ListenableFuture<Unit> forceFlush()

Description copied from interface: BatchingLogger

Signals to upload whatever remaining information is buffered.

Specified by:

forceFlush in interface BatchingLogger

Returns:

future representing the forced upload.

logMultiple

protected abstract com.google.common.util.concurrent.ListenableFuture<Unit> logMultiple(com.google.common.collect.ImmutableCollection<AbstractBatchingLogger.BatchEntry> data)