Uses of Interface
io.fluxcapacitor.common.Monitored

Packages that use Monitored

Package	Description
io.fluxcapacitor.common
io.fluxcapacitor.common.tracking
io.fluxcapacitor.javaclient.persisting.eventsourcing.client
io.fluxcapacitor.javaclient.persisting.search.client
io.fluxcapacitor.javaclient.publishing.client
io.fluxcapacitor.javaclient.scheduling.client
io.fluxcapacitor.javaclient.tracking.client
io.fluxcapacitor.testserver.scheduling

Uses of Monitored in io.fluxcapacitor.common

Classes in io.fluxcapacitor.common that implement Monitored

Modifier and Type	Class	Description
class	Backlog<T>	A thread-safe batching queue that asynchronously flushes its content to a consumer in configurable batch sizes.

Uses of Monitored in io.fluxcapacitor.common.tracking

Subinterfaces of Monitored in io.fluxcapacitor.common.tracking

Modifier and Type	Interface	Description
interface	MessageStore	A low-level store for serialized messages.

Uses of Monitored in io.fluxcapacitor.javaclient.persisting.eventsourcing.client

Classes in io.fluxcapacitor.javaclient.persisting.eventsourcing.client that implement Monitored

Modifier and Type	Class	Description
class	InMemoryEventStore	An implementation of the EventStoreClient interface that provides an in-memory event storage solution.
class	LocalEventStoreClient	A client implementation for managing and storing events in an in-memory event store.

Uses of Monitored in io.fluxcapacitor.javaclient.persisting.search.client

Classes in io.fluxcapacitor.javaclient.persisting.search.client that implement Monitored

Modifier and Type	Class	Description
class	CollectionMessageStore	A MessageStore implementation backed by a collection in an InMemorySearchStore.

Uses of Monitored in io.fluxcapacitor.javaclient.publishing.client

Subinterfaces of Monitored in io.fluxcapacitor.javaclient.publishing.client

Modifier and Type	Interface	Description
interface	GatewayClient	Low-level interface for sending SerializedMessages to a gateway (e.g. commands, events, queries).

Classes in io.fluxcapacitor.javaclient.publishing.client that implement Monitored

Modifier and Type	Class	Description
class	WebsocketGatewayClient	A GatewayClient implementation that sends serialized messages to the Flux Platform over a WebSocket connection.

Uses of Monitored in io.fluxcapacitor.javaclient.scheduling.client

Classes in io.fluxcapacitor.javaclient.scheduling.client that implement Monitored

Modifier and Type	Class	Description
class	InMemoryScheduleStore	An in-memory implementation of a scheduling store that allows the scheduling, retrieval, and management of scheduled messages.
class	LocalSchedulingClient	A client implementation for managing scheduling operations using an in-memory schedule store.

Uses of Monitored in io.fluxcapacitor.javaclient.tracking.client

Classes in io.fluxcapacitor.javaclient.tracking.client that implement Monitored

Modifier and Type	Class	Description
class	InMemoryMessageStore	An in-memory implementation of the MessageStore interface for storing SerializedMessages without external persistence.
class	LocalTrackingClient	In-memory implementation of the TrackingClient and GatewayClient interfaces, designed for local-only or test-time usage.

Uses of Monitored in io.fluxcapacitor.testserver.scheduling

Classes in io.fluxcapacitor.testserver.scheduling that implement Monitored

Modifier and Type	Class	Description
class	TestServerScheduleStore