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(MessageType messageType, String topic) Subclasses must implement this method to return aTrackingClientfor the given message type and topic.protected TrackingClientLocalClient.createTrackingClient(MessageType messageType, String topic) protected TrackingClientWebSocketClient.createTrackingClient(MessageType messageType, String topic) AbstractClient.getTrackingClient(MessageType messageType, String topic) default TrackingClientClient.getTrackingClient(MessageType messageType) Returns aTrackingClientfor the given message type using the default topic.Client.getTrackingClient(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.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 RegistrationDefaultTracker.start(Consumer<List<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.