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 void
close()
Stop the consumption.default void
disableRateLimiting()
Disable any rate limit for this handle.default boolean
isReadyForProcessing()
Verify if we can read without any (known in advance) delays defined by any possibleThroughputLimiter
.static ObserveHandle
noop()
-
-
-
Method Detail
-
noop
@Internal static ObserveHandle noop()
- Returns:
- an
ObserveHandle
which 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:
close
in interfacejava.lang.AutoCloseable
-
disableRateLimiting
default void disableRateLimiting()
Disable any rate limit for this handle.
-
-