Package io.higson.runtime.diagnostic.flush

Class DiagnosticFlushService

java.lang.Object

io.higson.runtime.diagnostic.flush.DiagnosticFlushService

public class DiagnosticFlushService
extends Object

Drains the DiagnosticQueue, classifies events by DiagnosticEventCode and routes each group to a matching DiagnosticEventPersister. Provides retry-with-backoff per group.

Constructor Summary

Constructors

Constructor	Description
DiagnosticFlushService(DiagnosticQueue queue, List<DiagnosticEventPersister<?>> persisters, DiagnosticFlushConfig config)

Method Summary

Modifier and Type	Method	Description
int	flush(BooleanSupplier shouldContinue)	Drain the queue in batches and persist all events.

Methods inherited from class java.lang.Object

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

Constructor Details

DiagnosticFlushService

public DiagnosticFlushService(DiagnosticQueue queue,
 List<DiagnosticEventPersister<?>> persisters,
 DiagnosticFlushConfig config)

Method Details

flush

public int flush(BooleanSupplier shouldContinue)

Drain the queue in batches and persist all events. The shouldContinue supplier is checked between batches to allow graceful early-exit (e.g. on watcher shutdown).

Returns:

total number of events successfully drained from the queue