Uses of Interface
io.fluxzero.sdk.Fluxzero

Packages that use Fluxzero

Package	Description
io.fluxzero.sdk
io.fluxzero.sdk.configuration
io.fluxzero.sdk.configuration.spring
io.fluxzero.sdk.persisting.repository
io.fluxzero.sdk.scheduling
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.tracking.metrics.host
io.fluxzero.sdk.web

Uses of Fluxzero in io.fluxzero.sdk

Fields in io.fluxzero.sdk with type parameters of type Fluxzero

Modifier and Type	Field	Description
static final AtomicReference<Fluxzero>	Fluxzero.applicationInstance	Fluxzero instance set by the current application.
static final ThreadLocal<Fluxzero>	Fluxzero.instance	Thread-local binding of the current Fluxzero instance.

Methods in io.fluxzero.sdk that return Fluxzero

Modifier and Type	Method	Description
static Fluxzero	Fluxzero.get()	Returns the Fluxzero instance bound to the current thread or else set by the current application.

Methods in io.fluxzero.sdk that return types with arguments of type Fluxzero

Modifier and Type	Method	Description
static Optional<Fluxzero>	Fluxzero.getOptionally()	Returns the Fluxzero client bound to the current thread or else set by the current application as Optional.

Method parameters in io.fluxzero.sdk with type arguments of type Fluxzero

Modifier and Type	Method	Description
default <R> R	Fluxzero.apply(ThrowingFunction<Fluxzero,R> function)	Applies the given function with this Fluxzero set as current threadlocal instance.
default void	Fluxzero.execute(ThrowingConsumer<Fluxzero> task)	Executes the given task with this Fluxzero set as current threadlocal instance.

Uses of Fluxzero in io.fluxzero.sdk.configuration

Classes in io.fluxzero.sdk.configuration that implement Fluxzero

Modifier and Type	Class	Description
class	DefaultFluxzero

Methods in io.fluxzero.sdk.configuration that return Fluxzero

Modifier and Type	Method	Description
Fluxzero	DefaultFluxzero.Builder.build(@NonNull Client client)
Fluxzero	FluxzeroBuilder.build(Client client)	Builds the Fluxzero instance using the provided low-level Client.
protected Fluxzero	DefaultFluxzero.Builder.doBuild(Map<MessageType, ? extends Tracking> trackingSupplier, Function<String, ? extends GenericGateway> customGatewaySupplier, CommandGateway commandGateway, QueryGateway queryGateway, EventGateway eventGateway, ResultGateway resultGateway, ErrorGateway errorGateway, MetricsGateway metricsGateway, WebRequestGateway webRequestGateway, AggregateRepository aggregateRepository, SnapshotStore snapshotStore, EventStore eventStore, KeyValueStore keyValueStore, DocumentStore documentStore, MessageScheduler messageScheduler, UserProvider userProvider, Cache cache, Serializer serializer, CorrelationDataProvider correlationDataProvider, IdentityProvider identityProvider, PropertySource propertySource, DelegatingClock clock, TaskScheduler taskScheduler, Client client, ThrowingRunnable shutdownHandler)

Uses of Fluxzero in io.fluxzero.sdk.configuration.spring

Methods in io.fluxzero.sdk.configuration.spring that return Fluxzero

Modifier and Type	Method	Description
Fluxzero	FluxzeroSpringConfig.fluxzero(FluxzeroBuilder builder, List<FluxzeroCustomizer> customizers)	Constructs the Fluxzero instance if no Fluxzero bean exists, preferring a user-provided Client or falling back to either a WebSocketClient or LocalClient depending on presence of configuration properties.

Methods in io.fluxzero.sdk.configuration.spring with parameters of type Fluxzero

