Uses of Interface
io.fluxzero.common.tracking.PositionStore
Packages that use PositionStore
Package
Description
-
Uses of PositionStore in io.fluxzero.common.tracking
Classes in io.fluxzero.common.tracking that implement PositionStoreMethods in io.fluxzero.common.tracking that return PositionStoreModifier and TypeMethodDescriptionMessageLogMaintenance.getPositionStore()Returns the position store maintained by this instance.Constructors in io.fluxzero.common.tracking with parameters of type PositionStoreModifierConstructorDescriptionDefaultTrackingStrategy(MessageStore source, PositionStore positionStore) DefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler) protectedDefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler, int segments) protectedDefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler, int segments, Duration initialPositionLag) protectedDefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler, Duration initialPositionLag) DefaultTrackingStrategy(MessageStore source, PositionStore positionStore, Duration initialPositionLag) Creates a tracking strategy with a configurable look-back for consumers without a stored position.MessageLogMaintenance(MessageStore messageStore, PositionStore positionStore, TrackingStrategy trackingStrategy) Creates message log maintenance for the given shared log components. -
Uses of PositionStore in io.fluxzero.sdk.tracking.client
Constructors in io.fluxzero.sdk.tracking.client with parameters of type PositionStoreModifierConstructorDescriptionLocalTrackingClient(MessageStore messageStore, PositionStore positionStore, MessageType messageType, String topic) Creates a local tracking client from explicit storage components using the default initial look-back.LocalTrackingClient(MessageStore messageStore, PositionStore positionStore, MessageType messageType, String topic, Duration initialPositionLag) Creates a local tracking client from explicit storage components. -
Uses of PositionStore in io.fluxzero.testserver.websocket
Constructors in io.fluxzero.testserver.websocket with parameters of type PositionStoreModifierConstructorDescriptionConsumerEndpoint(TrackingStrategy trackingStrategy, MessageStore messageStore, PositionStore positionStore, MessageType messageType) ConsumerEndpoint(TrackingStrategy trackingStrategy, MessageStore messageStore, PositionStore positionStore, MessageType messageType, String topic) Creates a consumer endpoint from explicit tracking components.ConsumerEndpoint(TrackingStrategy trackingStrategy, MessageStore messageStore, PositionStore positionStore, MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint from explicit tracking components.