Class TrackerMonitor

java.lang.Object

io.fluxzero.sdk.tracking.metrics.TrackerMonitor

All Implemented Interfaces:

BatchInterceptor

public class TrackerMonitor
extends Object
implements BatchInterceptor

Nested Class Summary

Nested classes/interfaces inherited from interface BatchInterceptor

BatchInterceptor.FilterPreserving

Field Summary

Fields inherited from interface BatchInterceptor

defaultInterceptors

Constructor Summary

Constructors

Constructor	Description
TrackerMonitor()

Method Summary

Modifier and Type	Method	Description
ConsumerFilter	describeConsumerFilter(ConsumerFilter downstream)	Describes serialized inputs needed by this interceptor and its downstream consumer.
Consumer<MessageBatch>	intercept(Consumer<MessageBatch> consumer, Tracker tracker)	Intercepts the given batch message consumer and returns a decorated version to be invoked by the tracker.

Methods inherited from class Object

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

Methods inherited from interface BatchInterceptor

andThen, shutdown

Constructor Details

TrackerMonitor

public TrackerMonitor()

Method Details

intercept

public Consumer<MessageBatch> intercept(Consumer<MessageBatch> consumer,
 Tracker tracker)

Description copied from interface: BatchInterceptor

Intercepts the given batch message consumer and returns a decorated version to be invoked by the tracker.

Specified by:

intercept in interface BatchInterceptor

Parameters:

consumer - the original consumer that processes the MessageBatch

tracker - the tracker invoking this interceptor

Returns:

a wrapped consumer with additional behavior

describeConsumerFilter

public ConsumerFilter describeConsumerFilter(ConsumerFilter downstream)

Description copied from interface: BatchInterceptor

Describes serialized inputs needed by this interceptor and its downstream consumer. The default is unrestricted because interceptors can transform messages or require inputs that no handler accepts. Implementations may return downstream only when excluded inputs are irrelevant to their behavior and they never transform an excluded input into one the downstream filter admits. Custom inverse projections describe the input side of a transformation; this method runs after serializer/upcaster projection.

Specified by:

describeConsumerFilter in interface BatchInterceptor