Package cz.o2.proxima.direct.core.batch
Interface ObserveHandle
-
- All Superinterfaces:
java.lang.AutoCloseable
- All Known Subinterfaces:
OffsetTrackingBatchLogReader.OffsetTrackingObserveHandle
- All Known Implementing Classes:
TerminationContext
@Stable public interface ObserveHandle extends java.lang.AutoCloseable
A interface for handling progress and control consumption of running observe process.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description voidclose()Stop the consumption.default voiddisableRateLimiting()Disable any rate limit for this handle.default booleanisReadyForProcessing()Verify if we can read without any (known in advance) delays defined by any possibleThroughputLimiter.static ObserveHandlenoop()
-
-
-
Method Detail
-
noop
@Internal static ObserveHandle noop()
- Returns:
- an
ObserveHandlewhich does nothing.
-
isReadyForProcessing
default boolean isReadyForProcessing()
Verify if we can read without any (known in advance) delays defined by any possibleThroughputLimiter.
-
close
void close()
Stop the consumption.- Specified by:
closein interfacejava.lang.AutoCloseable
-
disableRateLimiting
default void disableRateLimiting()
Disable any rate limit for this handle.
-
-