Package org.datadog.jenkins.plugins.datadog.util

Class AsyncWriter<T>

java.lang.Object

org.datadog.jenkins.plugins.datadog.util.AsyncWriter<T>

public final class AsyncWriter<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static com.codahale.metrics.MetricRegistry	METRICS

Constructor Summary

Constructors

Constructor	Description
AsyncWriter(String name, Consumer<List<T>> queueConsumer, Runnable onStop, int queueCapacity, int submitTimeoutSeconds, int pollingTimeoutSeconds, int stopTimeoutSeconds, int batchSizeLimit)

Method Summary

Modifier and Type	Method	Description
void	start()
void	stopAsynchronously()
void	stopSynchronously()
void	submit(T element)

Methods inherited from class java.lang.Object

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

Field Detail

METRICS

public static final com.codahale.metrics.MetricRegistry METRICS

Constructor Detail

AsyncWriter

public AsyncWriter(String name,
                   Consumer<List<T>> queueConsumer,
                   Runnable onStop,
                   int queueCapacity,
                   int submitTimeoutSeconds,
                   int pollingTimeoutSeconds,
                   int stopTimeoutSeconds,
                   int batchSizeLimit)

Method Detail

start

public void start()

stopAsynchronously

public void stopAsynchronously()

stopSynchronously

public void stopSynchronously()
                       throws InterruptedException

Throws:

InterruptedException

submit

public void submit(@Nullable
                   T element)
            throws InterruptedException,
                   TimeoutException

Throws:

InterruptedException

TimeoutException