Package io.higson.runtime.diagnostic.queue

Class DiagnosticQueueConfig

java.lang.Object

io.higson.runtime.diagnostic.queue.DiagnosticQueueConfig

public class DiagnosticQueueConfig
extends Object

Configuration for DiagnosticQueue.

Fluent builder-style setters allow chaining, e.g.:

   new DiagnosticQueueConfig()
       .capacity(5000)
       .overflowStrategy(OverflowStrategy.DROP_NEWEST)
       .batchSize(50);
 

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BATCH_SIZE
static final int	DEFAULT_CAPACITY	With metrics collected every 20s and the default 5-minute flush interval the queue accumulates ~15 events between flushes. 10000 leaves ample headroom for transient flush failures (~3.3 days of metrics) before OverflowStrategy.DROP_OLDEST starts dropping.
static final OverflowStrategy	DEFAULT_OVERFLOW_STRATEGY

Constructor Summary

Constructors

Constructor	Description
DiagnosticQueueConfig()

Method Summary

Modifier and Type	Method	Description
DiagnosticQueueConfig	batchSize(int batchSize)
DiagnosticQueueConfig	capacity(int capacity)
int	getBatchSize()
int	getCapacity()
OverflowStrategy	getOverflowStrategy()
DiagnosticQueueConfig	overflowStrategy(OverflowStrategy overflowStrategy)
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

DEFAULT_CAPACITY

public static final int DEFAULT_CAPACITY

With metrics collected every 20s and the default 5-minute flush interval the queue accumulates ~15 events between flushes. 10000 leaves ample headroom for transient flush failures (~3.3 days of metrics) before OverflowStrategy.DROP_OLDEST starts dropping.

See Also:

• Constant Field Values

DEFAULT_OVERFLOW_STRATEGY

public static final OverflowStrategy DEFAULT_OVERFLOW_STRATEGY

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

• Constant Field Values

Constructor Details

DiagnosticQueueConfig

public DiagnosticQueueConfig()

Method Details

capacity

public DiagnosticQueueConfig capacity(int capacity)

overflowStrategy

public DiagnosticQueueConfig overflowStrategy(OverflowStrategy overflowStrategy)

batchSize

public DiagnosticQueueConfig batchSize(int batchSize)

getCapacity

public int getCapacity()

getOverflowStrategy

public OverflowStrategy getOverflowStrategy()

getBatchSize

public int getBatchSize()

toString

public String toString()

Overrides:

toString in class Object