Modifier and Type	Method	Description
AggregateRepository	FluxzeroSpringConfig.aggregateRepository(Fluxzero fluxzero)	Exposes this Fluxzero instance's aggregate repository as a Spring bean when no overriding bean exists.
CommandGateway	FluxzeroSpringConfig.commandGateway(Fluxzero fluxzero)	Exposes this Fluxzero instance's command gateway as a Spring bean when no overriding bean exists.
DocumentStore	FluxzeroSpringConfig.documentStore(Fluxzero fluxzero)	Exposes this Fluxzero instance's document store as a Spring bean when no overriding bean exists.
ErrorGateway	FluxzeroSpringConfig.errorGateway(Fluxzero fluxzero)	Exposes this Fluxzero instance's error gateway as a Spring bean when no overriding bean exists.
EventGateway	FluxzeroSpringConfig.eventGateway(Fluxzero fluxzero)	Exposes this Fluxzero instance's event gateway as a Spring bean when no overriding bean exists.
KeyValueStore	FluxzeroSpringConfig.keyValueStore(Fluxzero fluxzero)	Exposes this Fluxzero instance's key-value store as a Spring bean when no overriding bean exists.
MetricsGateway	FluxzeroSpringConfig.metricsGateway(Fluxzero fluxzero)	Exposes this Fluxzero instance's metrics gateway as a Spring bean when no overriding bean exists.
QueryGateway	FluxzeroSpringConfig.queryGateway(Fluxzero fluxzero)	Exposes this Fluxzero instance's query gateway as a Spring bean when no overriding bean exists.
ResultGateway	FluxzeroSpringConfig.resultGateway(Fluxzero fluxzero)	Exposes this Fluxzero instance's result gateway as a Spring bean when no overriding bean exists.
MessageScheduler	FluxzeroSpringConfig.scheduler(Fluxzero fluxzero)	Exposes this Fluxzero instance's message scheduler as a Spring bean when no overriding bean exists.

Uses of Fluxzero in io.fluxzero.sdk.persisting.repository

Methods in io.fluxzero.sdk.persisting.repository with parameters of type Fluxzero

Modifier and Type	Method	Description
void	DefaultModelRepository.configureOwningApplication(Fluxzero application)	Binds background cache replay to this repository's owning application, including namespace views.

Uses of Fluxzero in io.fluxzero.sdk.scheduling

Methods in io.fluxzero.sdk.scheduling with parameters of type Fluxzero

Modifier and Type	Method	Description
protected void	DefaultMessageScheduler.scheduleLocalDelivery(Schedule schedule, boolean ifAbsent, Fluxzero fluxzero)

Constructors in io.fluxzero.sdk.scheduling with parameters of type Fluxzero

Modifier	Constructor	Description
protected	LocalScheduleTask(Schedule schedule, Fluxzero fluxzero)

Uses of Fluxzero in io.fluxzero.sdk.tracking

Methods in io.fluxzero.sdk.tracking with parameters of type Fluxzero

Modifier and Type	Method	Description
static List<BatchInterceptor>	BatchInterceptor.effectiveInterceptors(ConsumerConfiguration configuration, MessageType type, Fluxzero fluxzero)	Ordered application and consumer interceptors, shared by execution and input selection.
Registration	DefaultTracking.observeConsumers(Fluxzero fluxzero, List<?> handlers, BiFunction<ConsumerConfiguration, List<DefaultTracking.PreparedHandler>, Registration> observer)	Describes effective consumers using the ordinary tracking preparation without starting trackers, initializing schedules, or opening document readers.
protected List<String>	DefaultTracking.retainTrackingTopics(ConsumerConfiguration configuration, List<Handler<DeserializingMessage>> activeHandlers, List<Handler<DeserializingMessage>> addedHandlers, Fluxzero fluxzero)
Registration	DefaultTracking.start(Fluxzero fluxzero, List<?> handlers)	Starts tracking by assigning the given handlers to configured consumers and creating topic-specific or shared trackers.
default Registration	Tracking.start(Fluxzero fluxzero, Object... handlers)	Starts the tracking process using the specified Fluxzero instance and the provided handlers.
Registration	Tracking.start(Fluxzero fluxzero, List<?> handlers)	Starts tracking messages using the provided Fluxzero and a list of handlers.
protected Registration	DefaultTracking.startTracking(ConsumerConfiguration configuration, List<Handler<DeserializingMessage>> handlers, String topic, Fluxzero fluxzero)

Uses of Fluxzero in io.fluxzero.sdk.tracking.client

Methods in io.fluxzero.sdk.tracking.client with parameters of type Fluxzero

Modifier and Type	Method	Description
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.

Uses of Fluxzero in io.fluxzero.sdk.tracking.metrics.host

Constructors in io.fluxzero.sdk.tracking.metrics.host with parameters of type Fluxzero

Modifier	Constructor	Description
	HostMetricsCollector(HostMetricsConfiguration configuration, Fluxzero fluxzero)

Uses of Fluxzero in io.fluxzero.sdk.web

Methods in io.fluxzero.sdk.web with parameters of type Fluxzero

Modifier and Type	Method	Description
protected GatewayClient	ForwardingWebConsumer.responseGateway(Fluxzero fluxzero)
void	ForwardingWebConsumer.start(Fluxzero fluxzero)	Restarts forwarding for the supplied Fluxzero instance, consuming web requests and asynchronously returning correlated responses from the configured local server.