Index (io.fluxzero:common 1.260.0 API)

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractConverter<I,O> - Class in io.fluxzero.common.serialization: An abstract base class for converting data of type I to type O.
AbstractConverter() - Constructor for class io.fluxzero.common.serialization.AbstractConverter
AbstractRequestResult - Class in io.fluxzero.common.api: Base implementation for built-in RequestResult types.
AbstractRequestResult() - Constructor for class io.fluxzero.common.api.AbstractRequestResult
accept() - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer0
accept(Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer1
accept(Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer2
accept(Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer3
accept(Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer4
accept(Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer5
accept(Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer6
accept(Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer7
accept(Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer8
accept(Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer9
accept(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Consumer10
accept(List) - Method in interface io.fluxzero.common.Backlog.BatchConsumer
accept(T) - Method in interface io.fluxzero.common.ThrowingConsumer: Performs this operation on the given argument.
accept(T, U) - Method in interface io.fluxzero.common.ThrowingBiConsumer: Performs this operation on the given arguments.
AdaptiveObjectCache - Class in io.fluxzero.common.caching: Cache implementation backed by the common hard-reference memory-aware cache support.
AdaptiveObjectCache() - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache
AdaptiveObjectCache(int) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache
AdaptiveObjectCache(int, MemoryPressureController) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache
AdaptiveObjectCache(int, MemoryPressureController, Duration) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache: Constructs a count-bounded cache with memory-pressure trimming and a maximum entry age.
AdaptiveObjectCache(int, MemoryPressureController, Duration, Clock) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache
AdaptiveObjectCache(int, Duration) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache: Constructs a count-bounded cache with a maximum entry age.
AdaptiveObjectCache(long, long, ToLongBiFunction, MemoryPressureController) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache
AdaptiveObjectCache(long, long, ToLongBiFunction, MemoryPressureController, Duration) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache: Constructs a weighted cache with memory-pressure trimming and a maximum entry age.
AdaptiveObjectCache(long, long, ToLongBiFunction, MemoryPressureController, Duration, Clock) - Constructor for class io.fluxzero.common.caching.AdaptiveObjectCache
add(Collection) - Method in class io.fluxzero.common.Backlog: Adds a collection of values to the backlog.
add(T...) - Method in class io.fluxzero.common.Backlog: Adds values to the backlog.
addIfAbsent(Object, Object) - Method in class io.fluxzero.common.api.Metadata: Adds the specified key-value pair to the metadata if the key is not already present.
addIfAbsent(Map) - Method in class io.fluxzero.common.api.Metadata: Adds all entries from the specified map to the current Metadata, ignoring keys that already exist.
addMetadataEntries(Map, Metadata) - Method in class io.fluxzero.common.search.JacksonInverter
adjustMaxSize(Tracker, int) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
afterRetry(Throwable) - Method in class io.fluxzero.common.RetryStatus: Produces a new RetryStatus based on this one, incrementing the retry count and updating the exception.
ALGORITHM - Static variable in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
all(Constraint...) - Static method in class io.fluxzero.common.api.search.constraints.AllConstraint: Creates an AllConstraint from the given array of constraints.
all(Collection) - Static method in class io.fluxzero.common.api.search.constraints.AllConstraint: Creates an AllConstraint from the given collection of constraints.
AllConstraint - Class in io.fluxzero.common.api.search.constraints: A composite constraint that requires all inner constraints to match.
AllConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.AllConstraint
ALLOW_ALL - Static variable in interface io.fluxzero.common.handling.MessageFilter
allowAll() - Static method in interface io.fluxzero.common.handling.MessageFilter
ALWAYS_HANDLE - Static variable in interface io.fluxzero.common.handling.HandlerFilter
and(Constraint) - Method in interface io.fluxzero.common.api.search.Constraint: Combines this constraint with another using logical AND.
and(HandlerFilter) - Method in interface io.fluxzero.common.handling.HandlerFilter: Combines this filter with another using logical AND.
and(MessageFilter) - Method in interface io.fluxzero.common.handling.MessageFilter: Combines this filter with another using logical AND.
and(ThrowingPredicate) - Method in interface io.fluxzero.common.ThrowingPredicate: Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
andFinally(HandlerInvoker) - Method in interface io.fluxzero.common.handling.HandlerInvoker: Composes this invoker with another to be invoked in a finally block.
andThen(ThrowingBiConsumer) - Method in interface io.fluxzero.common.ThrowingBiConsumer: Returns a composed ThrowingBiConsumer that performs, in sequence, this operation followed by the after operation.
andThen(ThrowingConsumer) - Method in interface io.fluxzero.common.ThrowingConsumer: Returns a composed consumer that performs, in sequence, this operation followed by the after operation.
andThen(ThrowingFunction) - Method in interface io.fluxzero.common.ThrowingBiFunction: Returns a composed function that first applies this function to its input, and then applies the after function to the result.
andThen(ThrowingFunction) - Method in interface io.fluxzero.common.ThrowingFunction: Returns a composed function that first applies this function to its input, and then applies the after function to the result.
andThen(PropertySource) - Method in interface io.fluxzero.common.application.PropertySource: Combines this property source with another, returning the first non-null value found between the two.
annotatedFields(Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
annotatedMethods(Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
annotatedProperties(Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
annotatedProperty(Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
annotatedPropertyInvoker(Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
annotationAs(AnnotatedElement, Class, Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
annotations(AnnotatedElement) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
any(Constraint...) - Static method in class io.fluxzero.common.api.search.constraints.AnyConstraint: Creates an AnyConstraint from the given array of constraints.
any(Collection) - Static method in class io.fluxzero.common.api.search.constraints.AnyConstraint: Creates an AnyConstraint from the given collection of constraints.
AnyConstraint - Class in io.fluxzero.common.api.search.constraints: A composite constraint that requires at least one inner constraint to match.
AnyConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.AnyConstraint
append(SerializedMessage...) - Method in interface io.fluxzero.common.tracking.MessageStore: Appends the given messages to the store.
append(List) - Method in interface io.fluxzero.common.tracking.MessageStore: Appends a list of messages to the store.
Append - Class in io.fluxzero.common.api.publishing: Command to publish messages to a specific log in Fluxzero (e.g., commands, events, metrics, etc.).
Append() - Constructor for class io.fluxzero.common.api.publishing.Append
Append.Metric - Class in io.fluxzero.common.api.publishing: Metric payload used for internal monitoring and logging.
AppendEvents - Class in io.fluxzero.common.api.eventsourcing: Command used to append one or more event batches to the event store.
AppendEvents() - Constructor for class io.fluxzero.common.api.eventsourcing.AppendEvents
AppendEvents.Metric - Class in io.fluxzero.common.api.eventsourcing: Compact metric representation of an AppendEvents command.
ApplicationEnvironmentPropertiesSource - Class in io.fluxzero.common.application: A PropertySource that loads environment-specific properties from an application-<env>.properties file on the classpath.
ApplicationEnvironmentPropertiesSource() - Constructor for class io.fluxzero.common.application.ApplicationEnvironmentPropertiesSource: Constructs an ApplicationEnvironmentPropertiesSource based on the resolved environment.
ApplicationEnvironmentPropertiesSource(String) - Constructor for class io.fluxzero.common.application.ApplicationEnvironmentPropertiesSource: Constructs an ApplicationEnvironmentPropertiesSource using the specified environment name.
ApplicationLifecycleEvent - Class in io.fluxzero.common.api: Metric event emitted when a Fluxzero application instance starts or begins shutting down.
ApplicationLifecycleEvent() - Constructor for class io.fluxzero.common.api.ApplicationLifecycleEvent
ApplicationLifecycleEvent.Phase - Enum Class in io.fluxzero.common.api: Application lifecycle phases published as metrics.
ApplicationPropertiesSource - Class in io.fluxzero.common.application: A PropertySource implementation that loads properties from an application.properties file located on the classpath.
ApplicationPropertiesSource() - Constructor for class io.fluxzero.common.application.ApplicationPropertiesSource: Constructs a new ApplicationPropertiesSource by loading the application.properties file from the classpath.
apply() - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function0
apply(Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function1
apply(Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function2
apply(Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function3
apply(Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function4
apply(Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function5
apply(Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function6
apply(Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function7
apply(Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function8
apply(Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function9
apply(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxzero.common.reflection.DefaultMemberInvoker._Function10
apply(K) - Method in class io.fluxzero.common.DefaultMemoizingFunction
apply(T) - Method in interface io.fluxzero.common.ThrowingFunction: Applies this function to the given argument.
apply(T, U) - Method in class io.fluxzero.common.DefaultMemoizingBiFunction
apply(T, U) - Method in interface io.fluxzero.common.ThrowingBiFunction: Applies this function to the given arguments.
asBytes(Object) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to a JSON byte array.
asCallable(ThrowingRunnable) - Static method in class io.fluxzero.common.ObjectUtils: Converts a ThrowingRunnable into a Callable<Object> that returns null.
asCallable(Runnable) - Static method in class io.fluxzero.common.ObjectUtils: Converts a standard Runnable into a Callable<Object> that returns null.
asClass(Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
asConsumer(ThrowingConsumer) - Static method in class io.fluxzero.common.ObjectUtils
asFunction(ThrowingFunction) - Static method in class io.fluxzero.common.ObjectUtils
asHeaders(Collection) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities: Serializes the supplied compression capabilities into websocket request headers.
asInstance(Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
asIntegerOrString(String) - Static method in class io.fluxzero.common.SearchUtils: Attempts to convert a numeric string to an Integer, falling back to the original string otherwise.
asInvoker(Member) - Static method in class io.fluxzero.common.reflection.DefaultMemberInvoker
asInvoker(Member, boolean) - Static method in class io.fluxzero.common.reflection.DefaultMemberInvoker
asJson(Object) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to a JSON string.
asKotlinFunction(Executable) - Static method in class io.fluxzero.common.reflection.KotlinReflectionUtils
asKotlinParameter(Parameter) - Static method in class io.fluxzero.common.reflection.KotlinReflectionUtils
asPredicate() - Method in interface io.fluxzero.common.ThrowingPredicate: Converts this ThrowingPredicate into a standard Predicate.
asPrettyJson(Object) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to a formatted JSON string.
asPrimitive(Object) - Static method in class io.fluxzero.common.SearchUtils: Converts any non-primitive value to its string form.
asProperties(String) - Static method in class io.fluxzero.common.ObjectUtils: Parses Java Properties from a string.
asRunnable(ThrowingRunnable) - Static method in class io.fluxzero.common.ObjectUtils
asRunnable(Callable) - Static method in class io.fluxzero.common.ObjectUtils
asStream(Object) - Static method in class io.fluxzero.common.ObjectUtils: Converts an object into a stream.
asSupplier(Callable) - Static method in class io.fluxzero.common.ObjectUtils
asTransportHeaders(Collection) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities: Serializes the supplied websocket transport formats into websocket request headers.
atLeast(Object, String) - Static method in class io.fluxzero.common.api.search.constraints.BetweenConstraint: Creates a constraint that matches values in the given path that are greater than or equal to min.
auditTrail - Enum constant in enum class io.fluxzero.common.api.search.SearchCollectionType: A time-partitioned searchable audit trail.
available() - Method in class io.fluxzero.common.LazyInputStream
available() - Method in class io.fluxzero.common.StreamInputStream
awaitTermination(long, TimeUnit) - Method in class io.fluxzero.common.DirectExecutorService

B

Backlog<T> - Class in io.fluxzero.common: A thread-safe batching queue that asynchronously flushes its content to a consumer in configurable batch sizes.
Backlog(ThrowingFunction) - Constructor for class io.fluxzero.common.Backlog
Backlog(ThrowingFunction, int) - Constructor for class io.fluxzero.common.Backlog
Backlog(ThrowingFunction, int, ErrorHandler) - Constructor for class io.fluxzero.common.Backlog
Backlog(ThrowingFunction, int, ErrorHandler, boolean) - Constructor for class io.fluxzero.common.Backlog
Backlog.BatchConsumer<T> - Interface in io.fluxzero.common: A function that consumes a batch of items and returns a future that completes when processing is done.
Behavior - Section in class io.fluxzero.common.api.keyvalue.DeleteValue
Behavior - Section in class io.fluxzero.common.api.keyvalue.GetValue
below(Object, String) - Static method in class io.fluxzero.common.api.search.constraints.BetweenConstraint: Creates a constraint that matches values in the given path that are less than maxExclusive.
between(Object, Object, String) - Static method in class io.fluxzero.common.api.search.constraints.BetweenConstraint: Creates a constraint that matches values in the given path that are greater than or equal to min and less than max.
BetweenConstraint - Class in io.fluxzero.common.api.search.constraints: A Constraint that filters documents based on whether a value in a specific path lies between two bounds.
BetweenConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.BetweenConstraint
bindHandlerMethod(Object) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
bindHandlerMethod(Object) - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
bindHandlerMethod(T) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Binds this matcher to a stable target instance, if it can expose a reusable method plan.
bindHandlerMethodPlanner(Object) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
bindHandlerMethodPlanner(Object) - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
bindHandlerMethodPlanner(T) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Creates a planner whose invocation plans call handler methods on the supplied target instance.
bindPayloadHandlerMethodPlanner() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
bindPayloadHandlerMethodPlanner() - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
bindPayloadHandlerMethodPlanner() - Method in interface io.fluxzero.common.handling.HandlerMatcher: Creates a planner for handler methods declared on the payload itself.
BOOLEAN - Enum constant in enum class io.fluxzero.common.search.Document.EntryType: Represents boolean values: true or false.
BooleanResult - Class in io.fluxzero.common.api: A generic response containing a boolean value, typically used to indicate success/failure.
BooleanResult() - Constructor for class io.fluxzero.common.api.BooleanResult
box(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Converts a primitive type to its wrapper class and leaves non-primitive types unchanged.
Builder() - Constructor for class io.fluxzero.common.api.search.SearchQuery.Builder
BulkUpdate - Interface in io.fluxzero.common.api.search: Represents a single operation in a bulk document update.
BulkUpdate.Type - Enum Class in io.fluxzero.common.api.search: Supported bulk operation types.
BulkUpdateDocuments - Class in io.fluxzero.common.api.search: Command to perform a batch update of documents in the search/document store.
BulkUpdateDocuments() - Constructor for class io.fluxzero.common.api.search.BulkUpdateDocuments
BulkUpdateDocuments.Metric - Class in io.fluxzero.common.api.search: Metric representation for monitoring or observability.
byteLimited() - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Returns the value of the byteLimited record component.
bytes() - Method in class io.fluxzero.common.api.search.SerializedDocument: Returns the number of bytes in the serialized representation of the document.

C

Cache - Interface in io.fluxzero.common.caching: A generic cache interface for storing and managing objects identified by unique keys.
cacheable(Object, boolean, HandlerMethodPreparation) - Static method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Creates a result that may be reused for inputs with the same cache key.
CacheEviction - Class in io.fluxzero.common.caching: Represents an eviction from a Cache.
CacheEviction() - Constructor for class io.fluxzero.common.caching.CacheEviction
CacheEviction.Reason - Enum Class in io.fluxzero.common.caching: Indicates the cause for a cache entry eviction.
cacheKey() - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns the value of the cacheKey record component.
call(Callable) - Static method in interface io.fluxzero.common.handling.HandlerInvoker: Wraps a Callable in a HandlerInvoker.
call(Callable) - Static method in class io.fluxzero.common.ObjectUtils: Calls the given callable, forcibly rethrowing exceptions.
callAndWait(Callable, Duration) - Method in class io.fluxzero.common.TimeboxedExecutor: Executes the given task within the specified maximum duration.
callAndWait(Callable, Duration) - Static method in class io.fluxzero.common.TimingUtils: Executes the given task within the specified maximum duration.
callAndWait(Callable, Duration, Supplier) - Method in class io.fluxzero.common.TimeboxedExecutor: Executes the given task within the specified maximum duration.
callAndWait(Callable, Duration, Supplier) - Static method in class io.fluxzero.common.TimingUtils: Executes the given task within the specified maximum duration.
cancel() - Method in interface io.fluxzero.common.Registration: Cancels the resource or subscription associated with this registration.
CancelSchedule - Class in io.fluxzero.common.api.scheduling: Command to cancel a previously scheduled message using its CancelSchedule.scheduleId.
CancelSchedule() - Constructor for class io.fluxzero.common.api.scheduling.CancelSchedule
canDeserialize(Data) - Method in enum class io.fluxzero.common.search.DefaultDocumentSerializer: Checks whether the given Data object is in a format that this serializer can deserialize.
canHandle(SerializedMessage, int[]) - Method in interface io.fluxzero.common.tracking.Tracker: Checks if the given message can be handled by this tracker based on segment range and type filtering.
canHandle(M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
canHandle(M) - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
canHandle(M) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Returns whether the given message can be handled by a handler instance of type T.
canHandle(M) - Method in interface io.fluxzero.common.handling.HandlerMethod: Returns whether this method can handle the supplied message.
canHandle(M) - Method in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
Capabilities - Section in class io.fluxzero.common.handling.HandlerInspector
capitalize(String) - Static method in class io.fluxzero.common.ObjectUtils: Capitalizes the first character of a string, leaving null and empty strings unchanged.
cbor(ObjectMapper) - Static method in class io.fluxzero.common.websocket.WebSocketTransportCodecs: Jackson CBOR codec.
CBOR - Enum constant in enum class io.fluxzero.common.websocket.WebSocketTransportFormat: Jackson CBOR transport.
ChaCha20Poly1305Encryption - Class in io.fluxzero.common.encryption: Implementation of Encryption using the ChaCha20-Poly1305 authenticated encryption algorithm.
ChaCha20Poly1305Encryption() - Constructor for class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
ChaCha20Poly1305Encryption(String) - Constructor for class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
checkPathBeforeEntry() - Method in class io.fluxzero.common.api.search.constraints.BetweenConstraint
checkPathBeforeEntry() - Method in class io.fluxzero.common.api.search.constraints.PathConstraint: Determines whether path filtering should be performed before evaluating entry-level match criteria.
CHUNK_INDEX - Static variable in interface io.fluxzero.common.api.HasMetadata: Metadata key that stores the zero-based position of a chunk within a chunked message.
chunked() - Method in interface io.fluxzero.common.api.HasMetadata: Determines if the data associated with this metadata is "chunked".
ClaimResult - Class in io.fluxzero.common.tracking: Result of a segment claim in the tracking strategy domain.
ClaimResult() - Constructor for class io.fluxzero.common.tracking.ClaimResult
claimSegment(Tracker) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
claimSegment(Tracker) - Method in interface io.fluxzero.common.tracking.TrackingStrategy: Claims one or more message segments for the given tracker.
claimSegment(Tracker, DefaultTrackingStrategy.TrackerRequest) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
ClaimSegment - Class in io.fluxzero.common.api.tracking: A request to claim a message segment for consumption in client-controlled tracking mode.
ClaimSegment(Read) - Constructor for class io.fluxzero.common.api.tracking.ClaimSegment
ClaimSegment(MessageType, String, String, long, boolean, String, boolean, Long, Long) - Constructor for class io.fluxzero.common.api.tracking.ClaimSegment
claimSegmentRange(Tracker) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
ClaimSegmentResult - Class in io.fluxzero.common.api.tracking: Result of a ClaimSegment request.
ClaimSegmentResult() - Constructor for class io.fluxzero.common.api.tracking.ClaimSegmentResult
ClaimSegmentResult.Metric - Class in io.fluxzero.common.api.tracking: Lightweight metric representation of a ClaimSegmentResult, used for telemetry.
classExists(String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
classForName(String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
classForName(String, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
clear() - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
clear() - Method in interface io.fluxzero.common.caching.Cache: Removes all entries from the cache.
clear() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
clear() - Method in enum class io.fluxzero.common.caching.NoOpCache
clear() - Method in class io.fluxzero.common.DefaultMemoizingBiFunction
clear() - Method in class io.fluxzero.common.DefaultMemoizingFunction
clear() - Method in class io.fluxzero.common.DefaultMemoizingSupplier
clear() - Method in interface io.fluxzero.common.MemoizingBiFunction: Clears all cached values.
clear() - Method in interface io.fluxzero.common.MemoizingFunction: Removes all cached values from this function.
clear() - Method in interface io.fluxzero.common.MemoizingSupplier: Clears the cached value, forcing the next call to recompute.
CLIENT_SDK_VERSION_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
CLIENT_SESSION_ID_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
clientControlledIndex() - Method in class io.fluxzero.common.tracking.SimpleTracker
clientControlledIndex() - Method in interface io.fluxzero.common.tracking.Tracker
clock() - Method in class io.fluxzero.common.InMemoryTaskScheduler
clock() - Method in interface io.fluxzero.common.TaskScheduler: Returns the clock associated with this scheduler.
close() - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
close() - Method in interface io.fluxzero.common.caching.Cache: Closes the cache and releases all associated resources.
close() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
close() - Method in enum class io.fluxzero.common.caching.NoOpCache
close() - Method in class io.fluxzero.common.LazyInputStream
close() - Method in class io.fluxzero.common.StreamInputStream
close() - Method in class io.fluxzero.common.TimeboxedExecutor
close() - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
close() - Method in class io.fluxzero.common.tracking.InMemoryPositionStore
close() - Method in interface io.fluxzero.common.tracking.MessageStore: Default no-op close method.
close() - Method in interface io.fluxzero.common.tracking.PositionStore: Closes any underlying resources held by the store.
close() - Method in interface io.fluxzero.common.tracking.TrackingStrategy: Closes the tracking strategy and releases any underlying resources.
combineSummary(String, String) - Method in class io.fluxzero.common.search.JacksonInverter
Combining multiple registrations - Section in interface io.fluxzero.common.Registration
Command - Class in io.fluxzero.common.api: Base class for commands sent to the Fluxzero Runtime.
Command() - Constructor for class io.fluxzero.common.api.Command
COMMAND - Enum constant in enum class io.fluxzero.common.MessageType: A request to perform an action or change state.
comparator - Static variable in class io.fluxzero.common.api.search.SortableEntry: Comparator used to lexicographically compare entries based on SortableEntry.name and SortableEntry.value.
comparator - Static variable in interface io.fluxzero.common.tracking.Tracker: Default comparator based on consumer name and tracker ID.
comparator(HandlerConfiguration) - Static method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
compare(int, HandlerInspector.MethodHandlerMatcher.Specificity, int, int, Executable, int, HandlerInspector.MethodHandlerMatcher.Specificity, int, int, Executable, Comparator) - Static method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
compareForMessage(HandlerInspector.MethodHandlerMatcher, M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
compareTo(FacetEntry) - Method in class io.fluxzero.common.api.search.FacetEntry: Sorts facet entries by name, then by value.
compareTo(SortableEntry) - Method in class io.fluxzero.common.api.search.SortableEntry
compareTo(Document.Entry) - Method in class io.fluxzero.common.search.Document.Entry: Compares this entry with the specified entry for order.
compareTo(Tracker) - Method in interface io.fluxzero.common.tracking.Tracker: Compares trackers based on consumer and tracker IDs for stable sorting.
completeResults(long, Throwable) - Method in class io.fluxzero.common.Backlog
Components - Section in class io.fluxzero.common.search.Document
Composability - Section in interface io.fluxzero.common.api.search.Constraint
compose(ThrowingFunction) - Method in interface io.fluxzero.common.ThrowingFunction: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
compose(Function) - Method in interface io.fluxzero.common.MemoizingFunction: Composes this memoizing function with another function.
compose(Function) - Method in interface io.fluxzero.common.MemoizingBiFunction: Creates a MemoizingFunction by composing this memoizing bi-function with an input transformation.
compress(byte[]) - Method in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: Compresses bytes using this algorithm's public SDK wire format.
CompressionAlgorithm - Enum Class in io.fluxzero.common.serialization.compression: Enumeration of supported compression algorithms used for serializing and deserializing byte data.
compute(Object, BiFunction) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
compute(Object, BiFunction) - Method in interface io.fluxzero.common.caching.Cache: Computes and stores a new value for the given id using the provided function.
compute(Object, BiFunction) - Method in enum class io.fluxzero.common.caching.NoOpCache
compute(Stream, List, List) - Static method in class io.fluxzero.common.api.search.DocumentStats: Computes document statistics from a stream of documents.
computeClassForSpecificity() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
computeEntryMatcher() - Method in class io.fluxzero.common.api.search.constraints.MatchConstraint
computeIfAbsent(Object, Function) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
computeIfAbsent(Object, Function) - Method in interface io.fluxzero.common.caching.Cache: If a value is not already associated with the given id, computes and stores one using the given function.
computeIfAbsent(Object, Function) - Method in enum class io.fluxzero.common.caching.NoOpCache
computeIfPresent(Object, BiFunction) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
computeIfPresent(Object, BiFunction) - Method in interface io.fluxzero.common.caching.Cache: If a value is already associated with the given id, computes a new value using the provided function and replaces the old one.
computeIfPresent(Object, BiFunction) - Method in enum class io.fluxzero.common.caching.NoOpCache
computePathFilter() - Method in class io.fluxzero.common.api.search.SearchDocuments: Computes a path-level filter based on the SearchDocuments.pathFilters list.
computeSegment(String) - Static method in class io.fluxzero.common.ConsistentHashing: Computes the segment for a given routing key using the default hash function and the default maximum segment size.
computeSegment(String, int) - Static method in class io.fluxzero.common.ConsistentHashing: Computes the segment for a given routing key and maximum number of segments, using the default hash function.
computeSegment(String, Function, int) - Static method in class io.fluxzero.common.ConsistentHashing: Computes the segment using a custom hash function and max segment size.
computeSpecificity(M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
concat(Stream...) - Static method in class io.fluxzero.common.ObjectUtils: Concatenates multiple streams into a single flat stream.
CONFIG_LOCATIONS_PROPERTY - Static variable in class io.fluxzero.common.application.FluxzeroAdditionalPropertiesSource: Environment variable or system property that points to extra Fluxzero configuration locations.
CONFIG_LOCATIONS_PROPERTY_ALIAS - Static variable in class io.fluxzero.common.application.FluxzeroAdditionalPropertiesSource: Lower-case system property alias for FluxzeroAdditionalPropertiesSource.CONFIG_LOCATIONS_PROPERTY.
ConnectEvent - Class in io.fluxzero.common.api: A runtime-generated event that indicates a client has successfully connected to the Fluxzero Runtime.
ConnectEvent() - Constructor for class io.fluxzero.common.api.ConnectEvent
ConsistentHashing - Class in io.fluxzero.common: Utility class for computing segment assignments using consistent hashing.
ConsistentHashing() - Constructor for class io.fluxzero.common.ConsistentHashing
Constraint - Interface in io.fluxzero.common.api.search: Base interface for defining filter conditions (constraints) used in document search queries.
contains() - Element in annotation interface io.fluxzero.common.serialization.RegisterType: Optional filters to determine which types should be registered based on name matching.
contains(Metadata) - Method in class io.fluxzero.common.api.Metadata: Checks whether the current metadata contains all entries of the specified metadata.
contains(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Checks if the tracker is part of this cluster.
contains(Object, Object) - Method in class io.fluxzero.common.api.Metadata: Determines if the specified key-value pair exists within the data structure.
contains(String, boolean, boolean, boolean, String...) - Static method in class io.fluxzero.common.api.search.constraints.ContainsConstraint: Create a constraint that optionally splits the input phrase into individual terms and combines the resulting constraints using AllConstraint.
contains(String, boolean, boolean, String...) - Static method in class io.fluxzero.common.api.search.constraints.ContainsConstraint: Create a constraint that allows prefix and/or postfix matching of a given phrase.
contains(String, String...) - Static method in class io.fluxzero.common.api.search.constraints.ContainsConstraint: Create a basic ContainsConstraint that checks if the given phrase exists anywhere in the entry, using default full-word matching (i.e., neither prefix nor postfix logic).
containsAnyKey(Object...) - Method in class io.fluxzero.common.api.Metadata: Checks if the given keys are present in the internal entries.
ContainsConstraint - Class in io.fluxzero.common.api.search.constraints: A constraint that matches document entries containing the specified phrase, with optional wildcard-like flexibility.
ContainsConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.ContainsConstraint
containsKey(Object) - Method in class io.fluxzero.common.api.Metadata: Checks if the specified key is present in the entries map.
containsKey(Object) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
containsKey(Object) - Method in interface io.fluxzero.common.caching.Cache: Checks whether the cache contains an entry for the given id.
containsKey(Object) - Method in enum class io.fluxzero.common.caching.NoOpCache
containsKey(K) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
containsProperty(String) - Method in interface io.fluxzero.common.application.PropertySource: Checks if a property is defined.
convert(I) - Method in class io.fluxzero.common.serialization.AbstractConverter
convert(Data) - Method in class io.fluxzero.common.search.JacksonInverter
convert(Data) - Method in class io.fluxzero.common.serialization.AbstractConverter
convert(Data) - Method in interface io.fluxzero.common.serialization.Converter: Converts the given Data from input type I to output type O.
convertAnnotation(Annotation, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
Converter<I,O> - Interface in io.fluxzero.common.serialization: Interface for converting Data objects from one format or representation to another.
convertFormat(Data) - Method in class io.fluxzero.common.search.JacksonInverter
convertFormat(Data) - Method in interface io.fluxzero.common.serialization.Converter: Optionally converts the structure or format (e.g.: application/json) of the input data without modifying its core content.
convertIfKotlinClass(Object) - Static method in class io.fluxzero.common.reflection.KotlinReflectionUtils
convertValue(Object, TypeReference) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to an object of the given type.
convertValue(Object, Class) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to an object of the given class.
convertValue(Object, Type) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to an object of the given type which may be a ParameterizedType or Class.
convertValue(Object, Function) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to an object of the given type.
copyFields(V, V) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
copyOf(Properties) - Static method in class io.fluxzero.common.ObjectUtils: Creates a deep copy of a Properties instance.
CreateAuditTrail - Class in io.fluxzero.common.api.search: Command to configure to use a search collection as a searchable audit trail.
CreateAuditTrail() - Constructor for class io.fluxzero.common.api.search.CreateAuditTrail
createComparator(SearchDocuments) - Static method in class io.fluxzero.common.search.Document: Constructs a Comparator to sort documents based on the sorting options in SearchDocuments.
createHandler(Object, Class) - Static method in class io.fluxzero.common.handling.HandlerInspector: Creates a Handler for the given target object and annotation type.
createHandler(Object, Class, List) - Static method in class io.fluxzero.common.handling.HandlerInspector: Creates a Handler backed by a target supplier and parameter resolvers.
createHandler(Object, List, HandlerConfiguration) - Static method in class io.fluxzero.common.handling.HandlerInspector: Creates a Handler backed by a target supplier and parameter resolvers.
createHandler(Function, Class, List, HandlerConfiguration) - Static method in class io.fluxzero.common.handling.HandlerInspector: Creates a Handler backed by a target supplier and parameter resolvers.
createSummarizer(JacksonInverter) - Static method in class io.fluxzero.common.search.JacksonInverter
CUSTOM - Enum constant in enum class io.fluxzero.common.MessageType: A message from a custom message topic.

D

data() - Method in class io.fluxzero.common.api.Data: Returns this instance (for SerializedObject compatibility).
data() - Method in class io.fluxzero.common.api.SerializedMessage
data() - Method in interface io.fluxzero.common.api.SerializedObject: Returns the serialized payload held by this object.
Data<T> - Class in io.fluxzero.common.api: A generic container for holding a value along with serialization metadata such as type, revision, and format.
Data(Supplier, String, int, String) - Constructor for class io.fluxzero.common.api.Data: Constructs a Data instance with a Supplier to support lazy access.
Data(T, String, int) - Constructor for class io.fluxzero.common.api.Data: Constructs a Data instance without a specific format (defaults to JSON).
Data(T, String, int, String) - Constructor for class io.fluxzero.common.api.Data: Constructs a Data instance with a fixed value and full metadata.
declaresField(Class, String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
declaresField(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
decode(byte[]) - Method in interface io.fluxzero.common.websocket.WebSocketTransportCodec: Decodes transport bytes into a protocol object.
decompose() - Method in interface io.fluxzero.common.api.search.Constraint: Returns a version of this constraint with all composite constraints decomposed into their atomic elements.
decompress(byte[]) - Method in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: Decompresses bytes using this algorithm's public SDK wire format.
decrypt(String) - Method in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
decrypt(String) - Method in class io.fluxzero.common.encryption.DefaultEncryption
decrypt(String) - Method in interface io.fluxzero.common.encryption.Encryption: Decrypts the given encrypted value.
decrypt(String) - Method in enum class io.fluxzero.common.encryption.NoOpEncryption
DecryptingPropertySource - Class in io.fluxzero.common.application: A PropertySource decorator that transparently decrypts encrypted property values.
DecryptingPropertySource(PropertySource) - Constructor for class io.fluxzero.common.application.DecryptingPropertySource: Constructs a DecryptingPropertySource with the specified delegate property source.
DecryptingPropertySource(PropertySource, Encryption) - Constructor for class io.fluxzero.common.application.DecryptingPropertySource: Constructs a DecryptingPropertySource using an explicit Encryption strategy.
DecryptingPropertySource(PropertySource, String) - Constructor for class io.fluxzero.common.application.DecryptingPropertySource: Constructs a DecryptingPropertySource using the given encryption key.
deduplicate(List) - Static method in class io.fluxzero.common.ObjectUtils: Deduplicates elements in the list, preserving the last occurrence.
deduplicate(List, Function) - Static method in class io.fluxzero.common.ObjectUtils: Deduplicates elements using a key extractor, preserving the last occurrence.
deduplicate(List, Function, boolean) - Static method in class io.fluxzero.common.ObjectUtils: Deduplicates elements using a key extractor, optionally keeping the first occurrence.
DEFAULT_GC_TIME_THRESHOLD_PERCENT - Static variable in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
DEFAULT_HEAP_USAGE_THRESHOLD_PERCENT - Static variable in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
DEFAULT_INITIAL_POSITION_LAG - Static variable in class io.fluxzero.common.tracking.DefaultTrackingStrategy: Default look-back applied when a consumer has no stored or client-controlled position.
DEFAULT_MAX_SIZE - Static variable in class io.fluxzero.common.caching.AdaptiveObjectCache
DEFAULT_MAX_TRIM_WEIGHT - Static variable in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
DEFAULT_MEMORY_PRESSURE_CHECK_INTERVAL - Static variable in class io.fluxzero.common.caching.MemoryAwareCacheSupport
DEFAULT_TRIM_RATIO_PERCENT - Static variable in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
defaultclock - Static variable in class io.fluxzero.common.InMemoryTaskScheduler
defaultConstructor() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
defaultDelay - Static variable in class io.fluxzero.common.InMemoryTaskScheduler
DefaultDocumentSerializer - Enum Class in io.fluxzero.common.search: Default serializer for Document instances in the Fluxzero Runtime.
DefaultEncryption - Class in io.fluxzero.common.encryption: Default implementation of the Encryption interface used in Fluxzero.
DefaultEncryption() - Constructor for class io.fluxzero.common.encryption.DefaultEncryption
DefaultHandler<M> - Class in io.fluxzero.common.handling: Default implementation of the Handler interface.
DefaultHandler(Class, Function, HandlerMatcher) - Constructor for class io.fluxzero.common.handling.DefaultHandler
DefaultMemberInvoker - Class in io.fluxzero.common.reflection: Default implementation of MemberInvoker using high-performance method handle-based invocation.
DefaultMemberInvoker._Consumer0 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer1 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer10 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer2 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer3 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer4 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer5 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer6 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer7 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer8 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Consumer9 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function0 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function1 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function10 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function2 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function3 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function4 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function5 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function6 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function7 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function8 - Interface in io.fluxzero.common.reflection
DefaultMemberInvoker._Function9 - Interface in io.fluxzero.common.reflection
DefaultMemoizingBiFunction<T,U,R> - Class in io.fluxzero.common: A default implementation of the MemoizingBiFunction interface that memoizes (caches) results of a BiFunction based on a pair of input arguments.
DefaultMemoizingBiFunction(BiFunction) - Constructor for class io.fluxzero.common.DefaultMemoizingBiFunction
DefaultMemoizingBiFunction(BiFunction, Duration, Clock) - Constructor for class io.fluxzero.common.DefaultMemoizingBiFunction
DefaultMemoizingFunction<K,V> - Class in io.fluxzero.common: A default implementation of the MemoizingFunction interface that provides caching functionality for computed function results.
DefaultMemoizingFunction(ConcurrentHashMap, Function, Duration, Clock) - Constructor for class io.fluxzero.common.DefaultMemoizingFunction
DefaultMemoizingFunction(Function) - Constructor for class io.fluxzero.common.DefaultMemoizingFunction
DefaultMemoizingFunction(Function, Duration, Clock) - Constructor for class io.fluxzero.common.DefaultMemoizingFunction
DefaultMemoizingSupplier<T> - Class in io.fluxzero.common: A default implementation of the MemoizingSupplier interface that memoizes (caches) the result of a computation performed by a supplied Supplier.
DefaultMemoizingSupplier(Supplier) - Constructor for class io.fluxzero.common.DefaultMemoizingSupplier
DefaultMemoizingSupplier(Supplier, Duration, Clock) - Constructor for class io.fluxzero.common.DefaultMemoizingSupplier
DefaultPropertySource - Class in io.fluxzero.common.application: A layered PropertySource implementation used as the default source for resolving application properties in a Fluxzero application.
DefaultPropertySource() - Constructor for class io.fluxzero.common.application.DefaultPropertySource
defaultThreadName - Static variable in class io.fluxzero.common.InMemoryTaskScheduler
DefaultTrackingStrategy - Class in io.fluxzero.common.tracking: Streaming strategy that allows multiple clients to concurrently consume a message stream.
DefaultTrackingStrategy(MessageStore, PositionStore) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy
DefaultTrackingStrategy(MessageStore, PositionStore, TaskScheduler) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy
DefaultTrackingStrategy(MessageStore, PositionStore, TaskScheduler, int) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy
DefaultTrackingStrategy(MessageStore, PositionStore, TaskScheduler, int, Duration) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy
DefaultTrackingStrategy(MessageStore, PositionStore, TaskScheduler, Duration) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy
DefaultTrackingStrategy(MessageStore, PositionStore, Duration) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy: Creates a tracking strategy with a configurable look-back for consumers without a stored position.
DefaultTrackingStrategy.TrackerRequest<T> - Class in io.fluxzero.common.tracking
DefaultTrackingStrategy.WaitingTracker - Class in io.fluxzero.common.tracking
DefaultTypeRegistry - Class in io.fluxzero.common.serialization
DefaultTypeRegistry() - Constructor for class io.fluxzero.common.serialization.DefaultTypeRegistry
DefaultTypeRegistry(List) - Constructor for class io.fluxzero.common.serialization.DefaultTypeRegistry
defaultWriterBuilder() - Static method in class io.fluxzero.common.serialization.JsonUtils: Creates a preconfigured builder for a JsonMapper for writing/serializing objects to JSON.
delegate - Variable in class io.fluxzero.common.handling.Handler.DelegatingHandler
delegate - Variable in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
delegate - Variable in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
DelegatingClock - Class in io.fluxzero.common: A concrete implementation of a Clock that delegates its method calls to another Clock instance, allowing runtime manipulation of the delegated clock.
DelegatingClock() - Constructor for class io.fluxzero.common.DelegatingClock
DelegatingHandler() - Constructor for class io.fluxzero.common.handling.Handler.DelegatingHandler
DelegatingHandlerInvoker() - Constructor for class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
DelegatingHandlerMethod() - Constructor for class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
delete - Enum constant in enum class io.fluxzero.common.api.search.BulkUpdate.Type
DeleteCollection - Class in io.fluxzero.common.api.search: Command to delete an entire search collection, removing all documents within it.
DeleteCollection() - Constructor for class io.fluxzero.common.api.search.DeleteCollection
DeleteDocument - Class in io.fluxzero.common.api.search.bulkupdate: A bulk update operation that deletes a document from a given collection using its ID.
DeleteDocument() - Constructor for class io.fluxzero.common.api.search.bulkupdate.DeleteDocument
DeleteDocumentById - Class in io.fluxzero.common.api.search: Command to delete a single document from the search store by its collection and ID.
DeleteDocumentById() - Constructor for class io.fluxzero.common.api.search.DeleteDocumentById
DeleteDocuments - Class in io.fluxzero.common.api.search: Command to delete documents from the search store based on a search query.
DeleteDocuments(SearchQuery, Guarantee) - Constructor for class io.fluxzero.common.api.search.DeleteDocuments: Creates a deletion command that uses the runtime's default batch size.
DeleteEvents - Class in io.fluxzero.common.api.eventsourcing: Command to permanently delete all events associated with a specific aggregate ID.
DeleteEvents() - Constructor for class io.fluxzero.common.api.eventsourcing.DeleteEvents
DeleteValue - Class in io.fluxzero.common.api.keyvalue: Command to delete a value from the legacy key-value store by key.
DeleteValue() - Constructor for class io.fluxzero.common.api.keyvalue.DeleteValue
deserialize(byte) - Static method in enum class io.fluxzero.common.search.Document.EntryType: Deserializes a byte into an Document.EntryType enum instance.
deserialize(Data) - Method in enum class io.fluxzero.common.search.DefaultDocumentSerializer: Deserializes a Data blob containing a compressed, binary Document.
deserializeDocument() - Method in class io.fluxzero.common.api.search.SerializedDocument: Returns the deserialized document view.
determineCommonAncestors(Collection) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
determinesSpecificity() - Method in interface io.fluxzero.common.handling.ParameterResolver: Indicates whether this resolver contributes to determining handler method specificity when multiple handler candidates are available.
DirectExecutorService - Class in io.fluxzero.common: A simple implementation of AbstractExecutorService that executes tasks directly in the calling thread without using any worker threads.
DirectExecutorService() - Constructor for class io.fluxzero.common.DirectExecutorService
disableJsonIgnore(ObjectMapper) - Static method in class io.fluxzero.common.serialization.JsonUtils: Disables any Jackson @JsonIgnore behavior on the specified ObjectMapper.
DisconnectEvent - Class in io.fluxzero.common.api: A runtime-generated event that indicates a client has disconnected from the Fluxzero Runtime.
DisconnectEvent() - Constructor for class io.fluxzero.common.api.DisconnectEvent
DisconnectTracker - Class in io.fluxzero.common.api.tracking: Command used to explicitly disconnect a tracker from the Fluxzero Runtime and release any claimed message segments.
DisconnectTracker() - Constructor for class io.fluxzero.common.api.tracking.DisconnectTracker
disconnectTrackers(Predicate, boolean) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
disconnectTrackers(Predicate, boolean) - Method in interface io.fluxzero.common.tracking.TrackingStrategy: Disconnects trackers that match the provided filter.
distinctByKey(Function) - Static method in class io.fluxzero.common.ObjectUtils: Returns a predicate that filters out duplicates based on a key extractor.
Document - Class in io.fluxzero.common.search: Represents a structured, searchable, and indexable document within a Fluxzero collection.
Document() - Constructor for class io.fluxzero.common.search.Document
DOCUMENT - Enum constant in enum class io.fluxzero.common.MessageType: A message containing an updated search document from a given collection.
DOCUMENT_FORMAT - Static variable in class io.fluxzero.common.api.Data: Custom format identifier for document data used in SerializedDocument.
Document.Entry - Class in io.fluxzero.common.search: Represents a typed field value within a document (e.g. text, number, boolean).
Document.EntryType - Enum Class in io.fluxzero.common.search: Enumerates the supported types of values that can appear in a Document entry.
Document.Path - Class in io.fluxzero.common.search: Represents a navigable field access path for a Document entry.
DocumentStats - Class in io.fluxzero.common.api.search: Represents aggregate statistics for a group of documents, including values for specified fields.
DocumentStats() - Constructor for class io.fluxzero.common.api.search.DocumentStats
DocumentStats.FieldStats - Class in io.fluxzero.common.api.search: Statistical summary for a single document field.
DocumentUpdate - Class in io.fluxzero.common.api.search: Represents a single low-level document update operation to be applied to a search collection.
DocumentUpdate() - Constructor for class io.fluxzero.common.api.search.DocumentUpdate
dynamic() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata.PropertyPathMetadata

E

empty() - Static method in class io.fluxzero.common.api.Metadata: Creates an empty instance of the Metadata class with no entries.
EMPTY_ARRAY - Enum constant in enum class io.fluxzero.common.search.Document.EntryType: Represents empty arrays (e.g., []).
EMPTY_OBJECT - Enum constant in enum class io.fluxzero.common.search.Document.EntryType: Represents empty objects (e.g., {}).
EMPTY_PATH - Static variable in class io.fluxzero.common.search.Document.Path: Singleton instance representing an empty path.
emptyRange - Static variable in class io.fluxzero.common.tracking.TrackerCluster: Shared constant representing an empty segment range.
encode(JsonType) - Method in interface io.fluxzero.common.websocket.WebSocketTransportCodec: Encodes a protocol object into transport bytes.
encrypt(String) - Method in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
encrypt(String) - Method in class io.fluxzero.common.encryption.DefaultEncryption
encrypt(String) - Method in interface io.fluxzero.common.encryption.Encryption: Encrypts the given plain-text value using the configured encryption algorithm and key.
encrypt(String) - Method in enum class io.fluxzero.common.encryption.NoOpEncryption
Encryption - Interface in io.fluxzero.common.encryption: Defines a contract for encrypting and decrypting sensitive values within the system.
ensureAccessible(T) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
ensureMessageSegment(SerializedMessage) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
Entry() - Constructor for class io.fluxzero.common.search.Document.Entry
entrySet() - Method in class io.fluxzero.common.api.Metadata: Returns a set view of the mappings contained in this metadata object.
entryTooLarge - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction.Reason
EnvironmentVariablesSource - Enum Class in io.fluxzero.common.application: A PropertySource that resolves property values from system environment variables.
equals(Object) - Method in class io.fluxzero.common.api.Data
equals(Object) - Method in record class io.fluxzero.common.api.tracking.SegmentRange: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.Specificity: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.fluxzero.common.tracking.SimpleTracker
equals(Object) - Method in class io.fluxzero.common.tracking.WebSocketTracker
ERROR - Enum constant in enum class io.fluxzero.common.MessageType: A handler failure in response to a request message or generic system failure.
ErrorHandler<T> - Interface in io.fluxzero.common: Functional interface for handling errors during tasks.
Error Handling - Section in class io.fluxzero.common.api.ResultBatch
ErrorResult - Class in io.fluxzero.common.api: A generic error response returned when a request could not be completed successfully.
ErrorResult() - Constructor for class io.fluxzero.common.api.ErrorResult
escapeFieldName(String) - Static method in class io.fluxzero.common.SearchUtils: Escapes slashes and quotes in field names for safe indexing.
EVENT - Enum constant in enum class io.fluxzero.common.MessageType: A record of something that occurred.
EventBatch - Class in io.fluxzero.common.api.eventsourcing: Represents a batch of serialized events for a specific aggregate.
EventBatch() - Constructor for class io.fluxzero.common.api.eventsourcing.EventBatch
EventBatch.Metric - Class in io.fluxzero.common.api.eventsourcing: A compact metric representation of an EventBatch, used in AppendEvents.Metric.
eventSourcingPath() - Static method in class io.fluxzero.common.ServicePathBuilder: Returns the service path for the event sourcing subsystem.
evict(K, MemoryAwareCacheSupportEviction.Reason) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Removes a value and publishes the supplied eviction reason when the key was present.
evictBefore(K, boolean) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Evicts all ordered keys before the supplied frontier.
Example - Section in annotation interface io.fluxzero.common.serialization.Revision
Example - Section in class io.fluxzero.common.api.eventsourcing.GetEvents
Example - Section in interface io.fluxzero.common.api.HasId
Example - Section in interface io.fluxzero.common.serialization.TypeRegistry
Example: - Section in class io.fluxzero.common.application.ApplicationEnvironmentPropertiesSource
Example: - Section in class io.fluxzero.common.application.SystemPropertiesSource
Example application.properties: - Section in class io.fluxzero.common.application.ApplicationPropertiesSource
Examples - Section in class io.fluxzero.common.ServicePathBuilder
Examples - Section in class io.fluxzero.common.api.search.constraints.BetweenConstraint
Examples - Section in class io.fluxzero.common.api.search.constraints.ExistsConstraint
Examples - Section in class io.fluxzero.common.api.search.constraints.MatchConstraint
Examples - Section in class io.fluxzero.common.search.Document.Path
Examples - Section in interface io.fluxzero.common.api.JsonType
Example usage - Section in enum class io.fluxzero.common.application.EnvironmentVariablesSource
Example usage - Section in interface io.fluxzero.common.Monitored
Example Usage - Section in class io.fluxzero.common.serialization.JsonUtils
Example Use Cases - Section in class io.fluxzero.common.api.search.SortableEntry
Exception Behavior - Section in class io.fluxzero.common.api.ErrorResult
execute(Runnable) - Method in class io.fluxzero.common.DirectExecutorService
executeExpiredTasks() - Method in class io.fluxzero.common.InMemoryTaskScheduler
executeExpiredTasks() - Method in interface io.fluxzero.common.TaskScheduler: Executes any scheduled tasks that are due according to the scheduler's current time.
executeExpiredTasksAsync() - Method in class io.fluxzero.common.InMemoryTaskScheduler
executeExpiredTasksOnce() - Method in class io.fluxzero.common.InMemoryTaskScheduler
exists() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata.PropertyPathMetadata
exists(String...) - Static method in class io.fluxzero.common.api.search.constraints.ExistsConstraint: Creates a constraint that checks for the presence of any of the given paths.
ExistsConstraint - Class in io.fluxzero.common.api.search.constraints: A Constraint that checks whether one or more paths exist in a document.
ExistsConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.ExistsConstraint
expectResult() - Method in interface io.fluxzero.common.handling.HandlerDescriptor: Indicates whether the handler method has a return value.
expectResult() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
expectResult() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
expectResult() - Method in interface io.fluxzero.common.handling.HandlerInvoker: Indicates whether the handler method has a return value.
expectResult() - Method in class io.fluxzero.common.handling.HandlerInvoker.SimpleInvoker
expectResult() - Method in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
expiry - Enum constant in enum class io.fluxzero.common.caching.CacheEviction.Reason: The entry expired due to time-based eviction policy.
expiry - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction.Reason
exponentialBackoff(Duration, Duration) - Static method in class io.fluxzero.common.RetryConfiguration: Creates a capped exponential backoff strategy.
External source integration - Section in class io.fluxzero.common.api.tracking.ClaimSegment
extractMetadata(Map) - Static method in class io.fluxzero.common.search.JacksonInverter

F

Facet - Annotation Interface in io.fluxzero.common.search: Marker annotation on fields and methods that indicates that a property is to be used as facet when indexing a document for search.
FacetConstraint - Class in io.fluxzero.common.api.search.constraints: A constraint that matches documents containing a specific FacetEntry.
FacetConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.FacetConstraint
FacetEntry - Class in io.fluxzero.common.api.search: Represents a single facet field-value pair within a document.
FacetEntry() - Constructor for class io.fluxzero.common.api.search.FacetEntry
FacetStats - Class in io.fluxzero.common.api.search: Represents the count of documents matching a specific facet value.
FacetStats() - Constructor for class io.fluxzero.common.api.search.FacetStats
fallsInRange(int, int[]) - Static method in class io.fluxzero.common.ConsistentHashing: Checks if a given segment index falls within a specified segment range.
fallsInRange(String, int[]) - Static method in class io.fluxzero.common.ConsistentHashing: Checks if the segment computed from the routing key falls within the specified segment range.
fallsInRange(String, int[], int) - Static method in class io.fluxzero.common.ConsistentHashing: Same as ConsistentHashing.fallsInRange(String, int[]), but uses a custom max segment size.
field(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
fieldAnnotation(Field, Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
fields() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
Fields - Section in class io.fluxzero.common.api.keyvalue.StoreValues
Fields - Section in class io.fluxzero.common.api.search.SearchQuery
FieldStats(List, String) - Constructor for class io.fluxzero.common.api.search.DocumentStats.FieldStats: Constructs a FieldStats instance by scanning all numeric entries for a given path.
File Inheritance via @extends - Section in class io.fluxzero.common.serialization.JsonUtils
FileUtils - Class in io.fluxzero.common: Utility class for reading and writing files and classpath resources.
FileUtils() - Constructor for class io.fluxzero.common.FileUtils
filter(List, int[], Position, Tracker) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
Filtering using #contains() - Section in annotation interface io.fluxzero.common.serialization.RegisterType
filterPaths(Predicate) - Method in class io.fluxzero.common.search.Document: Filters document entries by a Document.Path predicate.
filterPredicate(int[], Position, Tracker) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
FINAL_CHUNK - Static variable in interface io.fluxzero.common.api.HasMetadata: Metadata key that marks whether a chunk is the final part of a chunked message.
FIRST_CHUNK - Static variable in interface io.fluxzero.common.api.HasMetadata: Metadata key that marks the first part of a chunked message.
firstChunk() - Method in interface io.fluxzero.common.api.HasMetadata: Determines if the data associated with this metadata is the first part of the data.
firstKey() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
FluxzeroAdditionalPropertiesSource - Class in io.fluxzero.common.application: A PropertySource that loads extra configuration from locations declared through "FLUXZERO_CONFIG_LOCATIONS".
FluxzeroAdditionalPropertiesSource() - Constructor for class io.fluxzero.common.application.FluxzeroAdditionalPropertiesSource: Creates a source backed by the configured additional locations.
FluxzeroPropertiesSource - Class in io.fluxzero.common.application: A PropertySource that loads Fluxzero-specific settings from classpath resources.
FluxzeroPropertiesSource() - Constructor for class io.fluxzero.common.application.FluxzeroPropertiesSource: Creates a source backed by fluxzero.json and fluxzero.properties classpath resources.
forAsyncConsumer(ThrowingFunction) - Static method in class io.fluxzero.common.Backlog: Creates a backlog for an asynchronous consumer with default max batch size and default logging error handler.
forAsyncConsumer(ThrowingFunction, int) - Static method in class io.fluxzero.common.Backlog: Creates a backlog for an asynchronous consumer with custom max batch size and default logging error handler.
forAsyncConsumer(ThrowingFunction, int, ErrorHandler) - Static method in class io.fluxzero.common.Backlog: Creates a backlog for an asynchronous consumer with custom max batch size and error handler.
forceThrow(Throwable) - Static method in class io.fluxzero.common.ObjectUtils: Forces the given throwable to be thrown.
forConsumer(ThrowingConsumer) - Static method in class io.fluxzero.common.Backlog: Creates a new backlog for a synchronous consumer and default batch size and default logging error handler.
forConsumer(ThrowingConsumer, int) - Static method in class io.fluxzero.common.Backlog: Creates a backlog with custom max batch size and default logging error handler.
forConsumer(ThrowingConsumer, int, ErrorHandler) - Static method in class io.fluxzero.common.Backlog: Creates a backlog with custom max batch size and error handler.
forEach(Consumer) - Method in class io.fluxzero.common.DefaultMemoizingBiFunction
forEach(Consumer) - Method in interface io.fluxzero.common.MemoizingBiFunction: Applies the given consumer to all currently cached values.
forEach(Consumer) - Method in class io.fluxzero.common.DefaultMemoizingFunction
forEach(Consumer) - Method in interface io.fluxzero.common.MemoizingFunction: Applies the given consumer to all currently cached values.
forFormat(WebSocketTransportFormat, ObjectMapper) - Static method in class io.fluxzero.common.websocket.WebSocketTransportCodecs: Creates a codec for the supplied format.
format() - Method in interface io.fluxzero.common.websocket.WebSocketTransportCodec: The negotiated format handled by this codec.
formatSortable(Object) - Static method in class io.fluxzero.common.api.search.SortableEntry: Formats the given object into a sortable string depending on its type.
forOrderedAsyncConsumer(ThrowingFunction) - Static method in class io.fluxzero.common.Backlog: Creates a backlog for an asynchronous consumer that starts the next batch only after the previous returned future has completed.
forOrderedAsyncConsumer(ThrowingFunction, int) - Static method in class io.fluxzero.common.Backlog: Creates an ordered async backlog with custom max batch size and default logging error handler.
forOrderedAsyncConsumer(ThrowingFunction, int, ErrorHandler) - Static method in class io.fluxzero.common.Backlog: Creates an ordered async backlog with custom max batch size and error handler.
forPayloadTarget(Class, Function, HandlerMatcher) - Static method in class io.fluxzero.common.handling.DefaultHandler: Creates a handler for methods declared on the message payload itself.
forTarget(Class, Object, HandlerMatcher) - Static method in class io.fluxzero.common.handling.DefaultHandler
fromData(Data) - Method in class io.fluxzero.common.search.JacksonInverter
fromDocument(SerializedDocument) - Static method in class io.fluxzero.common.api.search.bulkupdate.IndexDocument: Creates a bulk index operation from a SerializedDocument.
fromEncryptionKey(String) - Static method in class io.fluxzero.common.encryption.DefaultEncryption
fromFile(Class, String) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the reference point into an object.
fromFile(Class, String, JavaType) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the reference point into an object of the provided type.
fromFile(Class, String, Class) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the reference point into an object of the provided type.
fromFile(Class, String, Function) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the referencePoint into an object of the type specified by the provided type function.
fromFile(String) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the calling class.
fromFile(String...) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes JSON files located relative to the calling class.
fromFile(String, JavaType) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the calling class to an object of the specified type.
fromFile(String, Class) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the calling class to an object of the specified type.
fromFile(String, Function) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the calling class into an object of the type specified by the provided type function.
fromFileAs(String) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the calling class and casts it to type T.
fromFileWith(String, Map) - Static method in class io.fluxzero.common.serialization.JsonUtils: Loads and deserializes a JSON file located relative to the calling class, applies property replacements, and returns the resulting object.
fromJson(byte[]) - Static method in class io.fluxzero.common.serialization.JsonUtils: Deserializes a JSON byte array without a caller-provided target type.
fromJson(byte[], JavaType) - Static method in class io.fluxzero.common.serialization.JsonUtils: Deserializes a JSON byte array into an instance of the specified type.
fromJson(byte[], Class) - Static method in class io.fluxzero.common.serialization.JsonUtils: Deserializes a JSON byte array into an instance of the specified class type.
fromJson(byte[], Type) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts a JSON string to an object of the given type, which may be a ParameterizedType or Class.
fromJson(byte[], Function) - Static method in class io.fluxzero.common.serialization.JsonUtils: Deserializes a JSON byte array into an object of the type specified by the provided type function.
fromJson(MessageType, String, int[], long, Guarantee) - Static method in class io.fluxzero.common.api.tracking.StorePosition
fromJson(String) - Static method in class io.fluxzero.common.serialization.JsonUtils: Deserializes JSON without a caller-provided target type.
fromJson(String, JavaType) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts a JSON string to an object of the given type.
fromJson(String, Class) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts a JSON string to an object of the given class type.
fromJson(String, Type) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts a JSON string to an object of the given type, which may be a ParameterizedType or Class.
fromJson(String, Function) - Static method in class io.fluxzero.common.serialization.JsonUtils: Deserializes a JSON string into an object of the type specified by the provided type function.
fullSegment(long) - Static method in record class io.fluxzero.common.api.tracking.SegmentRange
future() - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy.TrackerRequest

G

gatewayPath(MessageType) - Static method in class io.fluxzero.common.ServicePathBuilder: Returns the gateway path used to publish messages of the given MessageType.
generateNewEncryptionKey() - Static method in class io.fluxzero.common.encryption.DefaultEncryption: Generates a new encryption key using the default encryption mechanism.
GenericTypeResolver - Class in io.fluxzero.common.reflection: Utility class for resolving generic type information in class hierarchies.
GenericTypeResolver() - Constructor for class io.fluxzero.common.reflection.GenericTypeResolver
get() - Method in class io.fluxzero.common.DefaultMemoizingSupplier
get() - Method in interface io.fluxzero.common.ThrowingSupplier: Gets a result.
get(Object) - Method in class io.fluxzero.common.api.Metadata: Retrieves the value associated with the given key from the entries map.
get(Object) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
get(Object) - Method in interface io.fluxzero.common.caching.Cache: Retrieves the value associated with the given id, or null if not found.
get(Object) - Method in enum class io.fluxzero.common.caching.NoOpCache
get(Object, TypeReference) - Method in class io.fluxzero.common.api.Metadata: Retrieves a value associated with the given key, deserializes it to the specified type, and returns it.
get(Object, Class, Function) - Method in class io.fluxzero.common.api.Metadata: Retrieves an object value or maps a raw string value to the requested type.
get(Object, Class) - Method in class io.fluxzero.common.api.Metadata: Retrieves the value associated with the given key and attempts to deserialize it into the specified type.
get(String) - Method in class io.fluxzero.common.api.search.Group: Returns the value associated with the given path in this group.
get(String) - Method in class io.fluxzero.common.application.DecryptingPropertySource: Returns the decrypted value of the given property name.
get(String) - Method in class io.fluxzero.common.application.DefaultPropertySource
get(String) - Method in enum class io.fluxzero.common.application.EnvironmentVariablesSource: Retrieves the value of the given property name from the system environment.
get(String) - Method in class io.fluxzero.common.application.JavaPropertiesSource: Retrieves the value for the given property name.
get(String) - Method in enum class io.fluxzero.common.application.NoOpPropertySource: Always returns null for any requested property name.
get(String) - Method in interface io.fluxzero.common.application.PropertySource: Retrieves the value of a property by name.
get(String) - Method in class io.fluxzero.common.application.SimplePropertySource: Retrieves the value associated with the given property name from the internal map.
get(String, String) - Method in interface io.fluxzero.common.application.PropertySource: Returns the property value, or the given default if not present.
get(K) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
GetAggregateIds - Class in io.fluxzero.common.api.modeling: Request to retrieve all aggregate identifiers associated with a given entity ID.
GetAggregateIds() - Constructor for class io.fluxzero.common.api.modeling.GetAggregateIds
GetAggregateIdsResult - Class in io.fluxzero.common.api.modeling: Response to a GetAggregateIds request, returning a mapping of aggregate IDs to types.
GetAggregateIdsResult() - Constructor for class io.fluxzero.common.api.modeling.GetAggregateIdsResult
getAlgorithm() - Method in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
getAlgorithm() - Method in class io.fluxzero.common.encryption.DefaultEncryption
getAlgorithm() - Method in interface io.fluxzero.common.encryption.Encryption: Returns the name or identifier of the encryption algorithm used.
getAlgorithm() - Method in enum class io.fluxzero.common.encryption.NoOpEncryption
getAllInterfaces(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns all interfaces implemented by the supplied type, including interfaces inherited through superclasses and parent interfaces.
getAllMethods(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedFields(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedFields(Object, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedMethods(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedMethods(Object, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedProperties(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedProperty(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedProperty(Object, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedPropertyInvoker(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedPropertyName(Object, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedPropertyValue(Object, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotatedPropertyValues(Object, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotation(AnnotatedElement, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotation(Executable) - Method in class io.fluxzero.common.handling.HandlerConfiguration: Retrieves the configured method annotation on the given method, if present.
getAnnotationAs(Annotation, Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotationAs(Class, Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotationAs(AnnotatedElement, Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getAnnotationAttribute(Annotation, String, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns a single annotation attribute value when it exists and matches the requested type.
getAnnotationAttributes(Annotation) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns all no-argument attributes declared by an annotation instance.
getAnnotations(AnnotatedElement) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns the direct annotations present on an annotated element.
getBatch(int[], Position, int) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
getBatch(Tracker) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
getBatch(Tracker) - Method in interface io.fluxzero.common.tracking.TrackingStrategy: Requests a new batch of messages for the given tracker.
getBatch(Tracker, DefaultTrackingStrategy.TrackerRequest) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
getBatch(Long, int) - Method in interface io.fluxzero.common.tracking.MessageStore: Retrieves a batch of messages starting from the given lastIndex (exclusive).
getBatch(Long, int, boolean) - Method in interface io.fluxzero.common.tracking.MessageStore: Retrieves a batch of messages starting from the given minIndex.
getBatch(Long, int, boolean, long) - Method in interface io.fluxzero.common.tracking.MessageStore: Retrieves a batch of messages starting from the given minIndex, limiting both message count and serialized payload bytes.
getBatch(Long, int, long) - Method in interface io.fluxzero.common.tracking.MessageStore: Retrieves a batch of messages starting from the given lastIndex (exclusive), limiting both message count and serialized payload bytes.
getBefore() - Method in class io.fluxzero.common.api.search.SearchQuery
getBoolean(String) - Method in interface io.fluxzero.common.application.PropertySource: Returns the value of the property as a boolean.
getBoolean(String, boolean) - Method in interface io.fluxzero.common.application.PropertySource: Returns the value of the property as a boolean, falling back to a default if not present.
getBytes() - Method in class io.fluxzero.common.api.eventsourcing.AppendEvents.Metric: The total number of bytes in the data across all messages within all batches.
getBytes() - Method in class io.fluxzero.common.api.eventsourcing.EventBatch: Calculates the total number of bytes in the data across all messages within the batch.
getBytes() - Method in class io.fluxzero.common.api.search.BulkUpdateDocuments
getBytes() - Method in class io.fluxzero.common.api.SerializedMessage: Returns the length of bytes in the serialized payload.
getBytes() - Method in class io.fluxzero.common.api.tracking.MessageBatch: Calculates the total number of bytes in the data across all messages within the batch.
getBytes(ByteBuffer) - Static method in class io.fluxzero.common.ObjectUtils: Extracts the byte array from a ByteBuffer.
getCacheKey(HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Returns the complete key without creating the message when the planner supports lazy input.
getCacheKey(M) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Returns a key containing every message property that can affect the result of HandlerMethodPlanner.prepare(Object).
getCacheKey(M) - Method in interface io.fluxzero.common.handling.KeyedParameterResolver: Returns an immutable, equality-stable and preferably low-cardinality applicability key.
getCallerClass() - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getClientId() - Method in class io.fluxzero.common.tracking.SimpleTracker
getClientId() - Method in interface io.fluxzero.common.tracking.Tracker
getClientSdkVersion(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
getClientSessionId(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
getCollection() - Method in interface io.fluxzero.common.api.search.BulkUpdate: The name of the collection to which this document belongs.
getCollectionElementType(AccessibleObject) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getCollectionElementType(Type) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getConsumerName() - Method in interface io.fluxzero.common.tracking.Tracker
getContent(Class, String) - Static method in class io.fluxzero.common.serialization.JsonUtils
getContent(URI) - Static method in class io.fluxzero.common.serialization.JsonUtils
getDeadline() - Method in interface io.fluxzero.common.tracking.Tracker
getDefaultConstructor(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns the default constructor declared by the supplied type, if present.
getDocument() - Method in class io.fluxzero.common.api.search.SerializedDocument: Returns the serialized representation of the document.
GetDocument - Class in io.fluxzero.common.api.search: Request to fetch a single document from the search store by ID and collection.
GetDocument() - Constructor for class io.fluxzero.common.api.search.GetDocument
GetDocumentResult - Class in io.fluxzero.common.api.search: Result returned in response to a GetDocument request.
GetDocumentResult() - Constructor for class io.fluxzero.common.api.search.GetDocumentResult
GetDocumentResult.Metric - Class in io.fluxzero.common.api.search: Lightweight structure for representing GetDocumentResult in Fluxzero metrics logs.
GetDocuments - Class in io.fluxzero.common.api.search: Request to fetch multiple documents from the search store by collection and their IDs.
GetDocuments() - Constructor for class io.fluxzero.common.api.search.GetDocuments
GetDocumentsResult - Class in io.fluxzero.common.api.search: Result returned in response to a GetDocuments request.
GetDocumentsResult() - Constructor for class io.fluxzero.common.api.search.GetDocumentsResult
GetDocumentsResult.Metric - Class in io.fluxzero.common.api.search: Lightweight structure for representing GetDocumentsResult in Fluxzero metrics logs.
GetDocumentStats - Class in io.fluxzero.common.api.search: Request to compute statistics on documents that match a given SearchQuery.
GetDocumentStats() - Constructor for class io.fluxzero.common.api.search.GetDocumentStats
GetDocumentStatsResult - Class in io.fluxzero.common.api.search: Response to a GetDocumentStats request.
GetDocumentStatsResult() - Constructor for class io.fluxzero.common.api.search.GetDocumentStatsResult
GetDocumentStatsResult.Metric - Class in io.fluxzero.common.api.search: Compact summary of the result, used for internal monitoring purposes.
getEnclosingClass(AccessibleObject) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getEncryptionKey() - Method in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
getEncryptionKey() - Method in class io.fluxzero.common.encryption.DefaultEncryption
getEncryptionKey() - Method in interface io.fluxzero.common.encryption.Encryption: Returns the encryption key used by this implementation.
getEncryptionKey() - Method in enum class io.fluxzero.common.encryption.NoOpEncryption
getEnd() - Method in class io.fluxzero.common.api.search.SerializedDocument: Returns the adjusted end timestamp.
getEnd() - Method in class io.fluxzero.common.search.Document
getEntries() - Method in class io.fluxzero.common.api.Metadata: Retrieves a map of entries where the keys and values are strings.
getEntryAtPath(String) - Method in class io.fluxzero.common.search.Document: Retrieves the first matching Document.Entry for a given query path.
getEntryType(JsonToken) - Method in class io.fluxzero.common.search.JacksonInverter
getEnvironment() - Static method in class io.fluxzero.common.application.ApplicationEnvironmentPropertiesSource: Attempts to resolve the active environment using environment variables or system properties.
GetEvents - Class in io.fluxzero.common.api.eventsourcing: A request to fetch stored events for a specific aggregate in an event-sourced system.
GetEvents() - Constructor for class io.fluxzero.common.api.eventsourcing.GetEvents
GetEventsResult - Class in io.fluxzero.common.api.eventsourcing: Response to a GetEvents request, returning a batch of events for an aggregate.
GetEventsResult() - Constructor for class io.fluxzero.common.api.eventsourcing.GetEventsResult
GetEventsResult.Metric - Class in io.fluxzero.common.api.eventsourcing: Lightweight metric representation of a GetEventsResult used for monitoring.
getFacets(Object) - Method in class io.fluxzero.common.search.JacksonInverter
getFacets(AccessibleObject, Object) - Method in class io.fluxzero.common.search.JacksonInverter
getFacetsStream(Object) - Method in class io.fluxzero.common.search.JacksonInverter
GetFacetStats - Class in io.fluxzero.common.api.search: Request to retrieve aggregated counts for all facet fields across documents matching the given SearchQuery.
GetFacetStats() - Constructor for class io.fluxzero.common.api.search.GetFacetStats
GetFacetStatsResult - Class in io.fluxzero.common.api.search: Result returned for a GetFacetStats request.
GetFacetStatsResult() - Constructor for class io.fluxzero.common.api.search.GetFacetStatsResult
GetFacetStatsResult.Metric - Class in io.fluxzero.common.api.search: Lightweight summary of the facet statistics result, used for internal metric tracking.
getField(Class, String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getFieldAnnotation(Field, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getFieldValue(String, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getFile(Class, String) - Static method in class io.fluxzero.common.FileUtils: Gets a file from a classpath location using a reference class.
getFirstTypeArgument(Type) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getFormat() - Method in class io.fluxzero.common.api.Data: Returns the effective format for the data, defaulting to Data.JSON_FORMAT if format is null or "json".
getGenericPropertyType(AccessibleObject) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getGenericType(Class, Class) - Static method in class io.fluxzero.common.reflection.GenericTypeResolver
getGenericType(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getGlobMatcher(String) - Static method in class io.fluxzero.common.SearchUtils: Converts a standard POSIX Shell globbing pattern into a regular expression pattern.
getGuarantee() - Method in class io.fluxzero.common.api.Command: Indicates the delivery guarantee required for this command.
getGuarantee() - Method in class io.fluxzero.common.api.keyvalue.StoreValueIfAbsent
getGuarantee() - Method in class io.fluxzero.common.api.keyvalue.StoreValuesAndWait: Deprecated.
getGuarantee() - Method in class io.fluxzero.common.api.publishing.Append
getGuarantee() - Method in class io.fluxzero.common.api.publishing.Truncate
getHandlerMethodOrNull(M) - Method in class io.fluxzero.common.handling.DefaultHandler
getHandlerMethodOrNull(M) - Method in class io.fluxzero.common.handling.Handler.DelegatingHandler
getHandlerMethodOrNull(M) - Method in interface io.fluxzero.common.handling.Handler: Returns a reusable HandlerMethod capable of processing the given message, or null when unavailable.
getHandlerMethodPlanner() - Method in class io.fluxzero.common.handling.DefaultHandler
getHandlerMethodPlanner() - Method in class io.fluxzero.common.handling.Handler.DelegatingHandler
getHandlerMethodPlanner() - Method in interface io.fluxzero.common.handling.Handler: Returns the planner used to select and prepare this handler's methods.
getHandlerMethodPlanOrNull(M) - Method in class io.fluxzero.common.handling.DefaultHandler
getHandlerMethodPlanOrNull(M) - Method in class io.fluxzero.common.handling.Handler.DelegatingHandler
getHandlerMethodPlanOrNull(M) - Method in interface io.fluxzero.common.handling.Handler: Returns a reusable plan for the handler method selected for this message.
getId() - Method in interface io.fluxzero.common.api.HasId: Returns the stringified identifier of this object.
getId() - Method in interface io.fluxzero.common.api.search.BulkUpdate: The unique identifier of the document within the collection.
getIndex(int) - Method in class io.fluxzero.common.api.tracking.Position: Returns the last known index for a specific segment.
getInputCacheKey(Parameter, Annotation, HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerInputResolver: Returns a key containing every input property that can affect whether this resolver matches the parameter and how the parameter value is resolved.
getInteger(String) - Method in interface io.fluxzero.common.application.PropertySource: Returns the value of the property as an integer.
getInteger(String, Integer) - Method in interface io.fluxzero.common.application.PropertySource: Returns the value of the property as an integer, falling back to a default if not present.
getInvoker(Object, M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
getInvoker(Object, M) - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
getInvoker(M) - Method in class io.fluxzero.common.handling.DefaultHandler
getInvoker(M) - Method in interface io.fluxzero.common.handling.Handler: Returns a HandlerInvoker capable of processing the given message, if available.
getInvoker(T, M) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Attempts to resolve a HandlerInvoker for the given target instance and message.
getInvokerOrNull(Object, M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
getInvokerOrNull(Object, M) - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
getInvokerOrNull(M) - Method in class io.fluxzero.common.handling.DefaultHandler
getInvokerOrNull(M) - Method in interface io.fluxzero.common.handling.Handler: Returns a HandlerInvoker capable of processing the given message, or null when unavailable.
getInvokerOrNull(T, M) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Attempts to resolve a HandlerInvoker for the given target instance and message.
getKotlinParameterName(Parameter) - Static method in class io.fluxzero.common.reflection.KotlinReflectionUtils: Returns the Kotlin source parameter name for a Java reflection parameter.
getLastTrackerIndex() - Method in interface io.fluxzero.common.tracking.Tracker
getLeastSpecificAllowedClass(Executable, Class) - Method in interface io.fluxzero.common.handling.MessageFilter: Provides the least specific class type that is allowed to match this filter for a given method and annotation.
getMatchingEntries(Predicate) - Method in class io.fluxzero.common.search.Document: Retrieves a stream of entries that match the provided path predicate.
getMaxBytes() - Method in interface io.fluxzero.common.tracking.Tracker
getMaxSize() - Method in interface io.fluxzero.common.tracking.Tracker
getMechanism() - Method in class io.fluxzero.common.serialization.GlobalTypeIdResolver
getMember() - Method in interface io.fluxzero.common.reflection.MemberInvoker
getMemberAnnotation(Class, String, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getMessage() - Method in interface io.fluxzero.common.handling.HandlerInput: Returns the message that contains the payload, creating it first when necessary.
getMessageIfAvailable() - Method in interface io.fluxzero.common.handling.HandlerInput: Returns the message if it is already available.
getMessageStore() - Method in interface io.fluxzero.common.tracking.HasMessageStore: Returns the associated MessageStore instance.
getMessageStore() - Method in class io.fluxzero.common.tracking.MessageLogMaintenance: Returns the message store maintained by this instance.
getMessageStore() - Method in interface io.fluxzero.common.tracking.MessageStore: Returns the current instance as the MessageStore.
getMetadata() - Method in interface io.fluxzero.common.api.HasMetadata: Returns the Metadata associated with this object.
getMethod() - Method in interface io.fluxzero.common.handling.HandlerDescriptor: The Executable representing the handler method (can be a static or instance Method or Constructor).
getMethod() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
getMethod() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
getMethod() - Method in interface io.fluxzero.common.handling.HandlerInvoker: The Executable representing the handler method (can be a static or instance Method or Constructor).
getMethod() - Method in class io.fluxzero.common.handling.HandlerInvoker.SimpleInvoker
getMethod() - Method in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
getMethod(Class, String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getMethodAnnotation() - Method in interface io.fluxzero.common.handling.HandlerDescriptor: Retrieves the configured handler annotation from the handler method, if present.
getMethodAnnotation() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
getMethodAnnotation() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
getMethodAnnotation() - Method in interface io.fluxzero.common.handling.HandlerInvoker: Retrieves a specific annotation from the handler method, if present.
getMethodAnnotation() - Method in class io.fluxzero.common.handling.HandlerInvoker.SimpleInvoker
getMethodAnnotation() - Method in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
getMethodAnnotation(Executable, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getMethodAnnotations(Executable, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getMethodOverrideHierarchy(Method) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getName(AccessibleObject) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getOptionally(Object) - Method in class io.fluxzero.common.api.Metadata: Retrieves the value associated with the provided key, if it exists, wrapped in an Optional.
getOptionally(Object, TypeReference) - Method in class io.fluxzero.common.api.Metadata: Retrieves an object associated with the given key, deserializes it to the specified type, and returns it wrapped in an Optional.
getOptionally(Object, Class) - Method in class io.fluxzero.common.api.Metadata: Retrieves an object associated with the given key, attempts to deserialize it to the specified type, and returns it wrapped in an Optional.
getOrDefault(Object, String) - Method in class io.fluxzero.common.api.Metadata: Retrieves the value mapped to the specified key in the entries map.
getOrDefault(Object, T) - Method in interface io.fluxzero.common.caching.Cache: Retrieves the value associated with the given id, or returns the specified default if not present.
getOriginalRevision() - Method in class io.fluxzero.common.api.SerializedMessage: Returns the original revision of the payload object.
getOrThrow(Object, Supplier) - Method in class io.fluxzero.common.api.Metadata: Retrieves the value associated with the specified key or throws an exception provided by the given error supplier if the key does not exist or has a null value.
getOutputType() - Method in class io.fluxzero.common.search.JacksonInverter
getOutputType() - Method in class io.fluxzero.common.serialization.AbstractConverter
getOutputType() - Method in interface io.fluxzero.common.serialization.Converter
getPackageAndParentPackages(Package) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPackageAnnotation(Package, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPackageAnnotations(Package) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPackageAnnotations(Package, boolean) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getParameterIndex(Parameter) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getParameterName(Parameter) - Method in class io.fluxzero.common.reflection.ParameterRegistry: Retrieves the name of a specific method parameter.
getParameterNames(Executable) - Method in class io.fluxzero.common.reflection.ParameterRegistry: Retrieves the parameter names for a given method.
getParameterOverrideHierarchy(Parameter) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPaths() - Method in class io.fluxzero.common.api.search.constraints.PathConstraint: Retrieves a list of paths associated with this constraint.
getPayload() - Method in interface io.fluxzero.common.handling.HandlerInput: Returns the payload that is being handled.
GetPosition - Class in io.fluxzero.common.api.tracking: Query to retrieve the current tracked Position for a given consumer and MessageType.
GetPosition() - Constructor for class io.fluxzero.common.api.tracking.GetPosition
GetPositionResult - Class in io.fluxzero.common.api.tracking: Response to a GetPosition request, containing the current tracked position for a specific consumer and MessageType.
GetPositionResult() - Constructor for class io.fluxzero.common.api.tracking.GetPositionResult
getPositionStore() - Method in class io.fluxzero.common.tracking.MessageLogMaintenance: Returns the position store maintained by this instance.
getPreferredCompressionAlgorithm(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities: Returns the most preferred compression algorithm advertised via request headers, if available.
getPreferredTransportFormat(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities: Returns the most preferred websocket transport format advertised via request headers, if available.
getPrimaryConstructor(Class) - Static method in class io.fluxzero.common.reflection.KotlinReflectionUtils: Returns the Java reflection constructor that corresponds to a Kotlin class' primary constructor.
getPriority(Annotation) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
getProcessingDuration(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Returns how long the given tracker has been active.
getPropertyAnnotation(String, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPropertyName(AccessibleObject) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPropertyPathMetadata(Class, String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPropertyType(AccessibleObject) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getPurgeDelay() - Method in class io.fluxzero.common.tracking.SimpleTracker
getPurgeDelay() - Method in interface io.fluxzero.common.tracking.Tracker
GetRelationships - Class in io.fluxzero.common.api.modeling: Request to retrieve all aggregate relationships for a given entity ID.
GetRelationships() - Constructor for class io.fluxzero.common.api.modeling.GetRelationships
GetRelationshipsResult - Class in io.fluxzero.common.api.modeling: Response to a GetRelationships request, containing all known relationships for a given entity ID.
GetRelationshipsResult() - Constructor for class io.fluxzero.common.api.modeling.GetRelationshipsResult
getReplacedSessionId(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
getRequestId() - Method in interface io.fluxzero.common.api.RequestResult: The requestId of the original Request this result corresponds to.
getRequestReceivedTimestamp() - Method in class io.fluxzero.common.api.AbstractRequestResult: The timestamp (in epoch milliseconds) when the Fluxzero Runtime received the original request.
getRequestReceivedTimestamp() - Method in interface io.fluxzero.common.api.RequestResult: The timestamp (in epoch milliseconds) when the Fluxzero Runtime received the original request.
getResourceBaseUri(String) - Static method in class io.fluxzero.common.FileUtils: Retrieves the base URI of a given resource path.
getResourceBaseUri(String, ClassLoader) - Static method in class io.fluxzero.common.FileUtils: Retrieves the base URI of a given resource path.
getResponseQueuedTimestamp() - Method in class io.fluxzero.common.api.AbstractRequestResult: The timestamp (in epoch milliseconds) when the Fluxzero Runtime queued this response for websocket delivery.
getResponseQueuedTimestamp() - Method in interface io.fluxzero.common.api.RequestResult: The timestamp (in epoch milliseconds) when the Fluxzero Runtime queued this response for websocket delivery.
getResponseSendStartTimestamp() - Method in class io.fluxzero.common.api.AbstractRequestResult: The timestamp (in epoch milliseconds) just before the Fluxzero Runtime encoded and sent this response.
getResponseSendStartTimestamp() - Method in interface io.fluxzero.common.api.RequestResult: The timestamp (in epoch milliseconds) just before the Fluxzero Runtime encoded and sent this response.
getRevision() - Method in class io.fluxzero.common.api.SerializedMessage
getRevision() - Method in interface io.fluxzero.common.api.SerializedObject: Returns the revision of the serialized object.
getRuntimeSessionId(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
getRuntimeVersion(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
GetSchedule - Class in io.fluxzero.common.api.scheduling: Request to retrieve a scheduled message by its GetSchedule.scheduleId.
GetSchedule() - Constructor for class io.fluxzero.common.api.scheduling.GetSchedule
getScheduledDeadlines() - Method in class io.fluxzero.common.InMemoryTaskScheduler
GetScheduleResult - Class in io.fluxzero.common.api.scheduling: Response to a GetSchedule request, containing the matching SerializedSchedule, if found.
GetScheduleResult() - Constructor for class io.fluxzero.common.api.scheduling.GetScheduleResult
GetScheduleResult.Metric - Class in io.fluxzero.common.api.scheduling: Metric payload used for internal monitoring and logging.
GetSearchCollections - Class in io.fluxzero.common.api.search: Request to retrieve existing regular search collections and audit trails.
GetSearchCollections() - Constructor for class io.fluxzero.common.api.search.GetSearchCollections
GetSearchCollectionsResult - Class in io.fluxzero.common.api.search: Response to a GetSearchCollections request.
GetSearchCollectionsResult() - Constructor for class io.fluxzero.common.api.search.GetSearchCollectionsResult
GetSearchCollectionsResult.Metric - Class in io.fluxzero.common.api.search: Compact result summary used for metrics.
GetSearchHistogram - Class in io.fluxzero.common.api.search: Request to compute a time-based histogram over documents that match a given query.
GetSearchHistogram() - Constructor for class io.fluxzero.common.api.search.GetSearchHistogram
GetSearchHistogramResult - Class in io.fluxzero.common.api.search: Result of a GetSearchHistogram request.
GetSearchHistogramResult() - Constructor for class io.fluxzero.common.api.search.GetSearchHistogramResult
getSegment(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Returns the segment range assigned to the tracker.
getSelectedCompressionAlgorithm(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
getSelectedTransportFormat(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
getSimpleName(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getSimpleName(Package) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getSimpleName(String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getSize() - Method in class io.fluxzero.common.api.eventsourcing.AppendEvents.Metric: The size of the metric, representing the number of events within all batches.
getSize() - Method in class io.fluxzero.common.api.eventsourcing.EventBatch: Returns the number of events in this batch.
getSize() - Method in class io.fluxzero.common.api.publishing.Append
getSize() - Method in class io.fluxzero.common.api.search.BulkUpdateDocuments
getSize() - Method in class io.fluxzero.common.api.search.IndexDocuments
getSize() - Method in class io.fluxzero.common.api.tracking.MessageBatch: Returns the number of messages contained in this batch.
getSortableEntries(Object) - Method in class io.fluxzero.common.search.JacksonInverter
getSortableEntries(AccessibleObject, Object) - Method in class io.fluxzero.common.search.JacksonInverter
getSortableEntries(Predicate) - Method in class io.fluxzero.common.search.Document: Retrieves a stream of SortableEntry objects from the document's indexes that match the provided path predicate.
getSortables(Object) - Method in class io.fluxzero.common.search.JacksonInverter
getSummary() - Method in class io.fluxzero.common.search.Document: Retrieves the summary of the document or null if no summary is available.
getSupportedCompressionAlgorithms(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities: Extracts the ordered list of compression algorithms from websocket request headers.
getSupportedSourceVersion() - Method in class io.fluxzero.common.serialization.TypeRegistryProcessor
getSupportedTransportFormats(Map) - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities: Extracts the ordered list of websocket transport formats from websocket request headers.
getTargetClass() - Method in class io.fluxzero.common.handling.DefaultHandler
getTargetClass() - Method in class io.fluxzero.common.handling.Handler.DelegatingHandler
getTargetClass() - Method in interface io.fluxzero.common.handling.Handler: Returns the class of the handler's target object.
getTargetClass() - Method in interface io.fluxzero.common.handling.HandlerDescriptor: The target class that contains the handler method.
getTargetClass() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
getTargetClass() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
getTargetClass() - Method in interface io.fluxzero.common.handling.HandlerInvoker: The target class that contains the handler method.
getTargetClass() - Method in class io.fluxzero.common.handling.HandlerInvoker.SimpleInvoker
getTargetClass() - Method in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
getter(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
getTimestamp() - Method in interface io.fluxzero.common.api.RequestResult: The timestamp (in epoch milliseconds) when this result was generated.
getTraceEntries() - Method in class io.fluxzero.common.api.Metadata: Retrieves a map containing only the entries from the metadata whose keys start with the prefix "$trace.".
getTrackerId() - Method in class io.fluxzero.common.tracking.SimpleTracker
getTrackerId() - Method in interface io.fluxzero.common.tracking.Tracker
getTrackers() - Method in class io.fluxzero.common.tracking.TrackerCluster: Returns an unmodifiable view of the current set of trackers.
getTrackingStrategy() - Method in class io.fluxzero.common.tracking.MessageLogMaintenance: Returns the tracking strategy whose active trackers are coordinated by this instance.
getType() - Method in class io.fluxzero.common.api.search.bulkupdate.DeleteDocument
getType() - Method in interface io.fluxzero.common.api.search.BulkUpdate: Indicates the operation type: index, indexIfNotExists, or delete.
getType() - Method in class io.fluxzero.common.api.search.bulkupdate.IndexDocument
getType() - Method in class io.fluxzero.common.api.search.bulkupdate.IndexDocumentIfNotExists
getType() - Method in class io.fluxzero.common.api.SerializedMessage
getType() - Method in interface io.fluxzero.common.api.SerializedObject: Returns the type identifier for the serialized payload.
getTypeAnnotation(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getTypeAnnotations(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getTypeArgument(Type, int) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getTypeArguments(Type) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getTypeFilter() - Method in interface io.fluxzero.common.tracking.Tracker: Returns a predicate for filtering messages based on their type (class name).
getTypeMetadata(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getTypeName(String) - Method in class io.fluxzero.common.serialization.DefaultTypeRegistry
getTypeName(String) - Method in enum class io.fluxzero.common.serialization.NoOpTypeRegistry
getTypeName(String) - Method in interface io.fluxzero.common.serialization.TypeRegistry: Returns the fully qualified class name associated with the given alias or type key.
getValue() - Method in class io.fluxzero.common.api.Data: Returns the deserialized value.
getValue(AccessibleObject, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
getValue(AccessibleObject, Object, boolean) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
GetValue - Class in io.fluxzero.common.api.keyvalue: Request to retrieve a value from the legacy key-value store.
GetValue() - Constructor for class io.fluxzero.common.api.keyvalue.GetValue
GetValueResult - Class in io.fluxzero.common.api.keyvalue: Response to a GetValue request, returning the value associated with the given key.
GetValueResult() - Constructor for class io.fluxzero.common.api.keyvalue.GetValueResult
GetValueResult.Metric - Class in io.fluxzero.common.api.keyvalue
getZone() - Method in class io.fluxzero.common.DelegatingClock
GlobalTypeIdResolver - Class in io.fluxzero.common.serialization
GlobalTypeIdResolver() - Constructor for class io.fluxzero.common.serialization.GlobalTypeIdResolver
Group - Class in io.fluxzero.common.api.search: Represents a group key for aggregating documents in DocumentStats.
Group(Map) - Constructor for class io.fluxzero.common.api.search.Group
Guarantee - Enum Class in io.fluxzero.common: Represents a delivery or completion guarantee for messages or state changes in Fluxzero.
GZIP - Enum constant in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: GZIP compression using standard Java APIs.

H

handleError(Throwable, T) - Method in interface io.fluxzero.common.ErrorHandler: Handles the given Throwable in the context of the provided value.
Handler<M> - Interface in io.fluxzero.common.handling: Represents a container for a message handler and the mechanism to resolve a HandlerInvoker for a given message.
Handler.DelegatingHandler<M> - Class in io.fluxzero.common.handling: Abstract base class for Handler implementations that delegate to another handler.
Handler Architecture - Section in interface io.fluxzero.common.handling.Handler
HandlerConfiguration<M> - Class in io.fluxzero.common.handling: Configuration object used to define how message handler methods are selected and filtered for a given message type.
HandlerConfiguration() - Constructor for class io.fluxzero.common.handling.HandlerConfiguration
HandlerDescriptor - Interface in io.fluxzero.common.handling: Describes the handler method that is involved in a handling operation.
HandlerFilter - Interface in io.fluxzero.common.handling: Represents a predicate used to determine whether a given method should be considered a valid message handler.
HandlerInput<M> - Interface in io.fluxzero.common.handling: Provides the input for a prepared handler invocation.
HandlerInputResolver<M> - Interface in io.fluxzero.common.handling: Optional extension of ParameterResolver for resolving handler parameters from a HandlerInput.
HandlerInputResolver.Resolution<M> - Record Class in io.fluxzero.common.handling: Describes what a resolver decided for one handler parameter.
HandlerInspector - Class in io.fluxzero.common.handling: Utility for inspecting and constructing handler components from annotated methods.
HandlerInspector() - Constructor for class io.fluxzero.common.handling.HandlerInspector
HandlerInspector.MethodHandlerMatcher<M> - Class in io.fluxzero.common.handling: A matcher that encapsulates metadata and resolution logic for a single handler method or constructor.
HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker - Class in io.fluxzero.common.handling
HandlerInspector.MethodHandlerMatcher.Specificity - Record Class in io.fluxzero.common.handling
HandlerInspector.ObjectHandlerMatcher<M> - Class in io.fluxzero.common.handling: A composite HandlerMatcher that delegates to a list of individual matchers.
HandlerInvoker - Interface in io.fluxzero.common.handling: Represents an invocable handler method.
HandlerInvoker.DelegatingHandlerInvoker - Class in io.fluxzero.common.handling: A HandlerInvoker that delegates all behavior to another instance.
HandlerInvoker.SimpleInvoker - Class in io.fluxzero.common.handling: A simple invoker backed by a Callable, typically used for test utilities or framework-internal logic.
HandlerMatcher<T,M> - Interface in io.fluxzero.common.handling: Defines the logic to determine whether a given target object can handle a message, and how to invoke it.
HandlerMethod<M> - Interface in io.fluxzero.common.handling: A reusable, target-bound handler method.
HandlerMethod.DelegatingHandlerMethod<M> - Class in io.fluxzero.common.handling: A HandlerMethod that delegates all behavior to another instance.
HandlerMethodApplicability<M> - Record Class in io.fluxzero.common.handling: Describes whether a handler method applies to a group of equivalent inputs and, when it does, how to invoke it.
HandlerMethodApplicability(Object, boolean, HandlerMethodPreparation) - Constructor for record class io.fluxzero.common.handling.HandlerMethodApplicability: Creates an instance of a HandlerMethodApplicability record class.
HandlerMethodPlan<M> - Interface in io.fluxzero.common.handling: A reusable plan for invoking one already selected handler method.
HandlerMethodPlanner<M> - Interface in io.fluxzero.common.handling: Selects and prepares a handler method so that the result can be reused for equivalent inputs.
HandlerMethodPreparation<M> - Record Class in io.fluxzero.common.handling: The outcome of trying to prepare a handler method for repeated invocation.
HandlerMethodPreparation(HandlerMethodPreparation.Status, HandlerMethodPlan) - Constructor for record class io.fluxzero.common.handling.HandlerMethodPreparation: Creates an instance of a HandlerMethodPreparation record class.
HandlerMethodPreparation.Status - Enum Class in io.fluxzero.common.handling: Possible outcomes of preparing a handler method.
Handling - Section in class io.fluxzero.common.api.scheduling.Schedule
has(Class, Method) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
has(Class, Parameter) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
HasDocument - Class in io.fluxzero.common.api.search: A request to check whether a document exists in a given collection.
HasDocument() - Constructor for class io.fluxzero.common.api.search.HasDocument
hasHandlerMethods(Class, HandlerConfiguration) - Static method in class io.fluxzero.common.handling.HandlerInspector: Returns whether the given class contains at least one method or constructor that matches the handler configuration.
hashCode() - Method in class io.fluxzero.common.api.Data
hashCode() - Method in record class io.fluxzero.common.api.tracking.SegmentRange: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.Specificity: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Returns a hash code value for this object.
hashCode() - Method in class io.fluxzero.common.tracking.SimpleTracker
hashCode() - Method in class io.fluxzero.common.tracking.WebSocketTracker
HasId - Interface in io.fluxzero.common.api: Interface for exposing a string-based representation of an object's identifier.
HasMessageStore - Interface in io.fluxzero.common.tracking: Interface for components that expose a MessageStore.
HasMetadata - Interface in io.fluxzero.common.api: Marker interface for objects that carry associated Metadata.
hasMissedDeadline() - Method in interface io.fluxzero.common.tracking.Tracker
hasNonDefaultAnnotationAttribute(Annotation, String) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns whether an annotation attribute has a value that differs from its declared default.
hasPathConstraint() - Method in interface io.fluxzero.common.api.search.Constraint: Indicates whether this constraint targets specific paths in the document.
hasPathConstraint() - Method in class io.fluxzero.common.api.search.constraints.AllConstraint
hasPathConstraint() - Method in class io.fluxzero.common.api.search.constraints.AnyConstraint
hasPathConstraint() - Method in class io.fluxzero.common.api.search.constraints.FacetConstraint: This constraint does not apply to specific document paths, so this always returns false.
hasPathConstraint() - Method in class io.fluxzero.common.api.search.constraints.NotConstraint
hasPathConstraint() - Method in class io.fluxzero.common.api.search.constraints.PathConstraint
hasPathConstraint() - Method in class io.fluxzero.common.api.search.NoOpConstraint: Always returns false, as this constraint is not tied to any document path.
hasProperty(String, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
hasReturnType(Executable) - Static method in class io.fluxzero.common.reflection.ReflectionUtils

I

identityFunction - Static variable in class io.fluxzero.common.search.Document
idFromValue(Object) - Method in class io.fluxzero.common.serialization.GlobalTypeIdResolver
idFromValueAndType(Object, Class) - Method in class io.fluxzero.common.serialization.GlobalTypeIdResolver
ifClass(Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Determines and returns the Class of the provided object if it is either an instance of Class or a Kotlin class that can be converted using Kotlin reflection utilities.
ifTrue(boolean) - Static method in class io.fluxzero.common.ObjectUtils: Returns a consumer that runs the task only if check is true.
ignoreSegment() - Method in class io.fluxzero.common.tracking.SimpleTracker
ignoreSegment() - Method in interface io.fluxzero.common.tracking.Tracker
Important Notes - Section in class io.fluxzero.common.api.eventsourcing.DeleteEvents
index - Enum constant in enum class io.fluxzero.common.api.search.BulkUpdate.Type
index() - Method in record class io.fluxzero.common.api.tracking.SegmentRange: Returns the value of the index record component.
IndexDocument - Class in io.fluxzero.common.api.search.bulkupdate: A bulk update operation that indexes (inserts or replaces) a document in the store.
IndexDocument() - Constructor for class io.fluxzero.common.api.search.bulkupdate.IndexDocument
IndexDocumentIfNotExists - Class in io.fluxzero.common.api.search.bulkupdate: A bulk update operation that indexes a document only if it does not already exist in the store.
IndexDocumentIfNotExists() - Constructor for class io.fluxzero.common.api.search.bulkupdate.IndexDocumentIfNotExists
IndexDocuments - Class in io.fluxzero.common.api.search: Command used to index a collection of SerializedDocument instances in the search store.
IndexDocuments() - Constructor for class io.fluxzero.common.api.search.IndexDocuments
IndexDocuments.Metric - Class in io.fluxzero.common.api.search
indexIfNotExists - Enum constant in enum class io.fluxzero.common.api.search.BulkUpdate.Type
init(ProcessingEnvironment) - Method in class io.fluxzero.common.serialization.TypeRegistryProcessor
InMemoryPositionStore - Class in io.fluxzero.common.tracking
InMemoryPositionStore() - Constructor for class io.fluxzero.common.tracking.InMemoryPositionStore
InMemoryTaskScheduler - Class in io.fluxzero.common: An in-memory implementation of the TaskScheduler interface, enabling scheduling and execution of tasks in a virtualized time environment.
InMemoryTaskScheduler() - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(int) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(int, String) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(int, String, Clock) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(int, String, Clock, ExecutorService) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(int, String, Clock, ExecutorService, boolean) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(int, Clock) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(String) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(String, Clock) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(String, Clock, ExecutorService) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(String, Clock, ExecutorService, boolean) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(String, ExecutorService) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(Clock) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler(ExecutorService) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler
InMemoryTaskScheduler.Task - Class in io.fluxzero.common
inspect(Class, List, HandlerConfiguration) - Static method in class io.fluxzero.common.handling.HandlerInspector: Inspects the given class for methods matching the specified annotation and builds a HandlerMatcher.
inspect(Class, List, Class) - Static method in class io.fluxzero.common.handling.HandlerInspector: Inspects the given class for methods matching the specified annotation and builds a HandlerMatcher.
instance - Static variable in class io.fluxzero.common.api.search.NoOpConstraint: Singleton instance of the no-op constraint.
INSTANCE - Enum constant in enum class io.fluxzero.common.application.EnvironmentVariablesSource
INSTANCE - Enum constant in enum class io.fluxzero.common.application.NoOpPropertySource
INSTANCE - Enum constant in enum class io.fluxzero.common.caching.NoOpCache
INSTANCE - Enum constant in enum class io.fluxzero.common.encryption.NoOpEncryption
INSTANCE - Enum constant in enum class io.fluxzero.common.search.DefaultDocumentSerializer
INSTANCE - Enum constant in enum class io.fluxzero.common.serialization.NoOpTypeRegistry
instant() - Method in class io.fluxzero.common.DelegatingClock
Internal Use Only - Section in class io.fluxzero.common.reflection.ParameterRegistry
invert(byte[]) - Method in class io.fluxzero.common.search.JacksonInverter
Inverter<T> - Interface in io.fluxzero.common.search: Interface responsible for converting a domain object into a SerializedDocument for indexing, and vice versa—deserializing a byte[] representation into the original object type.
invoke() - Method in interface io.fluxzero.common.handling.HandlerInvoker: Invokes the handler using the default result-combining strategy (returns the first result).
invoke(HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerMethodPlan: Invokes the selected handler method using the supplied input.
invoke(Object) - Method in class io.fluxzero.common.reflection.DefaultMemberInvoker
invoke(Object) - Method in interface io.fluxzero.common.reflection.MemberInvoker: Invokes the member with no parameters.
invoke(Object, int, IntFunction) - Method in class io.fluxzero.common.reflection.DefaultMemberInvoker
invoke(Object, int, IntFunction) - Method in interface io.fluxzero.common.reflection.MemberInvoker: Invokes the member with the provided number of parameters using a parameter provider.
invoke(Object, Object) - Method in class io.fluxzero.common.reflection.DefaultMemberInvoker
invoke(Object, Object) - Method in interface io.fluxzero.common.reflection.MemberInvoker: Invokes the member with a single parameter.
invoke(Object, Object...) - Method in interface io.fluxzero.common.reflection.MemberInvoker: Invokes the member with a variable number of parameters.
invoke(BiFunction) - Method in interface io.fluxzero.common.handling.HandlerInvoker: Invokes the handler and combines results using the given combiner function.
invoke(BiFunction) - Method in class io.fluxzero.common.handling.HandlerInvoker.SimpleInvoker
invoke(M) - Method in interface io.fluxzero.common.handling.HandlerMethod: Invokes this handler method for the supplied message using the default result-combining strategy.
invoke(M, BiFunction) - Method in interface io.fluxzero.common.handling.HandlerMethod: Invokes this handler method for the supplied message and combines multiple results using the given combiner.
invoker(Member, boolean) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
io.fluxzero.common - module io.fluxzero.common
io.fluxzero.common - package io.fluxzero.common
io.fluxzero.common.api - package io.fluxzero.common.api
io.fluxzero.common.api.eventsourcing - package io.fluxzero.common.api.eventsourcing
io.fluxzero.common.api.keyvalue - package io.fluxzero.common.api.keyvalue
io.fluxzero.common.api.modeling - package io.fluxzero.common.api.modeling
io.fluxzero.common.api.publishing - package io.fluxzero.common.api.publishing
io.fluxzero.common.api.scheduling - package io.fluxzero.common.api.scheduling
io.fluxzero.common.api.search - package io.fluxzero.common.api.search
io.fluxzero.common.api.search.bulkupdate - package io.fluxzero.common.api.search.bulkupdate
io.fluxzero.common.api.search.constraints - package io.fluxzero.common.api.search.constraints
io.fluxzero.common.api.tracking - package io.fluxzero.common.api.tracking
io.fluxzero.common.application - package io.fluxzero.common.application
io.fluxzero.common.caching - package io.fluxzero.common.caching
io.fluxzero.common.encryption - package io.fluxzero.common.encryption
io.fluxzero.common.handling - package io.fluxzero.common.handling
io.fluxzero.common.reflection - package io.fluxzero.common.reflection
io.fluxzero.common.search - package io.fluxzero.common.search
io.fluxzero.common.serialization - package io.fluxzero.common.serialization
io.fluxzero.common.serialization.compression - package io.fluxzero.common.serialization.compression
io.fluxzero.common.tracking - package io.fluxzero.common.tracking
io.fluxzero.common.websocket - package io.fluxzero.common.websocket
isActive(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Checks if the tracker is currently marked as active.
isAlwaysTrue() - Method in interface io.fluxzero.common.handling.MessageFilter: Returns whether this filter accepts every message without inspecting runtime state.
isAnnotationPresent(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isAnnotationPresent(Parameter, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isBlank(CharSequence) - Static method in class io.fluxzero.common.ObjectUtils: Returns whether a character sequence is null, empty, or contains only whitespace.
isCacheable() - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns whether this result may be reused for another input with the same key.
isCached() - Method in class io.fluxzero.common.DefaultMemoizingSupplier
isCached() - Method in interface io.fluxzero.common.MemoizingSupplier: Returns whether this supplier has already cached a value.
isCached(K) - Method in class io.fluxzero.common.DefaultMemoizingFunction
isCached(K) - Method in interface io.fluxzero.common.MemoizingFunction: Checks if the given key has a cached value.
isCached(T, U) - Method in class io.fluxzero.common.DefaultMemoizingBiFunction
isCached(T, U) - Method in interface io.fluxzero.common.MemoizingBiFunction: Returns true if the function has already cached a value for the given inputs.
isCacheKeyRelevant(Parameter, Annotation) - Method in interface io.fluxzero.common.handling.KeyedParameterResolver: Returns whether this resolver's key can affect applicability for the supplied parameter.
isClass(Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isDone() - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy.TrackerRequest
isEmpty() - Method in class io.fluxzero.common.api.eventsourcing.EventBatch: Returns true if the batch contains no events.
isEmpty() - Method in class io.fluxzero.common.api.tracking.MessageBatch: Indicates whether this message batch is empty.
isEmpty() - Method in interface io.fluxzero.common.caching.Cache: Returns whether the cache is empty.
isEmpty() - Method in class io.fluxzero.common.tracking.TrackerCluster: Returns true if no trackers are currently registered.
isEmptyRange(int[]) - Static method in class io.fluxzero.common.ConsistentHashing: Checks whether the segment range is empty (i.e., start == end).
isEncrypted(String) - Method in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
isEncrypted(String) - Method in class io.fluxzero.common.encryption.DefaultEncryption
isEncrypted(String) - Method in interface io.fluxzero.common.encryption.Encryption: Returns true if the given value is considered encrypted by this implementation.
isEncrypted(String) - Method in enum class io.fluxzero.common.encryption.NoOpEncryption
isEncryptedWithKnownAlgorithm(String) - Method in class io.fluxzero.common.encryption.DefaultEncryption
isEqual(Object) - Static method in interface io.fluxzero.common.ThrowingPredicate: Returns a predicate that tests if two arguments are equal according to Objects.equals(Object, Object).
isFilterMessageTarget() - Method in interface io.fluxzero.common.tracking.Tracker
isIgnoreMessageTarget() - Method in class io.fluxzero.common.api.tracking.Read
isInteger(String) - Static method in class io.fluxzero.common.SearchUtils: Checks whether the input string is a parseable integer.
isKotlinReflectionSupported() - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isLeafValue(Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns whether the given value should be treated as a terminal scalar during reflective traversal.
isLongPath(String) - Static method in class io.fluxzero.common.search.Document.Path: Determines whether a given path string qualifies as a "long path".
isMetadataPath(String) - Static method in class io.fluxzero.common.search.JacksonInverter
isMethodAnnotationPresent(Executable, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isMissedDeadline(long) - Static method in class io.fluxzero.common.TimingUtils: Returns whether the given deadline has passed using the system UTC clock.
isMissedDeadline(Clock, long) - Static method in class io.fluxzero.common.TimingUtils: Returns whether the given deadline has passed using the specified Clock.
isNew(int[]) - Method in class io.fluxzero.common.api.tracking.Position: Indicates whether no index has been tracked yet for any segment in the given range.
isNewIndex(int, Long) - Method in class io.fluxzero.common.api.tracking.Position: Indicates whether the provided message index is newer than what is currently tracked for a segment.
isNewMessage(SerializedMessage) - Method in class io.fluxzero.common.api.tracking.Position: Indicates whether the message index is newer than what is currently tracked for its segment.
isNoMatchPayloadClassKey(HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Returns whether the payload's runtime class alone completely determines a non-match for this input.
isNoMatchPayloadClassKey(Parameter, Annotation, HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerInputResolver: Returns whether an unmatched result is guaranteed to remain unmatched for every payload with the same runtime class.
isNullable(Parameter) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isNumeric(CharSequence) - Static method in class io.fluxzero.common.ObjectUtils: Returns whether a character sequence is non-empty and consists entirely of Unicode digits.
ISO_FULL - Static variable in class io.fluxzero.common.SearchUtils: Date-time formatter used to serialize or deserialize full ISO-8601 instant values with millisecond precision.
isOrHas(Annotation, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isOrHas(Class, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isPassive() - Method in interface io.fluxzero.common.handling.HandlerDescriptor: Indicates whether this handler operates in passive mode (i.e., results will not be published).
isPassive() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
isPassive() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
isPassive() - Method in interface io.fluxzero.common.handling.HandlerInvoker: Indicates whether this handler operates in passive mode (i.e., results will not be published).
isPassive() - Method in class io.fluxzero.common.handling.HandlerInvoker.SimpleInvoker
isPassive() - Method in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
isPassive(Annotation) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
isPayloadClassKey(HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Returns whether the payload's runtime class alone completely determines a successful preparation for this input.
isPayloadClassKey(Parameter, Annotation, HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerInputResolver: Returns whether the payload's runtime class alone determines this resolver's successful result for the supplied parameter.
isPrepared() - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Returns whether preparation produced an invocation plan.
isReplaced() - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy.TrackerRequest
isShutdown() - Method in class io.fluxzero.common.DirectExecutorService
isStatic(Executable) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
isTerminated() - Method in class io.fluxzero.common.DirectExecutorService
isUnsupported() - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Returns whether the normal per-message handling path must be used.
iterate(T, UnaryOperator, Predicate) - Static method in class io.fluxzero.common.ObjectUtils: Creates a stream that stops once the break condition evaluates true.

J

JacksonInverter - Class in io.fluxzero.common.search: Implementation of Inverter that uses Jackson to invert an Object into a SerializedDocument and back into a JsonNode.
JacksonInverter() - Constructor for class io.fluxzero.common.search.JacksonInverter
JacksonInverter(JsonMapper) - Constructor for class io.fluxzero.common.search.JacksonInverter
JavaPropertiesSource - Class in io.fluxzero.common.application: Base class for PropertySource implementations backed by a Properties object.
JavaPropertiesSource(Properties) - Constructor for class io.fluxzero.common.application.JavaPropertiesSource: Creates a new property source backed by the given Properties instance.
join(byte[]...) - Static method in class io.fluxzero.common.ObjectUtils: Combines multiple byte arrays into a single byte array by concatenating their contents in the given order.
join(PropertySource...) - Static method in interface io.fluxzero.common.application.PropertySource: Joins multiple PropertySource instances into a single one.
join(List) - Static method in interface io.fluxzero.common.handling.HandlerInvoker: Joins a list of invokers into a single composite invoker.
json(ObjectMapper) - Static method in class io.fluxzero.common.websocket.WebSocketTransportCodecs: Existing JSON websocket codec.
JSON - Enum constant in enum class io.fluxzero.common.websocket.WebSocketTransportFormat: Existing JSON transport.
JSON_FORMAT - Static variable in class io.fluxzero.common.api.Data: Standard media type for JSON data.
JSON sequences - Section in class io.fluxzero.common.serialization.JsonUtils
JsonType - Interface in io.fluxzero.common.api: Marker interface for all low-level request and response types in the Fluxzero protocol.
JsonUtils - Class in io.fluxzero.common.serialization: Utility class for JSON serialization, deserialization, and file-based JSON resource loading.
JsonUtils() - Constructor for class io.fluxzero.common.serialization.JsonUtils
jvm() - Static method in interface io.fluxzero.common.caching.MemoryPressureController
jvm(PropertySource) - Static method in interface io.fluxzero.common.caching.MemoryPressureController

K

key() - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Returns the value of the key record component.
Key Characteristics: - Section in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
KeyedParameterResolver<M> - Interface in io.fluxzero.common.handling: Optional extension for dynamic parameter resolvers whose applicability can be safely reused for messages with the same low-cardinality key.
KeyedParameterResolver.Resolution<M> - Record Class in io.fluxzero.common.handling: Cached outcome of evaluating one resolver for one handler parameter.
Key Features - Section in class io.fluxzero.common.Backlog
Key Features - Section in class io.fluxzero.common.ConsistentHashing
Key Features - Section in class io.fluxzero.common.api.Metadata
Key Features - Section in class io.fluxzero.common.api.SerializedMessage
Key Features - Section in class io.fluxzero.common.reflection.DefaultMemberInvoker
Key Features - Section in class io.fluxzero.common.reflection.ParameterRegistry
Key Features - Section in class io.fluxzero.common.serialization.JsonUtils
keys() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
KeyValuePair - Class in io.fluxzero.common.api.keyvalue: Represents a single key-value entry in the legacy key-value store.
KeyValuePair() - Constructor for class io.fluxzero.common.api.keyvalue.KeyValuePair
keyValuePath() - Static method in class io.fluxzero.common.ServicePathBuilder: Returns the service path for the key-value store subsystem.
Kotlin package registration - Section in annotation interface io.fluxzero.common.serialization.RegisterType
KotlinReflectionUtils - Class in io.fluxzero.common.reflection: Provides utilities for bridging Java reflection with Kotlin reflection.
KotlinReflectionUtils() - Constructor for class io.fluxzero.common.reflection.KotlinReflectionUtils

L

lastChunk() - Method in interface io.fluxzero.common.api.HasMetadata: Determines if the data associated with this metadata is the final part of the data.
lastKey() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
lastMatch() - Method in class io.fluxzero.common.api.search.SearchDocumentsResult: Returns the last document in the result list, or null if no matches were found.
lastScannedIndex() - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Returns the value of the lastScannedIndex record component.
LazyInputStream - Class in io.fluxzero.common
LazyInputStream(Supplier) - Constructor for class io.fluxzero.common.LazyInputStream
Leaf - Interface in io.fluxzero.common: Marker interface for value objects that should be treated as leaves during reflective traversal.
letterOrNumber - Static variable in class io.fluxzero.common.SearchUtils: A character class used in regex patterns that includes letters and digits.
limitByCumulativeWeight(List, long, ToLongFunction) - Static method in class io.fluxzero.common.ObjectUtils: Returns a prefix of the list whose cumulative weight stays within maxWeight.
loadFile(File) - Static method in class io.fluxzero.common.FileUtils: Loads file contents from a File.
loadFile(File, Charset) - Static method in class io.fluxzero.common.FileUtils: Loads file contents from a File using a specific charset.
loadFile(Class, String) - Static method in class io.fluxzero.common.FileUtils: Loads a classpath resource relative to a given reference class.
loadFile(Class, String, Charset) - Static method in class io.fluxzero.common.FileUtils: Loads a file from a classpath location using a reference class and charset.
loadFile(String) - Static method in class io.fluxzero.common.FileUtils: Loads the contents of a file located relative to the calling class.
loadFile(String, Charset) - Static method in class io.fluxzero.common.FileUtils: Loads a file with a specified charset, using the calling class as reference point.
loadFile(URI) - Static method in class io.fluxzero.common.FileUtils: Loads file contents from a URI.
loadFile(URI, Charset) - Static method in class io.fluxzero.common.FileUtils: Loads file contents from a URI using a specific charset.
loadFile(URL, Charset) - Static method in class io.fluxzero.common.FileUtils: Loads file contents from a URL using a specific charset.
loadProperties(String) - Static method in class io.fluxzero.common.application.ApplicationEnvironmentPropertiesSource: Loads properties from an application-<env>.properties file if the environment name is present.
loadProperties(String) - Static method in class io.fluxzero.common.FileUtils: Loads properties from the classpath, merging from all available matching resources.
lookAhead(String, String...) - Static method in class io.fluxzero.common.api.search.constraints.LookAheadConstraint: Creates a LookAheadConstraint that matches any terms or phrases starting with the given input string.
LookAheadConstraint - Class in io.fluxzero.common.api.search.constraints: A constraint that supports search-as-you-type functionality by matching terms or phrases that start with a given input string.
LookAheadConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.LookAheadConstraint
lowestIndexForSegment(int[]) - Method in class io.fluxzero.common.api.tracking.Position: Returns the lowest tracked index within the given segment range.
LZ4 - Enum constant in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: Fast compression using the LZ4 codec.

M

manual - Enum constant in enum class io.fluxzero.common.caching.CacheEviction.Reason: The entry was manually evicted by application logic.
manual - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction.Reason
map(ThrowingFunction) - Method in class io.fluxzero.common.api.Data: Transforms the value using a custom mapping function, while preserving serialization metadata.
mark(int) - Method in class io.fluxzero.common.LazyInputStream
markSupported() - Method in class io.fluxzero.common.LazyInputStream
match(Object, boolean, String...) - Static method in class io.fluxzero.common.api.search.constraints.MatchConstraint: Creates a constraint that matches the given value across the specified paths, with an option to enforce strict string equality.
match(Object, String...) - Static method in class io.fluxzero.common.api.search.constraints.MatchConstraint: Creates a constraint that performs non-strict (normalized) matching of the provided value across the specified paths.
MatchConstraint - Class in io.fluxzero.common.api.search.constraints: A constraint that matches indexed document values based on text equality or normalized phrase matching.
MatchConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.MatchConstraint
matched() - Method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Returns the value of the matched record component.
matched() - Method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Returns the value of the matched record component.
matches(SerializedDocument) - Method in class io.fluxzero.common.api.search.SearchQuery: Checks if the given serialized document matches the query's constraints and collection filters.
matches(Document) - Method in interface io.fluxzero.common.api.search.Constraint: Evaluates whether this constraint applies to the given document.
matches(Document) - Method in class io.fluxzero.common.api.search.constraints.AllConstraint
matches(Document) - Method in class io.fluxzero.common.api.search.constraints.AnyConstraint
matches(Document) - Method in class io.fluxzero.common.api.search.constraints.FacetConstraint
matches(Document) - Method in class io.fluxzero.common.api.search.constraints.LookAheadConstraint: Evaluates whether this constraint matches the given Document.
matches(Document) - Method in class io.fluxzero.common.api.search.constraints.NotConstraint
matches(Document) - Method in class io.fluxzero.common.api.search.constraints.PathConstraint
matches(Document) - Method in class io.fluxzero.common.api.search.constraints.QueryConstraint: Overrides Constraint.matches(Document) to evaluate a decomposed constraint tree.
matches(Document) - Method in class io.fluxzero.common.api.search.NoOpConstraint: Always returns true, indicating that any document matches.
matches(Document.Entry, Document) - Method in class io.fluxzero.common.api.search.constraints.BetweenConstraint
matches(Document.Entry, Document) - Method in class io.fluxzero.common.api.search.constraints.ContainsConstraint: Checks whether a single document entry matches the constraint.
matches(Document.Entry, Document) - Method in class io.fluxzero.common.api.search.constraints.ExistsConstraint
matches(Document.Entry, Document) - Method in class io.fluxzero.common.api.search.constraints.LookAheadConstraint: Not supported for this constraint type, as this constraint relies on higher-level document decomposition.
matches(Document.Entry, Document) - Method in class io.fluxzero.common.api.search.constraints.MatchConstraint
matches(Document.Entry, Document) - Method in class io.fluxzero.common.api.search.constraints.PathConstraint: Evaluates whether the specified document entry satisfies the condition defined by this method's implementation.
matches(Document.Entry, Document) - Method in class io.fluxzero.common.api.search.constraints.QueryConstraint: Not supported directly on a single document entry.
matches(Parameter, Annotation, M) - Method in interface io.fluxzero.common.handling.ParameterResolver: Indicates whether the resolved value is compatible with the declared parameter type.
matches(Parameter, Annotation, M) - Method in class io.fluxzero.common.handling.TypedParameterResolver: Determines whether the given parameter is eligible to be resolved by this resolver.
matchFacet(FacetEntry) - Static method in class io.fluxzero.common.api.search.constraints.FacetConstraint: Factory method to create a constraint that matches a single FacetEntry.
matchFacet(String, Object) - Static method in class io.fluxzero.common.api.search.constraints.FacetConstraint: Factory method to create a constraint that matches documents with the given facet name and value.
matchingMethods(M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
matchingMethods(M) - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
matchingMethods(M) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Returns a stream of methods from the target class that match the given message.
Matching Modes - Section in class io.fluxzero.common.api.search.constraints.MatchConstraint
MAX_SEGMENT - Static variable in record class io.fluxzero.common.api.tracking.SegmentRange
maxEntryWeight() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
maxTimeout() - Method in interface io.fluxzero.common.tracking.Tracker
maxTrimWeight() - Method in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
maxTrimWeight() - Method in interface io.fluxzero.common.caching.MemoryPressureController
maxWeight() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
mayApply(Executable, Class) - Method in interface io.fluxzero.common.handling.ParameterResolver: Returns true if this resolver might apply to the given method.
mayApply(Executable, Class) - Method in class io.fluxzero.common.handling.TypedParameterResolver: Determines whether this resolver may be applicable to the given method or constructor.
MemberInvoker - Interface in io.fluxzero.common.reflection: Abstraction for invoking a Member (e.g.
memoize(BiFunction) - Static method in class io.fluxzero.common.ObjectUtils
memoize(Function) - Static method in class io.fluxzero.common.ObjectUtils
memoize(Supplier) - Static method in class io.fluxzero.common.ObjectUtils
MemoizingBiFunction<T,U,R> - Interface in io.fluxzero.common: A BiFunction that memoizes (caches) its results based on a pair of input arguments.
MemoizingFunction<K,V> - Interface in io.fluxzero.common: A Function that memoizes (caches) its results by key.
MemoizingSupplier<T> - Interface in io.fluxzero.common: A Supplier that memoizes (caches) the result of a single computation.
MEMORY_PRESSURE_GC_TIME_THRESHOLD_PERCENT_PROPERTY - Static variable in interface io.fluxzero.common.caching.MemoryPressureController: GC-time percentage over the sampling window that triggers JVM-wide memory-aware cache trimming.
MEMORY_PRESSURE_HEAP_THRESHOLD_PERCENT_PROPERTY - Static variable in interface io.fluxzero.common.caching.MemoryPressureController: Heap usage percentage that triggers JVM-wide memory-aware cache trimming.
MEMORY_PRESSURE_MAX_TRIM_WEIGHT_PROPERTY - Static variable in interface io.fluxzero.common.caching.MemoryPressureController: Maximum cache weight to evict per observed memory-pressure pass.
MEMORY_PRESSURE_TRIM_RATIO_PERCENT_PROPERTY - Static variable in interface io.fluxzero.common.caching.MemoryPressureController: Percentage of the registered memory-aware cache weight to evict per observed memory-pressure pass.
MemoryAwareCacheSupport<K,V> - Class in io.fluxzero.common.caching: A hard-reference, weighted cache with LRU eviction and optional key ordering.
MemoryAwareCacheSupport(long, long, ToLongBiFunction) - Constructor for class io.fluxzero.common.caching.MemoryAwareCacheSupport
MemoryAwareCacheSupport(long, long, ToLongBiFunction, Comparator) - Constructor for class io.fluxzero.common.caching.MemoryAwareCacheSupport
MemoryAwareCacheSupport(long, long, ToLongBiFunction, Comparator, MemoryPressureController) - Constructor for class io.fluxzero.common.caching.MemoryAwareCacheSupport
MemoryAwareCacheSupport(long, long, ToLongBiFunction, Comparator, MemoryPressureController, Duration) - Constructor for class io.fluxzero.common.caching.MemoryAwareCacheSupport
MemoryAwareCacheSupportEviction<K,V> - Record Class in io.fluxzero.common.caching: Describes an entry removed from an MemoryAwareCacheSupport.
MemoryAwareCacheSupportEviction(K, V, long, MemoryAwareCacheSupportEviction.Reason) - Constructor for record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Creates an instance of a MemoryAwareCacheSupportEviction record class.
MemoryAwareCacheSupportEviction.Reason - Enum Class in io.fluxzero.common.caching
memoryPressure - Enum constant in enum class io.fluxzero.common.caching.CacheEviction.Reason: The JVM experienced memory pressure and the cache purged entries to free up space.
memoryPressure - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction.Reason
MemoryPressureController - Interface in io.fluxzero.common.caching: Determines whether caches should proactively shed entries.
MemoryPressureController.JvmMemoryPressureController - Class in io.fluxzero.common.caching
merge(Position) - Method in class io.fluxzero.common.api.tracking.Position: Merges two Position objects by taking the highest known index per segment.
merge(Registration) - Method in interface io.fluxzero.common.Registration: Returns a new Registration that cancels both this and the given otherRegistration.
merge(Properties, Properties) - Static method in class io.fluxzero.common.ObjectUtils: Merges two Properties instances into a new one.
merge(T, Object) - Static method in class io.fluxzero.common.serialization.JsonUtils: Merges a base object with a patch/update object, omitting null fields.
MessageBatch - Class in io.fluxzero.common.api.tracking: Represents a batch of messages retrieved from the message store for a specific segment range.
MessageBatch() - Constructor for class io.fluxzero.common.api.tracking.MessageBatch
MessageBatch.Metric - Class in io.fluxzero.common.api.tracking: Compact summary of a MessageBatch, used for logging and performance tracking.
MessageFilter<M> - Interface in io.fluxzero.common.handling: Defines a predicate that determines whether a given message is applicable to a handler method.
MessageLogMaintenance - Class in io.fluxzero.common.tracking: Coordinates maintenance operations that span the message log, tracking positions and active trackers.
MessageLogMaintenance(MessageStore, PositionStore, TrackingStrategy) - Constructor for class io.fluxzero.common.tracking.MessageLogMaintenance: Creates message log maintenance for the given shared log components.
messages() - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Returns the value of the messages record component.
MessageStore - Interface in io.fluxzero.common.tracking: A low-level store for serialized messages.
MessageStoreBatch - Record Class in io.fluxzero.common.tracking: Result of scanning a message store for a tracking batch.
MessageStoreBatch(List, Long, int, boolean) - Constructor for record class io.fluxzero.common.tracking.MessageStoreBatch: Creates an instance of a MessageStoreBatch record class.
MessageType - Enum Class in io.fluxzero.common: Enumerates the types of messages recognized and routed by the Fluxzero Runtime.
Metadata - Class in io.fluxzero.common.api: Represents immutable metadata associated with a Message in the Fluxzero Runtime.
METADATA_PATH_PREFIX - Static variable in class io.fluxzero.common.search.JacksonInverter
metadataPath(String) - Static method in class io.fluxzero.common.search.JacksonInverter
method(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
methodAnnotation(Executable, Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
methodAnnotations(Executable, Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
MethodHandlerInvoker() - Constructor for class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
MethodHandlerMatcher(Executable, Class, List, HandlerConfiguration) - Constructor for class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
methodIndex(Method, Class) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
MethodInvocationValidator<M> - Interface in io.fluxzero.common.handling: Validates method invocation arguments right before a handler method is invoked.
methodMatches(Class, Executable) - Method in class io.fluxzero.common.handling.HandlerConfiguration: Determines whether the given method is eligible to handle messages according to this configuration.
methods() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
methods(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
Metric() - Constructor for class io.fluxzero.common.api.eventsourcing.AppendEvents.Metric
Metric() - Constructor for class io.fluxzero.common.api.eventsourcing.EventBatch.Metric
Metric() - Constructor for class io.fluxzero.common.api.eventsourcing.GetEventsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.keyvalue.GetValueResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.keyvalue.StoreValueIfAbsent.Metric
Metric() - Constructor for class io.fluxzero.common.api.keyvalue.StoreValues.Metric
Metric() - Constructor for class io.fluxzero.common.api.keyvalue.StoreValuesAndWait.Metric: Deprecated.
Metric() - Constructor for class io.fluxzero.common.api.publishing.Append.Metric
Metric() - Constructor for class io.fluxzero.common.api.scheduling.GetScheduleResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.scheduling.Schedule.Metric
Metric() - Constructor for class io.fluxzero.common.api.scheduling.SerializedSchedule.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.BulkUpdateDocuments.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.GetDocumentResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.GetDocumentsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.GetDocumentStatsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.GetFacetStatsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.GetSearchCollectionsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.IndexDocuments.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.SearchDocumentsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.tracking.ClaimSegmentResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.tracking.MessageBatch.Metric
Metric() - Constructor for class io.fluxzero.common.api.tracking.ReadFromIndexResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.tracking.ReadResult.Metric
Metrics - Section in class io.fluxzero.common.api.keyvalue.StoreValues
METRICS - Enum constant in enum class io.fluxzero.common.MessageType: Internal system event used for diagnostics and monitoring.
Metrics Logging - Section in interface io.fluxzero.common.api.JsonType
modifyEach(BiFunction) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
modifyEach(BiFunction) - Method in interface io.fluxzero.common.caching.Cache: Applies the given modifier function to all values currently in the cache.
modifyEach(BiFunction) - Method in enum class io.fluxzero.common.caching.NoOpCache
Modular Use - Section in class io.fluxzero.common.reflection.ReflectionUtils
Monitored<T> - Interface in io.fluxzero.common: Represents a resource or component that can be monitored.
MoveDocumentById - Class in io.fluxzero.common.api.search: Command to move a single document to another collection.
MoveDocumentById() - Constructor for class io.fluxzero.common.api.search.MoveDocumentById
MoveDocuments - Class in io.fluxzero.common.api.search: Command to move matching documents to a collection.
MoveDocuments() - Constructor for class io.fluxzero.common.api.search.MoveDocuments
Murmur3 - Class in io.fluxzero.common: The MurmurHash3 algorithm was created by Austin Appleby and placed in the public domain.
Murmur3() - Constructor for class io.fluxzero.common.Murmur3
murmurhash3_x86_32(CharSequence) - Static method in class io.fluxzero.common.Murmur3: Returns the MurmurHash3_x86_32 hash of the UTF-8 bytes of the String using seed of 0 without actually encoding the string to a temporary buffer.
murmurhash3_x86_32(CharSequence, int, int, int) - Static method in class io.fluxzero.common.Murmur3: Returns the MurmurHash3_x86_32 hash of the UTF-8 bytes of the String without actually encoding the string to a temporary buffer.

N

negate() - Method in interface io.fluxzero.common.handling.HandlerFilter: Inverts the current filter.
negate() - Method in interface io.fluxzero.common.ThrowingPredicate: Returns a predicate that represents the logical negation of this predicate.
newInstance() - Static method in class io.fluxzero.common.DirectExecutorService
newObjectNode(Object...) - Static method in class io.fluxzero.common.serialization.JsonUtils: Constructs a new ObjectNode from alternating key-value arguments.
newPlatformThreadFactory(String) - Static method in class io.fluxzero.common.ObjectUtils: Creates a new ThreadFactory with a named prefix.
newPosition() - Static method in class io.fluxzero.common.api.tracking.Position: Creates an empty position.
newShortSessionId() - Static method in class io.fluxzero.common.websocket.WebSocketCapabilities
newVirtualThreadFactory(String) - Static method in class io.fluxzero.common.ObjectUtils: Creates a new named virtual-thread ThreadFactory.
newWorkerPool(String, int) - Static method in class io.fluxzero.common.ObjectUtils: Creates a worker pool that uses virtual threads on Java 25+ and a fixed-size platform pool otherwise.
newWorkerThreadFactory(String) - Static method in class io.fluxzero.common.ObjectUtils: Creates a worker thread factory that uses virtual threads on Java 25+ and platform threads otherwise.
NO_MATCH - Enum constant in enum class io.fluxzero.common.handling.HandlerMethodPreparation.Status: The handler definitely does not match inputs represented by the associated cache key.
noMatch() - Static method in record class io.fluxzero.common.handling.HandlerMethodPreparation
none() - Static method in interface io.fluxzero.common.caching.MemoryPressureController
NONE - Enum constant in enum class io.fluxzero.common.Guarantee: No delivery guarantee is enforced.
NONE - Enum constant in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: No compression.
NONE - Static variable in interface io.fluxzero.common.caching.MemoryPressureController
noOp - Static variable in interface io.fluxzero.common.handling.MethodInvocationValidator
noOp() - Static method in interface io.fluxzero.common.handling.HandlerInvoker: Returns a no-op invoker that performs no action and returns null.
noOp() - Static method in interface io.fluxzero.common.handling.MethodInvocationValidator
noOp() - Static method in interface io.fluxzero.common.Registration: Returns a no-op Registration that does nothing on Registration.cancel().
noOp(Class, Executable) - Static method in interface io.fluxzero.common.handling.HandlerInvoker: Returns a no-op invoker associated with a handler method.
noOpBiPredicate() - Static method in class io.fluxzero.common.ObjectUtils: Returns a bi-predicate that always evaluates to true.
NoOpCache - Enum Class in io.fluxzero.common.caching
NoOpConstraint - Class in io.fluxzero.common.api.search: A Constraint implementation that matches all documents and imposes no filtering conditions.
NoOpConstraint() - Constructor for class io.fluxzero.common.api.search.NoOpConstraint
NoOpEncryption - Enum Class in io.fluxzero.common.encryption: A no-op implementation of the Encryption interface that performs no actual encryption or decryption.
noOpPredicate() - Static method in class io.fluxzero.common.ObjectUtils: Returns a predicate that always evaluates to true.
NoOpPropertySource - Enum Class in io.fluxzero.common.application: A no-operation PropertySource implementation that never returns any property values.
No-op Registration - Section in interface io.fluxzero.common.Registration
NoOpTypeRegistry - Enum Class in io.fluxzero.common.serialization
normalize(String) - Static method in class io.fluxzero.common.SearchUtils: Normalizes a string to lowercase and removes diacritics and leading/trailing whitespace.
normalizeJson(byte[]) - Static method in class io.fluxzero.common.SearchUtils: Normalizes all string values in a JSON byte array by stripping accents and lowercasing.
normalizePath(String) - Static method in class io.fluxzero.common.SearchUtils: Replaces unescaped dots in field paths with slashes.
not(Constraint) - Static method in class io.fluxzero.common.api.search.constraints.NotConstraint: Factory method to create a NotConstraint.
not(ThrowingPredicate) - Static method in interface io.fluxzero.common.ThrowingPredicate: Returns a predicate that is the negation of the supplied predicate.
NotConstraint - Class in io.fluxzero.common.api.search.constraints: A constraint that negates the result of another constraint.
NotConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.NotConstraint
Notes - Section in class io.fluxzero.common.api.keyvalue.StoreValueIfAbsent
Notes: - Section in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
NOTIFICATION - Enum constant in enum class io.fluxzero.common.MessageType: Same as events, but used in a fan-out strategy when a consumer is interested in events across all segments.
NULL - Enum constant in enum class io.fluxzero.common.search.Document.EntryType: Represents explicitly null entries.
NullCollectionsAsEmptyModule - Class in io.fluxzero.common.serialization: A custom Jackson module that configures deserialization behavior to treat null collections as empty collections.
NullCollectionsAsEmptyModule() - Constructor for class io.fluxzero.common.serialization.NullCollectionsAsEmptyModule
NUMERIC - Enum constant in enum class io.fluxzero.common.search.Document.EntryType: Represents numeric values including integers and decimals (e.g., 42, 3.14).

O

ObjectHandlerMatcher(List, boolean) - Constructor for class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
objectMapper - Static variable in class io.fluxzero.common.api.Metadata
ObjectUtils - Class in io.fluxzero.common: Utility class for common object handling, memoization, concurrency, stream processing, and error handling.
ObjectUtils() - Constructor for class io.fluxzero.common.ObjectUtils
of(Class) - Static method in class io.fluxzero.common.reflection.ParameterRegistry: Returns the registry instance for the specified class, loading and memoizing the generated _params class on first access.
of(Object...) - Static method in class io.fluxzero.common.api.Metadata: Creates a new Metadata instance with the provided key-value pairs.
of(Object, Object) - Static method in class io.fluxzero.common.api.Metadata: Creates a new Metadata instance with a single key-value pair.
of(String...) - Static method in class io.fluxzero.common.api.search.Group: Creates a Group from an even-length list of alternating keys and values.
of(Map) - Static method in class io.fluxzero.common.api.Metadata: Creates a new instance of Metadata populated with the given map.
onChange(Runnable) - Method in class io.fluxzero.common.DelegatingClock: Registers a listener that is invoked whenever the backing clock changes.
onClusterUpdate(TrackerCluster) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
onUpdate(List) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
Optional Final Notification - Section in class io.fluxzero.common.api.tracking.DisconnectTracker
or(Constraint) - Method in interface io.fluxzero.common.api.search.Constraint: Combines this constraint with another using logical OR.
or(HandlerFilter) - Method in interface io.fluxzero.common.handling.HandlerFilter: Combines this filter with another using logical OR.
or(Handler) - Method in interface io.fluxzero.common.handling.Handler: Creates a composite handler that executes the current handler and then delegates to the specified next handler if the current handler cannot handle the message or does not provide an invoker.
or(HandlerMatcher) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Combines this HandlerMatcher with another HandlerMatcher to form a composite matcher.
or(ThrowingPredicate) - Method in interface io.fluxzero.common.ThrowingPredicate: Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
orTimeout(CompletableFuture, Duration) - Method in interface io.fluxzero.common.TaskScheduler: Sets a timeout for a CompletableFuture.

P

parameterize(Class, Type...) - Static method in class io.fluxzero.common.reflection.GenericTypeResolver: Creates a parameterized type for a raw class and its actual type arguments.
ParameterRegistry - Class in io.fluxzero.common.reflection: Registry for accessing method parameter names at runtime in environments where Java reflection does not retain them (e.g.
ParameterRegistry() - Constructor for class io.fluxzero.common.reflection.ParameterRegistry
ParameterResolver<M> - Interface in io.fluxzero.common.handling: Mechanism to resolve method parameters in message handler methods (e.g. those annotated with HandleEvent, HandleCommand, etc.).
parseMetadataValue(String) - Method in class io.fluxzero.common.search.JacksonInverter
parseObject(JsonParser, Map, String) - Method in class io.fluxzero.common.search.JacksonInverter
parseTimeProperty(String, Object, boolean, Supplier) - Static method in class io.fluxzero.common.SearchUtils: Parses a time-related property from an object based on the specified property path.
Path() - Constructor for class io.fluxzero.common.search.Document.Path
PathConstraint - Class in io.fluxzero.common.api.search.constraints: Abstract base class for constraints that apply to specific paths in a Document.
PathConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.PathConstraint
Path Filtering - Section in class io.fluxzero.common.api.search.constraints.PathConstraint
Path Handling - Section in class io.fluxzero.common.api.search.constraints.MatchConstraint
pathPredicate(String) - Static method in class io.fluxzero.common.search.Document.Path: Constructs a predicate to match Document.Path instances against the given glob-style path query.
payloadClassKey() - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns the value of the payloadClassKey record component.
Performance consideration - Section in class io.fluxzero.common.api.search.constraints.PathConstraint
Performance Considerations - Section in class io.fluxzero.common.api.search.constraints.ContainsConstraint
Performance Considerations - Section in class io.fluxzero.common.api.search.constraints.QueryConstraint
Performance Considerations - Section in class io.fluxzero.common.reflection.ReflectionUtils
plan() - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Returns the value of the plan record component.
position(Tracker, int[]) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
position(String) - Method in class io.fluxzero.common.tracking.InMemoryPositionStore
position(String) - Method in interface io.fluxzero.common.tracking.PositionStore: Retrieves the full multi-segment position for the given consumer.
Position - Class in io.fluxzero.common.api.tracking: Represents the tracking state of a consumer, i.e. the last known indexes of consumed messages per segment.
Position(int[], long) - Constructor for class io.fluxzero.common.api.tracking.Position: Creates a position for a single segment range.
Position(long) - Constructor for class io.fluxzero.common.api.tracking.Position: Creates a position that applies the same index to all segments.
Position(SegmentRange) - Constructor for class io.fluxzero.common.api.tracking.Position: Creates a position for a single segment range.
Position(List) - Constructor for class io.fluxzero.common.api.tracking.Position: Creates a position from a list of segment ranges.
PositionStore - Interface in io.fluxzero.common.tracking: Interface for storing and retrieving Position objects representing the last processed message indexes per segment for a given consumer.
Preferred Alternatives - Section in class io.fluxzero.common.api.tracking.ResetPosition
preparation() - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns the value of the preparation record component.
prepare(HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Selects and prepares a handler method without creating the message when the planner supports lazy input.
prepare(Executable, Class, Class) - Method in interface io.fluxzero.common.handling.MessageFilter: Returns a filter prepared for the supplied handler method.
prepare(Parameter, Annotation) - Method in interface io.fluxzero.common.handling.ParameterResolver: Prepares a resolver function when this resolver can determine compatibility from the parameter and method annotation alone.
prepare(M) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Selects a handler method for the representative message and prepares its invocation.
prepareApplicability(HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Determines whether a handler applies without creating the complete message when the planner supports lazy input.
prepareApplicability(M) - Method in interface io.fluxzero.common.handling.HandlerMethodPlanner: Determines whether a handler applies to the message and returns the complete key needed to reuse that decision.
prepared(HandlerMethodPlan) - Static method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Creates a successful preparation.
PREPARED - Enum constant in enum class io.fluxzero.common.handling.HandlerMethodPreparation.Status: The handler matches and HandlerMethodPreparation.plan() contains its invocation plan.
PreparedParameterResolver<M> - Interface in io.fluxzero.common.handling: Optional extension for parameter resolvers that can prepare a resolver function for a specific message in one step.
prepareHandlerMethod(Object, M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
prepareHandlerMethod(Object, M) - Method in class io.fluxzero.common.handling.HandlerInspector.ObjectHandlerMatcher
prepareHandlerMethod(T, M) - Method in interface io.fluxzero.common.handling.HandlerMatcher: Selects and prepares a handler method on the supplied target for the given message.
prepareInput(Parameter, Annotation, HandlerInput) - Method in interface io.fluxzero.common.handling.HandlerInputResolver: Determines whether this resolver handles the parameter and, when it does, creates the function that supplies the parameter value during invocation.
prepareInvoker(M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
prepareInvokerOrNull(M) - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher
priority() - Method in record class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.Specificity: Returns the value of the priority record component.
process(Set, RoundEnvironment) - Method in class io.fluxzero.common.serialization.TypeRegistryProcessor
processToken(JsonToken, Map, String, JsonParser) - Method in class io.fluxzero.common.search.JacksonInverter
propertyPath(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
PropertySource - Interface in io.fluxzero.common.application: Represents a source of configuration properties.
purgeCeasedTrackers(Duration) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
purgeCeasedTrackers(Instant) - Method in class io.fluxzero.common.tracking.TrackerCluster: Removes trackers that have not sent activity after the given timestamp.
purgeTrackers(Predicate) - Method in class io.fluxzero.common.tracking.TrackerCluster: Removes all trackers that match the provided predicate.
put(Object, Object) - Method in enum class io.fluxzero.common.caching.NoOpCache
put(Object, Object) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
put(Object, Object) - Method in interface io.fluxzero.common.caching.Cache: Puts a value in the cache for the given id, overwriting any existing value.
put(K, V) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Stores a value when it fits the configured entry and total weight constraints.
putAll(Map) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Stores all values in iteration order while applying the same admission and weight constraints as MemoryAwareCacheSupport.put(Object, Object).
putIfAbsent(Object, Object) - Method in enum class io.fluxzero.common.caching.NoOpCache
putIfAbsent(Object, Object) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
putIfAbsent(Object, Object) - Method in interface io.fluxzero.common.caching.Cache: Associates the specified value with the given id only if no value is currently associated.

Q

query(String, boolean, String...) - Static method in class io.fluxzero.common.api.search.constraints.QueryConstraint: Creates a QueryConstraint with optional lookahead behavior for terms.
query(String, String...) - Static method in class io.fluxzero.common.api.search.constraints.QueryConstraint: Creates a QueryConstraint that parses and evaluates the given query string.
QUERY - Enum constant in enum class io.fluxzero.common.MessageType: A request for data or read-only information.
QueryConstraint - Class in io.fluxzero.common.api.search.constraints: A Constraint that parses a human-friendly query string into a structured tree of constraints.
QueryConstraint() - Constructor for class io.fluxzero.common.api.search.constraints.QueryConstraint

R

rawClass(Type) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Resolves a reflective Type to the best raw Class representation available.
read() - Method in class io.fluxzero.common.LazyInputStream
read() - Method in class io.fluxzero.common.StreamInputStream
read(byte[]) - Method in class io.fluxzero.common.LazyInputStream
read(byte[], int, int) - Method in class io.fluxzero.common.LazyInputStream
read(byte[], int, int) - Method in class io.fluxzero.common.StreamInputStream
Read - Class in io.fluxzero.common.api.tracking: Command to read a batch of messages from the Fluxzero Runtime for a given consumer and tracker.
Read(MessageType, String, String, int, long, long, String, boolean, boolean, boolean, boolean, Long, Long) - Constructor for class io.fluxzero.common.api.tracking.Read
Read(MessageType, String, String, int, long, String, boolean, boolean, boolean, boolean, Long, Long) - Constructor for class io.fluxzero.common.api.tracking.Read
reader - Static variable in class io.fluxzero.common.serialization.JsonUtils: Preconfigured JsonMapper for reading/deserializing objects from JSON, including type handling.
ReadFromIndex - Class in io.fluxzero.common.api.tracking: Request to fetch a batch of messages from a given log starting from a given index.
ReadFromIndex(long, int) - Constructor for class io.fluxzero.common.api.tracking.ReadFromIndex
ReadFromIndex(long, int, long) - Constructor for class io.fluxzero.common.api.tracking.ReadFromIndex
ReadFromIndexResult - Class in io.fluxzero.common.api.tracking: Result for a ReadFromIndex request.
ReadFromIndexResult() - Constructor for class io.fluxzero.common.api.tracking.ReadFromIndexResult
ReadFromIndexResult.Metric - Class in io.fluxzero.common.api.tracking: Metric representation of a ReadFromIndexResult, used for internal monitoring and analytics.
readProperty(String, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
ReadResult - Class in io.fluxzero.common.api.tracking: Result returned in response to a Read request for a batch of messages.
ReadResult() - Constructor for class io.fluxzero.common.api.tracking.ReadResult
ReadResult.Metric - Class in io.fluxzero.common.api.tracking: Compact representation of the ReadResult used for monitoring.
readTree(byte[]) - Static method in class io.fluxzero.common.serialization.JsonUtils: Reads a JSON structure as a JsonNode tree from a JSON byte array.
readTree(InputStream) - Static method in class io.fluxzero.common.serialization.JsonUtils: Reads a JSON structure as a JsonNode tree from a JSON input stream.
readTree(String) - Static method in class io.fluxzero.common.serialization.JsonUtils: Reads a JSON structure as a JsonNode tree from a JSON string.
reason() - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Returns the value of the reason record component.
rebuild() - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
rebuild() - Method in interface io.fluxzero.common.caching.Cache: Returns a fresh cache instance with the same configuration and no stored entries.
rebuild() - Method in enum class io.fluxzero.common.caching.NoOpCache
ReflectionUtils - Class in io.fluxzero.common.reflection: Utility class for high-performance reflection-based operations across the Fluxzero Runtime.
ReflectionUtils() - Constructor for class io.fluxzero.common.reflection.ReflectionUtils
ReflectionUtils.TypeMetadata - Class in io.fluxzero.common.reflection: Lazily computed reflection metadata for a single Java type.
ReflectionUtils.TypeMetadata.PropertyPathMetadata - Class in io.fluxzero.common.reflection
registerEvictionListener(Consumer) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
registerEvictionListener(Consumer) - Method in interface io.fluxzero.common.caching.Cache: Registers a listener to be notified whenever a cache entry is evicted or removed.
registerEvictionListener(Consumer) - Method in enum class io.fluxzero.common.caching.NoOpCache
registerEvictionListener(Consumer) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
registerMonitor(Consumer) - Method in class io.fluxzero.common.Backlog: Adds a monitor to observe flushed batches.
registerMonitor(Consumer) - Method in interface io.fluxzero.common.Monitored: Registers a monitor that will be notified when an activity of type T occurs.
RegisterType - Annotation Interface in io.fluxzero.common.serialization: Annotation to register a class or package for inclusion in the TypeRegistry.
registerValue(Document.EntryType, String, String, Map) - Method in class io.fluxzero.common.search.JacksonInverter
Registration - Interface in io.fluxzero.common: Represents a handle for a cancellable registration, such as a subscription, listener, or callback.
regular - Enum constant in enum class io.fluxzero.common.api.search.SearchCollectionType: A regular document collection.
rejected() - Static method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Returns a result indicating that this resolver claims the parameter but rejects the representative input.
rejected() - Static method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Returns an outcome that rejects the handler without considering later resolvers.
Relationship - Class in io.fluxzero.common.api.modeling: Describes a relationship between an entity and the aggregate that contains or owns it.
Relationship() - Constructor for class io.fluxzero.common.api.modeling.Relationship
remove(Object) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
remove(Object) - Method in interface io.fluxzero.common.caching.Cache: Removes the entry associated with the given id, if present.
remove(Object) - Method in enum class io.fluxzero.common.caching.NoOpCache
remove(K) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
remove(K) - Method in class io.fluxzero.common.DefaultMemoizingFunction
remove(K) - Method in interface io.fluxzero.common.MemoizingFunction: Removes and returns the cached result for the given key, if present.
remove(T, U) - Method in class io.fluxzero.common.DefaultMemoizingBiFunction
remove(T, U) - Method in interface io.fluxzero.common.MemoizingBiFunction: Removes the cached result for the given input pair, if present.
RepairRelationships - Class in io.fluxzero.common.api.modeling: Command to repair or re-index the relationships for an existing aggregate.
RepairRelationships() - Constructor for class io.fluxzero.common.api.modeling.RepairRelationships
REPLACES_SESSION_ID_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
Request - Class in io.fluxzero.common.api: Base class for requests sent to the Fluxzero Runtime.
Request() - Constructor for class io.fluxzero.common.api.Request
RequestBatch<T> - Class in io.fluxzero.common.api: Represents a batch of requests to be sent to the Fluxzero Runtime in a single network round-trip.
RequestBatch() - Constructor for class io.fluxzero.common.api.RequestBatch
RequestResult - Interface in io.fluxzero.common.api: Marker interface for responses to Request objects (including commands and queries).
require(String) - Method in interface io.fluxzero.common.application.PropertySource: Retrieves the value of a property by name and throws if not present.
reset() - Method in class io.fluxzero.common.LazyInputStream
resetPosition(String, long) - Method in class io.fluxzero.common.tracking.InMemoryPositionStore
resetPosition(String, long) - Method in interface io.fluxzero.common.tracking.PositionStore: Resets the position of the consumer for all segments to the given index.
ResetPosition - Class in io.fluxzero.common.api.tracking: Command to forcibly reset the tracked position for a given consumer and message type.
ResetPosition() - Constructor for class io.fluxzero.common.api.tracking.ResetPosition
Resolution(boolean, Function) - Constructor for record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Creates an instance of a Resolution record class.
Resolution(boolean, Function) - Constructor for record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Creates an instance of a Resolution record class.
resolve(Parameter, Annotation) - Method in interface io.fluxzero.common.handling.ParameterResolver: Resolves a Parameter of a handler method into a value function based on the given message.
resolved(Function) - Static method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Returns a successful result with a function that supplies the argument for each compatible input.
resolved(Function) - Static method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Returns an outcome backed by a reusable current-message value resolver.
resolveDelay(RetryStatus) - Method in class io.fluxzero.common.RetryConfiguration: Resolves the delay duration for the next retry attempt based on the provided RetryStatus.
resolveForKey(Parameter, Annotation, M, Object) - Method in interface io.fluxzero.common.handling.KeyedParameterResolver: Computes a reusable resolution recipe for the supplied key.
resolveIfPossible(Parameter, Annotation, M) - Method in interface io.fluxzero.common.handling.PreparedParameterResolver: Returns a prepared resolver for the given message, or null when this resolver cannot handle the parameter.
resolver() - Method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Returns the value of the resolver record component.
resolver() - Method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Returns the value of the resolver record component.
Responsibilities - Section in interface io.fluxzero.common.tracking.Tracker
Responsibilities - Section in interface io.fluxzero.common.tracking.TrackingStrategy
RESULT - Enum constant in enum class io.fluxzero.common.MessageType: The result of handling a request (e.g. command, query).
ResultBatch - Class in io.fluxzero.common.api: Represents a batch of results returned from the Fluxzero Runtime in response to a RequestBatch.
ResultBatch() - Constructor for class io.fluxzero.common.api.ResultBatch
Result Matching - Section in class io.fluxzero.common.api.ResultBatch
rethrow(Throwable) - Static method in class io.fluxzero.common.ObjectUtils: Unwraps then returns the given Throwable as an unchecked exception.
RetryConfiguration - Class in io.fluxzero.common: Configuration for retry behavior when executing a task using TimingUtils.retryOnFailure(Runnable, Duration).
RetryConfiguration() - Constructor for class io.fluxzero.common.RetryConfiguration
retryOnFailure(Runnable, Duration) - Static method in class io.fluxzero.common.TimingUtils: Retries a task indefinitely if it fails, using a fixed delay.
retryOnFailure(Runnable, Duration, Predicate) - Static method in class io.fluxzero.common.TimingUtils: Retries a task indefinitely if it fails and matches the given exception predicate.
retryOnFailure(Callable, RetryConfiguration) - Static method in class io.fluxzero.common.TimingUtils: Retries a Callable task using a full RetryConfiguration.
retryOnFailure(Callable, Duration) - Static method in class io.fluxzero.common.TimingUtils: Retries a Callable task indefinitely with a fixed delay.
retryOnFailure(Callable, Duration, Predicate) - Static method in class io.fluxzero.common.TimingUtils: Retries a Callable task with a delay and a predicate to filter retryable exceptions.
RetryStatus - Class in io.fluxzero.common: Represents the current status of a retry operation.
RetryStatus() - Constructor for class io.fluxzero.common.RetryStatus
Revision - Annotation Interface in io.fluxzero.common.serialization: Specifies the revision number of a persistable object, such as a message payload, document, or aggregate snapshot.
Revisioned payloads - Section in class io.fluxzero.common.serialization.JsonUtils
root() - Element in annotation interface io.fluxzero.common.serialization.RegisterType: Optional explicit root package or type prefix to register.
Routing - Section in class io.fluxzero.common.api.eventsourcing.AppendEvents
Routing - Section in class io.fluxzero.common.api.keyvalue.StoreValues
routingKey() - Method in class io.fluxzero.common.api.Command: Optionally specifies a routing key for this command, which may be used to partition work or apply consistent hashing when processed in the Fluxzero Runtime.
routingKey() - Method in class io.fluxzero.common.api.eventsourcing.AppendEvents: Returns the routing key used to partition the command, based on the first batch’s aggregate ID.
routingKey() - Method in class io.fluxzero.common.api.eventsourcing.DeleteEvents: Returns the routing key used to partition or locate the event stream.
routingKey() - Method in class io.fluxzero.common.api.keyvalue.DeleteValue: Routing key used by the Fluxzero Runtime to shard or partition this command.
routingKey() - Method in class io.fluxzero.common.api.keyvalue.StoreValueIfAbsent
routingKey() - Method in class io.fluxzero.common.api.keyvalue.StoreValues
routingKey() - Method in class io.fluxzero.common.api.keyvalue.StoreValuesAndWait: Deprecated.
routingKey() - Method in class io.fluxzero.common.api.modeling.RepairRelationships: Routing key derived from the aggregate ID to ensure consistent processing.
routingKey() - Method in class io.fluxzero.common.api.modeling.UpdateRelationships: Returns a routing key to optimize dispatching.
routingKey() - Method in class io.fluxzero.common.api.publishing.Append
routingKey() - Method in class io.fluxzero.common.api.scheduling.CancelSchedule: Returns the routing key used for this command.
routingKey() - Method in class io.fluxzero.common.api.search.BulkUpdateDocuments: Uses the ID of the first update as the routing key for this command.
routingKey() - Method in class io.fluxzero.common.api.search.CreateAuditTrail: Uses the collection name as routing key to ensure consistent configuration.
routingKey() - Method in class io.fluxzero.common.api.search.DeleteCollection: Uses the collection name as the routing key for consistency and traceability.
routingKey() - Method in class io.fluxzero.common.api.search.DeleteDocumentById: Uses the document ID as the routing key, ensuring consistency during deletion.
routingKey() - Method in class io.fluxzero.common.api.search.IndexDocuments
routingKey() - Method in class io.fluxzero.common.api.search.MoveDocumentById: Uses the document ID as the routing key, ensuring consistency during the move.
routingKey() - Method in class io.fluxzero.common.api.tracking.DisconnectTracker
routingKey() - Method in class io.fluxzero.common.api.tracking.ResetPosition: Returns a routing key used for partitioning the reset command by consumer and message type.
routingKey() - Method in class io.fluxzero.common.api.tracking.StorePosition: Returns a routing key based on the message type and consumer name.
run() - Method in interface io.fluxzero.common.ThrowingRunnable: Executes this runnable.
run() - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy.WaitingTracker
run(ThrowingRunnable) - Static method in interface io.fluxzero.common.handling.HandlerInvoker: Wraps a ThrowingRunnable in a HandlerInvoker.
run(ThrowingRunnable) - Static method in class io.fluxzero.common.ObjectUtils: Executes the runnable, forcibly rethrowing exceptions as unchecked.
runAndWait(ThrowingRunnable, Duration) - Method in class io.fluxzero.common.TimeboxedExecutor: Executes the given task and waits for completion up to the given maximum duration.
runAndWait(ThrowingRunnable, Duration) - Static method in class io.fluxzero.common.TimingUtils: Executes the given task and waits for completion up to the given maximum duration.
runAndWaitSafely(ThrowingRunnable, Duration) - Method in class io.fluxzero.common.TimeboxedExecutor: Executes the given task and waits for completion up to the given maximum duration.
runAndWaitSafely(ThrowingRunnable, Duration) - Static method in class io.fluxzero.common.TimingUtils: Executes the given task and waits for completion up to the given maximum duration.
runAndWaitSafely(ThrowingRunnable, Duration, boolean) - Method in class io.fluxzero.common.TimeboxedExecutor: Executes the given task and waits for completion up to the given maximum duration.
runAndWaitSafely(ThrowingRunnable, Duration, boolean) - Static method in class io.fluxzero.common.TimingUtils: Executes the given task and waits for completion up to the given maximum duration.
RUNTIME_SESSION_ID_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
RUNTIME_VERSION_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
RuntimeLifecycleEvent - Class in io.fluxzero.common.api: Metric event emitted when a Fluxzero Runtime changes lifecycle phase.
RuntimeLifecycleEvent() - Constructor for class io.fluxzero.common.api.RuntimeLifecycleEvent
RuntimeLifecycleEvent.Phase - Enum Class in io.fluxzero.common.api: Runtime lifecycle phases that are published as metrics.

S

safeResolve(URI, String) - Static method in class io.fluxzero.common.FileUtils: Safely resolves a relative path against a base URI, including JAR URLs.
scan(Iterable, int, long, Predicate) - Static method in record class io.fluxzero.common.tracking.MessageStoreBatch: Scans source messages until the source count or accepted-message byte budget is exhausted.
scanBatch(int[], Position, int, long, Predicate) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
scanBatch(Long, int, boolean, long, Predicate) - Method in interface io.fluxzero.common.tracking.MessageStore: Scans messages starting from the given minIndex, returning messages accepted by filter and metadata about the unfiltered source scan.
scannedSize() - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Returns the value of the scannedSize record component.
schedule(long, ThrowingRunnable) - Method in class io.fluxzero.common.InMemoryTaskScheduler
schedule(long, ThrowingRunnable) - Method in interface io.fluxzero.common.TaskScheduler: Schedules a task to be executed at the given epoch millisecond timestamp.
schedule(Duration, ThrowingRunnable) - Method in interface io.fluxzero.common.TaskScheduler: Schedules a task to be executed after a specified delay.
schedule(Instant, ThrowingRunnable) - Method in interface io.fluxzero.common.TaskScheduler: Schedules a task to be executed at a specific timestamp.
Schedule - Class in io.fluxzero.common.api.scheduling: Command to schedule a batch of messages for future delivery.
Schedule() - Constructor for class io.fluxzero.common.api.scheduling.Schedule
SCHEDULE - Enum constant in enum class io.fluxzero.common.MessageType: A scheduled message to be delivered at a specific time.
Schedule.Metric - Class in io.fluxzero.common.api.scheduling: Lightweight metric representation of this Schedule command, used for monitoring purposes.
schedulingPath() - Static method in class io.fluxzero.common.ServicePathBuilder: Returns the service path for the scheduling subsystem.
SearchCollection - Class in io.fluxzero.common.api.search: Describes an existing search collection and its storage type.
SearchCollection() - Constructor for class io.fluxzero.common.api.search.SearchCollection
SearchCollectionType - Enum Class in io.fluxzero.common.api.search: Supported search collection types.
SearchDocuments - Class in io.fluxzero.common.api.search: Request used to perform a search over documents indexed in the Fluxzero search store.
SearchDocuments() - Constructor for class io.fluxzero.common.api.search.SearchDocuments
SearchDocumentsResult - Class in io.fluxzero.common.api.search: The result of a SearchDocuments request.
SearchDocumentsResult() - Constructor for class io.fluxzero.common.api.search.SearchDocumentsResult
SearchDocumentsResult.Metric - Class in io.fluxzero.common.api.search: Lightweight metric representation used for logging search result metadata.
SearchExclude - Annotation Interface in io.fluxzero.common.search: Marker annotation that indicates that a property is to be ignored when indexing a document for text search.
SearchHistogram - Class in io.fluxzero.common.api.search: Represents a histogram over a time range, typically returned by GetSearchHistogramResult.
SearchHistogram() - Constructor for class io.fluxzero.common.api.search.SearchHistogram
searchIgnoreCache - Static variable in class io.fluxzero.common.search.JacksonInverter
SearchInclude - Annotation Interface in io.fluxzero.common.search: Marker annotation that indicates that a property is to be included when indexing a document for search.
searchPath() - Static method in class io.fluxzero.common.ServicePathBuilder: Returns the service path for the search/document store subsystem.
SearchQuery - Class in io.fluxzero.common.api.search: A query for filtering documents in one or more search collections.
SearchQuery(List, Instant, Instant, boolean, boolean, List) - Constructor for class io.fluxzero.common.api.search.SearchQuery
SearchQuery.Builder - Class in io.fluxzero.common.api.search: Builder class for constructing instances of SearchQuery.
SearchUtils - Class in io.fluxzero.common: Utility class for search-related functionality such as term normalization, path transformation, glob pattern matching, and primitive value extraction.
SearchUtils() - Constructor for class io.fluxzero.common.SearchUtils
segmentEnd() - Method in record class io.fluxzero.common.api.tracking.SegmentRange: Returns the value of the segmentEnd record component.
SegmentRange - Record Class in io.fluxzero.common.api.tracking: Represents an index value for a contiguous range of segments.
SegmentRange(int, int, long) - Constructor for record class io.fluxzero.common.api.tracking.SegmentRange: Creates an instance of a SegmentRange record class.
Segment Reassignment - Section in class io.fluxzero.common.api.tracking.DisconnectTracker
segmentStart() - Method in record class io.fluxzero.common.api.tracking.SegmentRange: Returns the value of the segmentStart record component.
SELECTED_COMPRESSION_ALGORITHM_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
SELECTED_TRANSPORT_FORMAT_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
SENT - Enum constant in enum class io.fluxzero.common.Guarantee: Guarantees that the message or action was sent successfully.
Serialization - Section in interface io.fluxzero.common.api.JsonType
Serialization - Section in interface io.fluxzero.common.api.search.Constraint
Serialization Format - Section in enum class io.fluxzero.common.search.DefaultDocumentSerializer
serialize() - Method in enum class io.fluxzero.common.search.Document.EntryType: Serializes this entry type to a single byte.
serialize(Document) - Method in enum class io.fluxzero.common.search.DefaultDocumentSerializer: Serializes the given Document into a compressed binary Data container.
SerializedDocument - Class in io.fluxzero.common.api.search: Represents a serialized form of a search document stored in a Fluxzero collection.
SerializedDocument(Document) - Constructor for class io.fluxzero.common.api.search.SerializedDocument: Constructs a SerializedDocument from a deserialized Document representation.
SerializedDocument(String, Long, Long, String, Data, String, Set, Set) - Constructor for class io.fluxzero.common.api.search.SerializedDocument: Constructs a new instance of the SerializedDocument class with the specified parameters.
SerializedMessage - Class in io.fluxzero.common.api: Represents a fully serialized message for transmission or storage within the Fluxzero Runtime.
SerializedMessage(Data, Metadata, String, Long) - Constructor for class io.fluxzero.common.api.SerializedMessage
SerializedObject<T> - Interface in io.fluxzero.common.api
SerializedSchedule - Class in io.fluxzero.common.api.scheduling: Represents a scheduled message to be delivered at a specific SerializedSchedule.timestamp.
SerializedSchedule() - Constructor for class io.fluxzero.common.api.scheduling.SerializedSchedule
SerializedSchedule.Metric - Class in io.fluxzero.common.api.scheduling: Metric representation of the SerializedSchedule for tracking/monitoring.
ServicePathBuilder - Class in io.fluxzero.common: Utility class for constructing internal service endpoint paths used to route messages to the Fluxzero Runtime.
ServicePathBuilder() - Constructor for class io.fluxzero.common.ServicePathBuilder
setDelegate(Clock) - Method in class io.fluxzero.common.DelegatingClock: Replaces the backing clock and notifies registered change listeners after the new clock is visible.
setField(Field, Object, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
setField(String, Object, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
setRequestReceivedTimestamp(long) - Method in class io.fluxzero.common.api.AbstractRequestResult: Updates the timestamp at which the Fluxzero Runtime received the original request.
setRequestReceivedTimestamp(long) - Method in interface io.fluxzero.common.api.RequestResult: Updates the timestamp at which the Fluxzero Runtime received the original request.
setResponseQueuedTimestamp(long) - Method in class io.fluxzero.common.api.AbstractRequestResult: Updates the timestamp at which the Fluxzero Runtime queued this response for websocket delivery.
setResponseQueuedTimestamp(long) - Method in interface io.fluxzero.common.api.RequestResult: Updates the timestamp at which the Fluxzero Runtime queued this response for websocket delivery.
setResponseSendStartTimestamp(long) - Method in class io.fluxzero.common.api.AbstractRequestResult: Updates the timestamp just before the Fluxzero Runtime encoded and sent this response.
setResponseSendStartTimestamp(long) - Method in interface io.fluxzero.common.api.RequestResult: Updates the timestamp just before the Fluxzero Runtime encoded and sent this response.
setRetentionTime(Duration) - Method in interface io.fluxzero.common.tracking.MessageStore: Sets the retention period for messages.
SetRetentionTime - Class in io.fluxzero.common.api.publishing: Command to set or update the retention period for a message log in the Fluxzero Runtime.
SetRetentionTime() - Constructor for class io.fluxzero.common.api.publishing.SetRetentionTime
setter(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
setupModule(Module.SetupContext) - Method in class io.fluxzero.common.serialization.NullCollectionsAsEmptyModule
setupModule(Module.SetupContext) - Method in class io.fluxzero.common.serialization.StripStringsModule
shouldEvict(long, long) - Method in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
shouldEvict(long, long) - Method in interface io.fluxzero.common.caching.MemoryPressureController
shouldLogMissingTimestampWarning() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata.PropertyPathMetadata
shouldLogUnsupportedTimestampWarning() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata.PropertyPathMetadata
shutdown() - Method in class io.fluxzero.common.DirectExecutorService
shutdown() - Method in class io.fluxzero.common.InMemoryTaskScheduler
shutdown() - Method in interface io.fluxzero.common.TaskScheduler: Shuts down the scheduler and stops execution of any pending or future tasks.
shutDown() - Method in class io.fluxzero.common.Backlog: Shuts down the internal executor service cleanly.
shutdownNow() - Method in class io.fluxzero.common.DirectExecutorService
signature(Executable) - Static method in class io.fluxzero.common.reflection.ParameterRegistry: Generates a string representation of a method signature using a runtime reflection Executable.
signature(ExecutableElement) - Static method in class io.fluxzero.common.reflection.ParameterRegistry: Generates a string representation of a method signature using compile-time elements.
silentTest(Predicate) - Static method in class io.fluxzero.common.ObjectUtils: Returns a predicate that silently returns false when the given predicate throws an error.
SimplePropertySource - Class in io.fluxzero.common.application: A simple in-memory implementation of the PropertySource interface backed by a Map.
SimplePropertySource() - Constructor for class io.fluxzero.common.application.SimplePropertySource
SimpleTracker - Class in io.fluxzero.common.tracking
SimpleTracker() - Constructor for class io.fluxzero.common.tracking.SimpleTracker
singleTracker() - Method in interface io.fluxzero.common.tracking.Tracker
size - Enum constant in enum class io.fluxzero.common.caching.CacheEviction.Reason: The eviction occurred due to exceeding the configured cache size.
size - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction.Reason
size() - Method in class io.fluxzero.common.api.search.SearchDocumentsResult: Returns the number of matched documents.
size() - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
size() - Method in interface io.fluxzero.common.caching.Cache: Returns the number of entries currently stored in the cache.
size() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
size() - Method in enum class io.fluxzero.common.caching.NoOpCache
skip(long) - Method in class io.fluxzero.common.LazyInputStream
Sortable - Annotation Interface in io.fluxzero.common.search: Marker annotation on fields and getters that indicates that a property is to be used for sorting and filtering.
SortableEntry - Class in io.fluxzero.common.api.search: Represents a sortable entry in a Document for use in search operations.
SortableEntry(String, Object) - Constructor for class io.fluxzero.common.api.search.SortableEntry: Constructs a new SortableEntry by formatting the given object into a normalized, sortable string.
Specificity(Class, int) - Constructor for record class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.Specificity: Creates an instance of a Specificity record class.
specificityPriority() - Method in interface io.fluxzero.common.handling.ParameterResolver: Relative priority used when multiple specificity-determining resolvers could explain a matching handler.
split(String) - Static method in class io.fluxzero.common.search.Document.Path: Splits a given path string into a stream of its segments.
splitInTerms(String) - Static method in class io.fluxzero.common.SearchUtils: Extracts quoted phrases and standalone terms from a free-form query string.
stackTrace(Throwable) - Static method in class io.fluxzero.common.ObjectUtils: Renders a throwable and its causes to the same text produced by Throwable.printStackTrace().
STARTED - Enum constant in enum class io.fluxzero.common.api.ApplicationLifecycleEvent.Phase: The application was constructed and reached a Fluxzero Runtime metrics endpoint.
STARTED - Enum constant in enum class io.fluxzero.common.api.RuntimeLifecycleEvent.Phase: The runtime has started and is ready to accept traffic.
status() - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Returns the value of the status record component.
STOPPING - Enum constant in enum class io.fluxzero.common.api.ApplicationLifecycleEvent.Phase: The application has begun a controlled shutdown.
STOPPING - Enum constant in enum class io.fluxzero.common.api.RuntimeLifecycleEvent.Phase: The runtime is about to stop accepting traffic and shut down.
STORED - Enum constant in enum class io.fluxzero.common.Guarantee: Guarantees that the message or action was stored by Fluxzero.
storePosition(String, int[], long) - Method in class io.fluxzero.common.tracking.InMemoryPositionStore
storePosition(String, int[], long) - Method in interface io.fluxzero.common.tracking.PositionStore: Stores the latest processed index for a given segment range and consumer.
StorePosition - Class in io.fluxzero.common.api.tracking: Command sent to the Fluxzero Runtime to update the tracked position for a specific consumer and segment range.
StorePosition() - Constructor for class io.fluxzero.common.api.tracking.StorePosition
StoreValueIfAbsent - Class in io.fluxzero.common.api.keyvalue: Stores a key-value pair only if the specified key does not already exist in the key-value store.
StoreValueIfAbsent() - Constructor for class io.fluxzero.common.api.keyvalue.StoreValueIfAbsent
StoreValueIfAbsent.Metric - Class in io.fluxzero.common.api.keyvalue: Lightweight metric representation for logging or monitoring.
StoreValues - Class in io.fluxzero.common.api.keyvalue: Legacy API: This command stores key-value pairs in the legacy key-value store mechanism.
StoreValues() - Constructor for class io.fluxzero.common.api.keyvalue.StoreValues
StoreValues.Metric - Class in io.fluxzero.common.api.keyvalue: Lightweight metric representation of this command.
StoreValuesAndWait - Class in io.fluxzero.common.api.keyvalue: Deprecated.
Use StoreValues instead. This class remains for compatibility but is no longer used.
StoreValuesAndWait() - Constructor for class io.fluxzero.common.api.keyvalue.StoreValuesAndWait: Deprecated.
StoreValuesAndWait.Metric - Class in io.fluxzero.common.api.keyvalue: Deprecated.

Metric representation of the deprecated store call.
StreamInputStream<T> - Class in io.fluxzero.common: Exposes the mapped contents of a Stream as an InputStream without buffering the full stream in memory.
StreamInputStream(Stream, ThrowingBiConsumer) - Constructor for class io.fluxzero.common.StreamInputStream: Constructs a StreamInputStream instance that maps the elements of the given Stream to an InputStream representation using a provided writer function.
StringResult - Class in io.fluxzero.common.api: A generic response containing a string value.
StringResult() - Constructor for class io.fluxzero.common.api.StringResult
stripAccents(String) - Static method in class io.fluxzero.common.ObjectUtils: Removes accents from a string while retaining otherwise compatible Unicode characters.
StripStringsModule - Class in io.fluxzero.common.serialization: A Jackson module that customizes the deserialization of strings.
StripStringsModule() - Constructor for class io.fluxzero.common.serialization.StripStringsModule
submit(ThrowingRunnable) - Method in class io.fluxzero.common.InMemoryTaskScheduler
submit(ThrowingRunnable) - Method in interface io.fluxzero.common.TaskScheduler: Immediately schedules a task for execution.
substituteProperties(String) - Method in interface io.fluxzero.common.application.PropertySource: Substitutes all placeholders of the form ${property[:default]} in the given template string.
substituteProperties(Properties) - Method in interface io.fluxzero.common.application.PropertySource: Substitutes all placeholders of the form ${property[:default]} in the values of the given Properties object.
substitutionPattern - Static variable in interface io.fluxzero.common.application.PropertySource: Regex pattern used for property substitution in the form ${property.name[:default]}.
summarize(Object) - Method in class io.fluxzero.common.search.JacksonInverter
summarizeMetadata(Metadata) - Method in class io.fluxzero.common.search.JacksonInverter
SUPPORTED_COMPRESSION_ALGORITHMS_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
SUPPORTED_TRANSPORT_FORMATS_HEADER - Static variable in class io.fluxzero.common.websocket.WebSocketCapabilities
Supported Types - Section in enum class io.fluxzero.common.search.Document.EntryType
supportsTimeConversion() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata.PropertyPathMetadata
supportsVirtualThreadWorkers() - Static method in class io.fluxzero.common.ObjectUtils
SystemPropertiesSource - Class in io.fluxzero.common.application: A PropertySource implementation that reads configuration properties from the JVM system properties.
SystemPropertiesSource() - Constructor for class io.fluxzero.common.application.SystemPropertiesSource

T

Task(ThrowingRunnable, long) - Constructor for class io.fluxzero.common.InMemoryTaskScheduler.Task
TaskScheduler - Interface in io.fluxzero.common: Interface for in-memory scheduling of tasks in a way that supports deterministic testing and virtualized time.
termPattern - Static variable in class io.fluxzero.common.SearchUtils: Pattern for extracting search terms and quoted phrases from a string.
test(Class, Executable) - Method in interface io.fluxzero.common.handling.HandlerFilter: Evaluates whether the specified method on the given class should be considered a valid handler.
test(M, Executable, Class, Class) - Method in interface io.fluxzero.common.handling.MessageFilter: Evaluates whether a message should be handled by a given method annotated with a specific handler annotation.
test(M, Parameter) - Method in interface io.fluxzero.common.handling.ParameterResolver: Determines whether a given message should be passed to a handler method based on this parameter's characteristics.
test(T) - Method in interface io.fluxzero.common.ThrowingPredicate: Evaluates this predicate on the given argument.
TEXT - Enum constant in enum class io.fluxzero.common.search.Document.EntryType: Represents textual values such as plain strings (e.g., "hello").
ThrowingBiConsumer<T,U> - Interface in io.fluxzero.common: BiConsumer-like interface whose ThrowingBiConsumer.accept(Object, Object) method may throw a checked Exception.
ThrowingBiFunction<T,U,R> - Interface in io.fluxzero.common: Variant of BiFunction whose ThrowingBiFunction.apply(Object, Object) method is allowed to throw a checked Exception.
ThrowingConsumer<T> - Interface in io.fluxzero.common: Functional counterpart to Consumer that allows the ThrowingConsumer.accept(Object) method to throw a checked Exception.
ThrowingFunction<T,R> - Interface in io.fluxzero.common: Equivalent of Function whose ThrowingFunction.apply(Object) method may throw a checked Exception.
ThrowingPredicate<T> - Interface in io.fluxzero.common
ThrowingRunnable - Interface in io.fluxzero.common: Runnable-like interface whose ThrowingRunnable.run() method is allowed to throw a checked Exception.
ThrowingSupplier<T> - Interface in io.fluxzero.common: Equivalent of Supplier whose ThrowingSupplier.get() method may throw a checked Exception.
time(Runnable, Consumer) - Static method in class io.fluxzero.common.TimingUtils: Executes a task and measures its execution time in milliseconds.
time(Runnable, Consumer, TemporalUnit) - Static method in class io.fluxzero.common.TimingUtils: Executes a task and measures its execution time in the specified TemporalUnit.
time(Callable, Consumer) - Static method in class io.fluxzero.common.TimingUtils: Executes a Callable and measures its execution time in milliseconds.
time(Callable, Consumer, TemporalUnit) - Static method in class io.fluxzero.common.TimingUtils: Executes a Callable and measures its execution time in the given TemporalUnit.
TimeboxedExecutor - Class in io.fluxzero.common: Utility for running tasks with a maximum execution duration.
TimeboxedExecutor() - Constructor for class io.fluxzero.common.TimeboxedExecutor
timeToInstant(Object, boolean) - Static method in class io.fluxzero.common.SearchUtils: Converts a given time object to an Instant.
TimingUtils - Class in io.fluxzero.common: Utility class for measuring execution time and retrying operations with configurable backoff and error handling.
TimingUtils() - Constructor for class io.fluxzero.common.TimingUtils
toDocument(Object, String, int, String, String, Instant, Instant, Metadata) - Method in interface io.fluxzero.common.search.Inverter: Converts the given object into a SerializedDocument, which is suitable for indexing or storage in a document store.
toDocument(Object, String, int, String, String, Instant, Instant, Metadata) - Method in class io.fluxzero.common.search.JacksonInverter
toJsonData(JsonNode, Data) - Method in class io.fluxzero.common.search.JacksonInverter
toJsonNodeInstance(Object) - Method in class io.fluxzero.common.search.JacksonInverter
toMetric() - Method in class io.fluxzero.common.api.eventsourcing.AppendEvents: Converts this command to a metric-friendly representation for logging and monitoring.
toMetric() - Method in class io.fluxzero.common.api.eventsourcing.EventBatch: Transforms this batch into a lightweight metric representation for logging and monitoring.
toMetric() - Method in class io.fluxzero.common.api.eventsourcing.GetEventsResult: Converts this result to a minimal metric object for performance logging or monitoring.
toMetric() - Method in interface io.fluxzero.common.api.JsonType: Converts this object into a compact metric representation for logging or monitoring.
toMetric() - Method in class io.fluxzero.common.api.keyvalue.GetValueResult: Lightweight representation of this response for metrics logging.
toMetric() - Method in class io.fluxzero.common.api.keyvalue.StoreValueIfAbsent
toMetric() - Method in class io.fluxzero.common.api.keyvalue.StoreValues
toMetric() - Method in class io.fluxzero.common.api.keyvalue.StoreValuesAndWait: Deprecated.
toMetric() - Method in class io.fluxzero.common.api.publishing.Append
toMetric() - Method in class io.fluxzero.common.api.scheduling.GetScheduleResult
toMetric() - Method in class io.fluxzero.common.api.scheduling.Schedule
toMetric() - Method in class io.fluxzero.common.api.scheduling.SerializedSchedule: Returns a lightweight metric representation of this schedule for monitoring purposes.
toMetric() - Method in class io.fluxzero.common.api.search.BulkUpdateDocuments: Metric representation of the bulk update, for logging or monitoring.
toMetric() - Method in class io.fluxzero.common.api.search.GetDocumentResult: Converts this result to a compact representation for metrics logging.
toMetric() - Method in class io.fluxzero.common.api.search.GetDocumentsResult: Converts this result to a compact representation for metrics logging.
toMetric() - Method in class io.fluxzero.common.api.search.GetDocumentStatsResult: Returns a lightweight summary of this result for logging or metric tracking.
toMetric() - Method in class io.fluxzero.common.api.search.GetFacetStatsResult
toMetric() - Method in class io.fluxzero.common.api.search.GetSearchCollectionsResult
toMetric() - Method in class io.fluxzero.common.api.search.IndexDocuments
toMetric() - Method in class io.fluxzero.common.api.search.SearchDocumentsResult: Converts this result into a serializable metrics object that logs match count and timing, instead of full search result payloads.
toMetric() - Method in class io.fluxzero.common.api.tracking.ClaimSegmentResult: Returns a compact metric representation of this claim for monitoring purposes.
toMetric() - Method in class io.fluxzero.common.api.tracking.MessageBatch: Converts this batch into a compact, serializable representation for monitoring purposes.
toMetric() - Method in class io.fluxzero.common.api.tracking.ReadFromIndexResult: Converts this result into a metric representation, which includes the number of messages and timestamp.
toMetric() - Method in class io.fluxzero.common.api.tracking.ReadResult: Produces a metric-friendly summary of the result for publishing to the Fluxzero metrics log.
toSortableString(Number) - Static method in class io.fluxzero.common.api.search.SortableEntry: Converts a Number to a lexicographically sortable zero-padded string.
toString() - Method in class io.fluxzero.common.api.eventsourcing.AppendEvents: Returns a human-readable description of the operation.
toString() - Method in class io.fluxzero.common.api.eventsourcing.EventBatch: Returns a human-readable representation of this batch, including its aggregate ID and event count.
toString() - Method in class io.fluxzero.common.api.keyvalue.StoreValueIfAbsent
toString() - Method in class io.fluxzero.common.api.keyvalue.StoreValues
toString() - Method in class io.fluxzero.common.api.keyvalue.StoreValuesAndWait: Deprecated.
toString() - Method in class io.fluxzero.common.api.Metadata: Returns the string representation of this object, which is the string representation of the underlying entries map.
toString() - Method in class io.fluxzero.common.api.publishing.Append
toString() - Method in class io.fluxzero.common.api.scheduling.Schedule
toString() - Method in class io.fluxzero.common.api.search.BulkUpdateDocuments
toString() - Method in class io.fluxzero.common.api.search.IndexDocuments
toString() - Method in class io.fluxzero.common.api.tracking.MessageBatch
toString() - Method in record class io.fluxzero.common.api.tracking.SegmentRange: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Returns a string representation of this record class.
toString() - Method in class io.fluxzero.common.handling.DefaultHandler
toString() - Method in class io.fluxzero.common.handling.Handler.DelegatingHandler
toString() - Method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Returns a string representation of this record class.
toString() - Method in class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
toString() - Method in record class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.Specificity: Returns a string representation of this record class.
toString() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
toString() - Method in class io.fluxzero.common.handling.HandlerMethod.DelegatingHandlerMethod
toString() - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Returns a string representation of this record class.
toString() - Method in class io.fluxzero.common.tracking.SimpleTracker
toString() - Method in class io.fluxzero.common.tracking.WebSocketTracker
Tracker - Interface in io.fluxzero.common.tracking: A Tracker represents an active consumer of messages for a particular ConsumerConfiguration.
TrackerCluster - Class in io.fluxzero.common.tracking: Represents the current set of Trackers that are connected for a specific consumer.
TrackerCluster(int) - Constructor for class io.fluxzero.common.tracking.TrackerCluster: Creates a new, empty cluster with the given number of segments.
TrackerRequest(Function) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy.TrackerRequest
Tracking Fields - Section in class io.fluxzero.common.api.SerializedMessage
trackingPath(MessageType) - Static method in class io.fluxzero.common.ServicePathBuilder: Returns the tracking path used to read (track) messages of the given MessageType.
TrackingStrategy - Interface in io.fluxzero.common.tracking: A TrackingStrategy defines how a Tracker consumes messages from a message log or distributed segment space.
trimForMemoryPressure() - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
trimForMemoryPressure() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Proactively sheds cached weight according to the configured trim ratio and maximum trim weight when the controller observes memory pressure.
trimRatioPercent() - Method in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
trimRatioPercent() - Method in interface io.fluxzero.common.caching.MemoryPressureController
truncate() - Method in class io.fluxzero.common.tracking.InMemoryPositionStore
truncate() - Method in class io.fluxzero.common.tracking.MessageLogMaintenance: Truncates the message log and clears all tracking positions.
truncate() - Method in interface io.fluxzero.common.tracking.MessageStore: Removes all messages from this store while keeping the logical log available for future appends.
truncate() - Method in interface io.fluxzero.common.tracking.PositionStore: Removes all stored consumer positions while keeping this position store available for future tracking.
Truncate - Class in io.fluxzero.common.api.publishing: Command to truncate a message log and its associated tracking positions.
Truncate() - Constructor for class io.fluxzero.common.api.publishing.Truncate
tryAccept(Consumer) - Static method in class io.fluxzero.common.ObjectUtils: Returns a consumer that logs errors instead of propagating them.
tryCatch(Runnable) - Static method in class io.fluxzero.common.ObjectUtils: Wraps a runnable in a try/catch block that logs any exception on execution.
tryLoadFile(File) - Static method in class io.fluxzero.common.FileUtils: Attempts to load file content from a File.
tryLoadFile(File, Charset) - Static method in class io.fluxzero.common.FileUtils: Attempts to load file content from a File with specified charset.
tryLoadFile(Class, String) - Static method in class io.fluxzero.common.FileUtils: Attempts to load file content relative to a reference class.
tryLoadFile(Class, String, Charset) - Static method in class io.fluxzero.common.FileUtils: Attempts to load file content with specified reference class and charset.
tryLoadFile(String) - Static method in class io.fluxzero.common.FileUtils: Attempts to load file content relative to the caller class, returns empty if not found.
tryLoadFile(String, Charset) - Static method in class io.fluxzero.common.FileUtils: Attempts to load file content with specified charset.
tryRun(Runnable) - Static method in class io.fluxzero.common.ObjectUtils: Executes the runnable and logs any thrown exception.
tryRunTask(InMemoryTaskScheduler.Task) - Method in class io.fluxzero.common.InMemoryTaskScheduler
type() - Method in record class io.fluxzero.common.handling.HandlerInspector.MethodHandlerMatcher.Specificity: Returns the value of the type record component.
type() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
typeAnnotation(Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
typeAnnotations() - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
TypedParameterResolver<M> - Class in io.fluxzero.common.handling: Abstract base class for ParameterResolvers that resolve parameters based on type matching.
TypedParameterResolver() - Constructor for class io.fluxzero.common.handling.TypedParameterResolver
typeFactory() - Static method in class io.fluxzero.common.serialization.JsonUtils: Provides access to the TypeFactory instance used by the writer.
typeFromId(DatabindContext, String) - Method in class io.fluxzero.common.serialization.GlobalTypeIdResolver
TypeRegistry - Interface in io.fluxzero.common.serialization: Interface for resolving registered types by alias or simplified name.
TypeRegistryProcessor - Class in io.fluxzero.common.serialization
TypeRegistryProcessor() - Constructor for class io.fluxzero.common.serialization.TypeRegistryProcessor
Type Resolution via @class - Section in class io.fluxzero.common.serialization.JsonUtils
TYPES_FILE - Static variable in class io.fluxzero.common.serialization.TypeRegistryProcessor
Typical usage - Section in class io.fluxzero.common.api.tracking.ClaimSegment
Typical Use - Section in class io.fluxzero.common.Backlog
Typical Use - Section in class io.fluxzero.common.api.SerializedMessage

U

unbox(Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Converts a primitive wrapper type to its primitive class and leaves other types unchanged.
unescapeFieldName(String) - Static method in class io.fluxzero.common.SearchUtils: Unescapes slashes and quotes in field names.
unknown - Enum constant in enum class io.fluxzero.common.api.search.SearchCollectionType: A collection type that is unknown to this SDK version.
unmatched() - Static method in record class io.fluxzero.common.handling.HandlerInputResolver.Resolution: Returns a result indicating that this resolver does not handle the parameter.
unmatched() - Static method in record class io.fluxzero.common.handling.KeyedParameterResolver.Resolution: Returns an outcome that allows the next parameter resolver to be considered.
unsupported() - Static method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns a result indicating that applicability cannot be prepared safely for this input.
unsupported() - Static method in record class io.fluxzero.common.handling.HandlerMethodPreparation
UNSUPPORTED - Enum constant in enum class io.fluxzero.common.handling.HandlerMethodPreparation.Status: The result cannot be prepared safely; normal per-message handler selection must be used.
unwrap(Class) - Method in interface io.fluxzero.common.tracking.MessageStore: Attempts to unwrap the current instance to a concrete implementation or extension of MessageStore.
unwrapException(Throwable) - Static method in class io.fluxzero.common.ObjectUtils: Recursively unwraps the cause of common wrapping exceptions.
UpdateRelationships - Class in io.fluxzero.common.api.modeling: Command to inform the Fluxzero Runtime about changes in entity-aggregate relationships.
UpdateRelationships() - Constructor for class io.fluxzero.common.api.modeling.UpdateRelationships
Usage - Section in annotation interface io.fluxzero.common.serialization.RegisterType
Usage - Section in class io.fluxzero.common.api.RequestBatch
Usage - Section in class io.fluxzero.common.api.eventsourcing.EventBatch
Usage - Section in class io.fluxzero.common.api.eventsourcing.GetEvents
Usage - Section in class io.fluxzero.common.api.scheduling.Schedule
Usage - Section in interface io.fluxzero.common.Registration
Usage: - Section in class io.fluxzero.common.encryption.ChaCha20Poly1305Encryption
Usage Example - Section in class io.fluxzero.common.RetryConfiguration
Usage Example - Section in class io.fluxzero.common.api.Metadata
Usage Example - Section in interface io.fluxzero.common.handling.HandlerFilter
Usage Examples - Section in class io.fluxzero.common.api.search.constraints.QueryConstraint
Usage Examples: - Section in enum class io.fluxzero.common.MessageType
Usage Note: - Section in enum class io.fluxzero.common.encryption.NoOpEncryption
Usage Notes - Section in class io.fluxzero.common.api.keyvalue.DeleteValue
Usage Notes - Section in class io.fluxzero.common.api.keyvalue.GetValue
Use Cases - Section in class io.fluxzero.common.api.ConnectEvent
Use Cases - Section in class io.fluxzero.common.api.DisconnectEvent
Use Cases - Section in class io.fluxzero.common.api.tracking.DisconnectTracker
Use Cases - Section in class io.fluxzero.common.api.tracking.GetPosition
Use Cases - Section in class io.fluxzero.common.api.tracking.GetPositionResult
Use Cases - Section in interface io.fluxzero.common.api.HasId

V

validate(M, Object, Executable, Object[]) - Method in interface io.fluxzero.common.handling.MethodInvocationValidator
Validation - Section in class io.fluxzero.common.api.search.SearchQuery
value() - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Returns the value of the value record component.
value() - Element in annotation interface io.fluxzero.common.search.Facet: Optional argument that defines the name of the facet.
value() - Element in annotation interface io.fluxzero.common.search.SearchExclude: Optional argument that defines whether this annotation is active (true) or not (false).
value() - Element in annotation interface io.fluxzero.common.search.Sortable: Optional argument that defines the name of the indexed property.
value() - Element in annotation interface io.fluxzero.common.serialization.Revision: The revision number of the annotated class.
valueOf(String) - Static method in enum class io.fluxzero.common.api.ApplicationLifecycleEvent.Phase: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.api.RuntimeLifecycleEvent.Phase: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.api.search.BulkUpdate.Type: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.api.search.SearchCollectionType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.application.EnvironmentVariablesSource: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.application.NoOpPropertySource: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.caching.CacheEviction.Reason: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction.Reason: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.caching.NoOpCache: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.encryption.NoOpEncryption: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.Guarantee: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.handling.HandlerMethodPreparation.Status: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.MessageType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.search.DefaultDocumentSerializer: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.search.Document.EntryType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.serialization.NoOpTypeRegistry: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.websocket.WebSocketTransportFormat: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.fluxzero.common.api.ApplicationLifecycleEvent.Phase: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.api.RuntimeLifecycleEvent.Phase: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.api.search.BulkUpdate.Type: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.api.search.SearchCollectionType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.application.EnvironmentVariablesSource: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.application.NoOpPropertySource: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.caching.CacheEviction.Reason: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction.Reason: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.caching.NoOpCache: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.encryption.NoOpEncryption: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.Guarantee: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.handling.HandlerMethodPreparation.Status: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.MessageType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.search.DefaultDocumentSerializer: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.search.Document.EntryType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.serialization.NoOpTypeRegistry: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.fluxzero.common.websocket.WebSocketTransportFormat: Returns an array containing the constants of this enum class, in the order they are declared.
valuesFrom(K, boolean, int) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Returns cached values ordered by key, starting at minKey.
valueToTree(Object) - Static method in class io.fluxzero.common.serialization.JsonUtils: Converts an object to a JsonNode of type T.
VoidResult - Class in io.fluxzero.common.api: A generic response indicating successful completion of a request without returning any payload.
VoidResult() - Constructor for class io.fluxzero.common.api.VoidResult

W

waitForMessages(Tracker, MessageBatch) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
waitForMessages(Tracker, MessageBatch, DefaultTrackingStrategy.TrackerRequest) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
waitForUpdate(Tracker, MessageBatch, Runnable) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
waitForUpdate(Tracker, MessageBatch, Runnable, DefaultTrackingStrategy.TrackerRequest) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
WaitingTracker() - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy.WaitingTracker
wasSkipped() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
wasSkipped() - Method in interface io.fluxzero.common.handling.HandlerInvoker: Indicates whether this invocation was deliberately skipped after handler selection.
WEBREQUEST - Enum constant in enum class io.fluxzero.common.MessageType: A tracked web request routed to a handler via HTTP or WebSocket.
WEBRESPONSE - Enum constant in enum class io.fluxzero.common.MessageType: A response to a MessageType.WEBREQUEST, typically an HTTP or WebSocket reply.
WebSocketCapabilities - Class in io.fluxzero.common.websocket: Utility methods for exchanging Fluxzero websocket client capabilities through handshake headers.
WebSocketTracker - Class in io.fluxzero.common.tracking
WebSocketTracker(Read, MessageType, String, String) - Constructor for class io.fluxzero.common.tracking.WebSocketTracker
WebSocketTransportCodec - Interface in io.fluxzero.common.websocket: Encodes and decodes Fluxzero websocket transport payloads after format negotiation and before compression.
WebSocketTransportCodecs - Class in io.fluxzero.common.websocket: Factory and built-in implementations for Fluxzero websocket transport codecs.
WebSocketTransportFormat - Enum Class in io.fluxzero.common.websocket: Wire formats supported by the Fluxzero websocket transport.
weight() - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
weight() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
weight() - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Returns the value of the weight record component.
with(Metadata) - Method in class io.fluxzero.common.api.Metadata: Creates a new instance of Metadata by combining the current metadata with the given metadata.
with(Object...) - Method in class io.fluxzero.common.api.Metadata: Creates a new Metadata instance by adding the specified key-value pairs.
with(Object, Object) - Method in class io.fluxzero.common.api.Metadata: Returns a new Metadata instance with the specified key-value pair added or updated in the current entries.
with(Map) - Method in class io.fluxzero.common.api.Metadata: Returns a new Metadata instance that includes all the current entries and the mappings provided in the given map.
withActiveTracker(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Marks the given tracker as actively processing messages.
withCollection(String) - Method in class io.fluxzero.common.api.search.SerializedDocument: Creates a new SerializedDocument instance with the specified collection name.
withData(Data) - Method in class io.fluxzero.common.api.SerializedMessage
withData(Data) - Method in class io.fluxzero.common.api.Data: Replaces this instance with another Data object.
withData(Data) - Method in interface io.fluxzero.common.api.SerializedObject: Returns a new SerializedObject with the given data object.
withLastTrackerIndex(Long) - Method in interface io.fluxzero.common.tracking.Tracker: Returns a copy of this tracker with its last index updated.
withNull(Object) - Method in class io.fluxzero.common.api.Metadata: Returns a new Metadata instance with an explicit null value associated with the given key.
without(Object) - Method in class io.fluxzero.common.api.Metadata: Returns a new Metadata instance without the specified key.
withoutIf(Predicate) - Method in class io.fluxzero.common.api.Metadata: Returns a new instance of Metadata, excluding all entries where the provided predicate evaluates to true for the entry keys.
withoutTracker(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Removes the tracker from the cluster.
withPaths(List) - Method in class io.fluxzero.common.api.search.constraints.ExistsConstraint
withPaths(List) - Method in class io.fluxzero.common.api.search.constraints.PathConstraint
withPreparation(HandlerMethodPreparation) - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Copies this result with a different preparation while retaining its cache guarantees.
withTrace(Object, Object) - Method in class io.fluxzero.common.api.Metadata: Adds a trace entry with the specified key and value to the metadata.
withWaitingTracker(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Adds or updates the tracker as waiting (not currently processing).
withZone(ZoneId) - Method in class io.fluxzero.common.DelegatingClock
writeFile(String, String) - Static method in class io.fluxzero.common.FileUtils: Writes a string to a file using UTF-8 encoding.
writeProperty(String, Object, Object) - Static method in class io.fluxzero.common.reflection.ReflectionUtils
writer - Static variable in class io.fluxzero.common.serialization.JsonUtils: Preconfigured JsonMapper for writing/serializing objects to JSON.

Z

ZSTD - Enum constant in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: Zstandard compression using the Fluxzero compression header format.

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form