Uses of Interface
io.fluxzero.sdk.tracking.BatchInterceptor

Packages that use BatchInterceptor

Package	Description
io.fluxzero.sdk.configuration
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.metrics

Uses of BatchInterceptor in io.fluxzero.sdk.configuration

Methods in io.fluxzero.sdk.configuration that return types with arguments of type BatchInterceptor

Modifier and Type	Method	Description
Map<io.fluxzero.common.MessageType, List<BatchInterceptor>>	FluxzeroConfiguration.batchInterceptors()	Ordered batch interceptors grouped per message type.

Methods in io.fluxzero.sdk.configuration with parameters of type BatchInterceptor

Modifier and Type	Method	Description
FluxzeroBuilder	DefaultFluxzero.Builder.addBatchInterceptor(BatchInterceptor interceptor, io.fluxzero.common.MessageType... forTypes)
FluxzeroBuilder	FluxzeroBuilder.addBatchInterceptor(BatchInterceptor interceptor, io.fluxzero.common.MessageType... forTypes)	Registers a BatchInterceptor that applies to the given message types.

Uses of BatchInterceptor in io.fluxzero.sdk.tracking

Subinterfaces of BatchInterceptor in io.fluxzero.sdk.tracking

Modifier and Type	Interface	Description
interface	MappingBatchInterceptor	A BatchInterceptor specialization that transforms a MessageBatch before it is passed to the consumer for processing.

Classes in io.fluxzero.sdk.tracking that implement BatchInterceptor

Modifier and Type	Class	Description
static final record	BatchInterceptor.FilterPreserving	Explicit selection-preserving wrapper; use BatchInterceptor.preservingConsumerFilter(BatchInterceptor).
class	FluxzeroInterceptor	A BatchInterceptor that ensures the correct Fluxzero instance is bound to the current thread for the duration of a MessageBatch.
class	StallingBatchInterceptor	A BatchInterceptor that stalls batch processing until a minimum desired batch size is reached or a timeout occurs.

Fields in io.fluxzero.sdk.tracking with type parameters of type BatchInterceptor

Modifier and Type	Field	Description
static final List<BatchInterceptor>	BatchInterceptor.defaultInterceptors	Default batch interceptors discovered via Java's service loader, sorted by Order.

Methods in io.fluxzero.sdk.tracking that return BatchInterceptor

Modifier and Type	Method	Description
default BatchInterceptor	BatchInterceptor.andThen(BatchInterceptor nextInterceptor)	Composes this interceptor with another, returning a new interceptor that applies both in sequence.
BatchInterceptor	BatchInterceptor.FilterPreserving.delegate()	Returns the value of the delegate record component.
static BatchInterceptor	BatchInterceptor.join(List<BatchInterceptor> interceptors)	Joins a list of interceptors into a single composite interceptor, applying them in sequence.
static BatchInterceptor	BatchInterceptor.noOp()	Returns a no-op interceptor that does not alter the consumer behavior.
static BatchInterceptor	BatchInterceptor.preservingConsumerFilter(BatchInterceptor interceptor)	Marks an interceptor as preserving downstream selection.

Methods in io.fluxzero.sdk.tracking that return types with arguments of type BatchInterceptor

Modifier and Type	Method	Description
static List<BatchInterceptor>	BatchInterceptor.effectiveInterceptors(ConsumerConfiguration configuration, io.fluxzero.common.MessageType type, Fluxzero fluxzero)	Ordered application and consumer interceptors, shared by execution and input selection.

Methods in io.fluxzero.sdk.tracking with parameters of type BatchInterceptor

Modifier and Type	Method	Description
default BatchInterceptor	BatchInterceptor.andThen(BatchInterceptor nextInterceptor)	Composes this interceptor with another, returning a new interceptor that applies both in sequence.
static BatchInterceptor	BatchInterceptor.preservingConsumerFilter(BatchInterceptor interceptor)	Marks an interceptor as preserving downstream selection.

Method parameters in io.fluxzero.sdk.tracking with type arguments of type BatchInterceptor

Modifier and Type	Method	Description
static BatchInterceptor	BatchInterceptor.join(List<BatchInterceptor> interceptors)	Joins a list of interceptors into a single composite interceptor, applying them in sequence.

Constructors in io.fluxzero.sdk.tracking with parameters of type BatchInterceptor

Modifier	Constructor	Description
	FilterPreserving(BatchInterceptor delegate)	Creates an instance of a FilterPreserving record class.

Uses of BatchInterceptor in io.fluxzero.sdk.tracking.metrics

Classes in io.fluxzero.sdk.tracking.metrics that implement BatchInterceptor

Modifier and Type	Class	Description
class	DisableMetrics	Interceptor that disables the dispatch of outbound MessageType.METRICS messages.
class	TrackerMonitor