Package titan.network

Class LogBatcher

java.lang.Object

titan.network.LogBatcher

public class LogBatcher
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	BATCH_SIZE
private final List<String>	buffer
private static final int	FLUSH_INTERVAL_MS
private final String	host
private final String	jobId
private final Object	lock
private final int	port
private final ScheduledExecutorService	scheduler

Constructor Summary

Constructors

Constructor	Description
LogBatcher(String jobId, String host, int port)

Method Summary

Modifier and Type	Method	Description
void	addLog(String line)
void	close()
void	flush()

Methods inherited from class java.lang.Object

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

Field Details

jobId

private final String jobId

host

private final String host

port

private final int port

buffer

private final List<String> buffer

lock

private final Object lock

BATCH_SIZE

private static final int BATCH_SIZE

See Also:

• Constant Field Values

FLUSH_INTERVAL_MS

private static final int FLUSH_INTERVAL_MS

See Also:

• Constant Field Values

scheduler

private final ScheduledExecutorService scheduler

Constructor Details

LogBatcher

public LogBatcher(String jobId,
 String host,
 int port)

Method Details

addLog

public void addLog(String line)

flush

public void flush()

close

public void close()