Package cz.o2.proxima.direct.core.commitlog

Interface Summary

Interface	Description
CommitLogObserver	Base interface for bulk and online observers.
CommitLogObserver.OffsetCommitter	Committer for manipulation with offset during consumption.
CommitLogObserver.OnIdleContext	Context passed to CommitLogObserver.onIdle(cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnIdleContext).
CommitLogObserver.OnNextContext	Context passed to LogObserver.onNext(cz.o2.proxima.core.storage.StreamElement, ContextT).
CommitLogObserver.OnRepartitionContext	Context passed to CommitLogObserver.onRepartition(cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnRepartitionContext).
CommitLogReader	Read access to commit log.
CommitLogReader.Factory<T extends CommitLogReader>	Serializable factory for CommitLogReader.
ObserveHandle	A interface for handling progress and control consumption of running observe process.
Offset	Interface for implementations and their offset.
OffsetExternalizer	Interface provides methods for serializing commit log offset Offset to external formats.

Class Summary

Class	Description
CommitLogObservers
CommitLogObservers.ForwardingObserver	A @{link LogObserver} that delegates calls to underlying delegate.
CommitLogReaders	Utility class that constructs various versions of CommitLogReaders.
CommitLogReaders.LimitedCommitLogReader
ObserveHandleUtils
ObserverUtils	Various utilities for working with CommitLogObserver.

Enum Summary

Enum	Description
CommitLogObservers.TerminationStrategy	A strategy to use when maximal error count is reached.