Uses of Interface
io.fluxzero.sdk.tracking.client.TrackingClient
Packages that use TrackingClient
Package
Description
-
Uses of TrackingClient in io.fluxzero.sdk.configuration.client
Methods in io.fluxzero.sdk.configuration.client that return TrackingClientModifier and TypeMethodDescriptionprotected abstract TrackingClientAbstractClient.createTrackingClient(io.fluxzero.common.MessageType messageType, String topic) Subclasses must implement this method to return aTrackingClientfor the given message type and topic.protected TrackingClientLocalClient.createTrackingClient(io.fluxzero.common.MessageType messageType, String topic) protected TrackingClientWebSocketClient.createTrackingClient(io.fluxzero.common.MessageType messageType, String topic) AbstractClient.getTrackingClient(io.fluxzero.common.MessageType messageType, String topic) default TrackingClientClient.getTrackingClient(io.fluxzero.common.MessageType messageType) Returns aTrackingClientfor the given message type using the default topic.Client.getTrackingClient(io.fluxzero.common.MessageType messageType, String topic) Returns aTrackingClientfor the given message type and topic. -
Uses of TrackingClient in io.fluxzero.sdk.persisting.eventsourcing.client
Classes in io.fluxzero.sdk.persisting.eventsourcing.client that implement TrackingClientModifier and TypeClassDescriptionclassA client implementation for managing and storing events in an in-memory event store. -
Uses of TrackingClient in io.fluxzero.sdk.scheduling.client
Classes in io.fluxzero.sdk.scheduling.client that implement TrackingClientModifier and TypeClassDescriptionclassA client implementation for managing scheduling operations using an in-memory schedule store. -
Uses of TrackingClient in io.fluxzero.sdk.tracking
Methods in io.fluxzero.sdk.tracking with parameters of type TrackingClientModifier and TypeMethodDescriptionprotected List<DeserializingMessage> DefaultTracking.deserializeMessageList(List<io.fluxzero.common.api.SerializedMessage> serializedMessages, String topic, TrackingClient trackingClient, Map<String, ChunkedDeserializingMessage> activeChunkedMessages, int recoveryMaxFetchSize) -
Uses of TrackingClient in io.fluxzero.sdk.tracking.client
Classes in io.fluxzero.sdk.tracking.client that implement TrackingClientModifier and TypeClassDescriptionclassATrackingClientimplementation that wraps another client (typically aWebsocketTrackingClient) and caches recent messages in memory to reduce redundant round trips to the Fluxzero Runtime.classIn-memory implementation of theTrackingClientandGatewayClientinterfaces, designed for local-only or test-time usage.classWebSocket-based implementation of theTrackingClientthat connects to the Fluxzero Runtime.Methods in io.fluxzero.sdk.tracking.client with parameters of type TrackingClientModifier and TypeMethodDescriptionstatic io.fluxzero.common.RegistrationDefaultTracker.start(Consumer<List<io.fluxzero.common.api.SerializedMessage>> consumer, ConsumerConfiguration config, TrackingClient trackingClient) Starts one or more trackers that consume messages using the provided trackingClient and process them using the provided consumer.Constructors in io.fluxzero.sdk.tracking.client with parameters of type TrackingClient