Index (io.fluxzero:common 2.0.0-RC1 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(ModelCommitStep, ModelCommitTarget, int, H) - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.HeadConsumer
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.
ACCEPT - Enum constant in enum class io.fluxzero.common.api.modeling.ModelConflictPolicy: Accept the original event and silently rebase stale derived state.
accepted(long, String, List) - Static method in class io.fluxzero.common.api.modeling.CommitModelsResult: Creates an accepted commit result.
acceptedSingleTarget(long, String, long, Long, String, long, boolean) - Static method in class io.fluxzero.common.api.modeling.CommitModelsResult: Creates the common one-substep, one-target accepted result.
activeWorkers - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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.
addAllUntracked(Collection) - Method in class io.fluxzero.common.Backlog: Adds multiple values without creating per-value flush futures.
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
addUntracked(T) - Method in class io.fluxzero.common.Backlog: Adds one value without allocating a separate flush future.
adjustMaxSize(Tracker, int) - Method in class io.fluxzero.common.tracking.DefaultTrackingStrategy
AdoptModelMigration - Class in io.fluxzero.common.api.search: Atomically adopts an application-verified staged Model document.
AdoptModelMigration(String, String, Long, long, Guarantee) - Constructor for class io.fluxzero.common.api.search.AdoptModelMigration
affectsRelationships() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description
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
AliasCollisionException(String, String, String) - Constructor for exception class io.fluxzero.common.modeling.ModelCommitAssignment.AliasCollisionException
aliases() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the aliases record component.
aliases() - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Session
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
ANCESTOR - Enum constant in enum class io.fluxzero.common.api.search.ModelRelationConstraint.RelationDirection
ancestors(List, ModelReadBoundary, int, int, int, long) - Static method in class io.fluxzero.common.api.modeling.GetModelGraph: Creates a multi-root ancestor query through the same graph capability.
ANCESTORS - Enum constant in enum class io.fluxzero.common.api.modeling.GetModelGraph.TraversalDirection
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.
annotatedExecutables(Class) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata: Returns annotated methods, including inherited methods, followed by annotated constructors declared by this type.
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(long, MessageType, List, Guarantee) - Constructor for class io.fluxzero.common.api.publishing.Append: Restores an append request received through an optimized transport representation.
Append(MessageType, List, Guarantee) - 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(List, SearchDocuments) - Static method in class io.fluxzero.common.search.ModelGraphDocumentSearch: Applies the complete search request to already composed graph documents.
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.
applyPathOverrides(Collection, Collection) - Static method in class io.fluxzero.common.search.ModelGraphDocumentStitcher: Applies projection-local canonical path replacements to graph edges before composition.
applyTo(Map) - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Aliases: Applies a previously validated plan to an alias-to-model view.
array() - Method in interface io.fluxzero.common.api.Data.ByteArrayView
asBefore() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the boundary immediately before this selection.
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
asDuplicateForRequest(long) - Method in class io.fluxzero.common.api.modeling.CommitModelsResult: Copies this accepted result for an idempotent duplicate request.
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
assign(ModelCommitAssignment.Description, ModelCommitAssignment.HeadConsumer) - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Session
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.
at(Long) - Static method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns a current boundary for null, otherwise an exact state boundary.
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.api.internal.BinaryWire.Reader
available() - Method in class io.fluxzero.common.LazyInputStream
available() - Method in class io.fluxzero.common.StreamInputStream
AwaitModelGraphProjection - Class in io.fluxzero.common.api.modeling: Waits until one materialized graph projection has completed every root update originating at or before a committed model state.
AwaitModelGraphProjection(String, long) - Constructor for class io.fluxzero.common.api.modeling.AwaitModelGraphProjection: Creates a collection-wide projection barrier.
AwaitModelGraphProjection(String, long, Long, Collection) - Constructor for class io.fluxzero.common.api.modeling.AwaitModelGraphProjection
AwaitModelGraphProjection(String, long, Collection) - Constructor for class io.fluxzero.common.api.modeling.AwaitModelGraphProjection: Creates a projection barrier for the supplied affected models when the commit consists of one state transition.
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, int) - 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.
Batch() - Constructor for class io.fluxzero.common.jfr.FluxzeroJfr.Batch
batchEnabled() - Static method in class io.fluxzero.common.jfr.FluxzeroJfr: Returns whether batch diagnostics are enabled in the active recording.
before() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the value of the before record component.
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
binary(ObjectMapper) - Static method in class io.fluxzero.common.websocket.WebSocketTransportCodecs: Negotiated binary codec.
binary(ObjectMapper, List) - Static method in class io.fluxzero.common.websocket.WebSocketTransportCodecs: Negotiated binary codec extended with protocol-specific compact payload representations.
BINARY - Enum constant in enum class io.fluxzero.common.websocket.WebSocketTransportFormat: Native binary transport.
BinaryWire - Class in io.fluxzero.common.api.internal: Allocation-bounded primitive I/O shared by compact transports and persisted messages.
BinaryWire.Cursor - Class in io.fluxzero.common.api.internal: Unchecked cursor for validated embedded values whose public API does not expose I/O failures.
BinaryWire.Reader - Class in io.fluxzero.common.api.internal
BinaryWire.Writer - Class in io.fluxzero.common.api.internal
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.
build() - Method in class io.fluxzero.common.api.Metadata.Builder: Builds immutable metadata that remains compact until its serialized representation is needed.
builder(int) - Static method in class io.fluxzero.common.api.Metadata: Creates a compact metadata builder for values that are already normalized to strings.
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.
byteArrayView() - Method in class io.fluxzero.common.api.Data: Returns a read-only byte range when the value supplier can expose one without materializing a new array.
byteLimited() - Method in record class io.fluxzero.common.tracking.MessageStoreBatch: Returns the value of the byteLimited record component.
bytes - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
bytes() - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
bytes() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
bytes() - Method in class io.fluxzero.common.api.search.SerializedDocument: Returns the number of bytes in the serialized representation of the document.
BYTES - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupport.WeightUnit
bytesSize(byte[]) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns the encoded size of one nullable length-prefixed byte array.

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.
callbackNanos - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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.
cascadeRootIds() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the cascadeRootIds record component.
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
Change(String, Set) - Constructor for record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change
Change(String, Set, boolean) - Constructor for record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change: Creates an instance of a Change record class.
changes() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Step: Returns the value of the changes record component.
changes() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipStep: Returns the value of the changes record component.
checkForCycle() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change: Returns the value of the checkForCycle record component.
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.
childId() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change: Returns the value of the childId record component.
childId() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange: Returns the value of the childId record component.
childId() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
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.
COLLECTION - Static variable in class io.fluxzero.common.api.modeling.ModelSnapshotMutation
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(long) - Constructor for class io.fluxzero.common.api.Command: Restores a request identifier while decoding an optimized transport representation.
COMMAND - Enum constant in enum class io.fluxzero.common.MessageType: A request to perform an action or change state.
commit(String, int) - Static method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Creates a boundary at a commit substep.
COMMIT - Enum constant in enum class io.fluxzero.common.api.modeling.ModelUpdateKind: One persisted model-commit step.
COMMIT_ID - Static variable in class io.fluxzero.common.api.modeling.ModelEventMetadata: Durable idempotency identity of the model commit that emitted an event.
commitId() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the value of the commitId record component.
commitId() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the commitId record component.
CommitModels - Class in io.fluxzero.common.api.modeling: Atomically commits the ordered state transitions produced by one model commit.
CommitModels(String, long, List, List, ModelConflictPolicy, Guarantee, boolean) - Constructor for class io.fluxzero.common.api.modeling.CommitModels
CommitModels(String, long, List, List, ModelConflictPolicy, Guarantee, boolean, boolean) - Constructor for class io.fluxzero.common.api.modeling.CommitModels
CommitModels.Metric - Class in io.fluxzero.common.api.modeling: Payload-free model commit metrics.
CommitModelsResult - Class in io.fluxzero.common.api.modeling: Result of an accepted, rebase-requested, or conflict-rejected CommitModels.
CommitModelsResult(long, String, List, List, boolean, boolean, Long) - Constructor for class io.fluxzero.common.api.modeling.CommitModelsResult: Creates a model commit result, normalizing omitted compatibility fields to empty collections.
CommitModelsResult.Metric - Class in io.fluxzero.common.api.modeling: Payload-free commit-result metrics.
compactAcceptedResult(long, long, Long, long, boolean) - Static method in class io.fluxzero.common.api.modeling.ModelCommitWireCodec: Creates the compact transport form of an accepted single-target result without the durable commit and model identities owned by its correlated request.
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.
component - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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.
conflict(long, String, List, boolean) - Static method in class io.fluxzero.common.api.modeling.CommitModelsResult: Creates a rejected conflict result.
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.
create(String, H, String, long, long, Long, boolean, String) - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.HeadFactory
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
current() - Static method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the shared current-state boundary.
CURRENT - Static variable in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Unpinned current-state boundary including active message-batch values.
CURRENT_VERSION - Static variable in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Current manifest format version.
currentGraph(Collection, int, int, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves the current composable descendant graph for a root page.
Cursor(byte[], int, int, int) - Constructor for class io.fluxzero.common.api.internal.BinaryWire.Cursor
CUSTOM - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupport.WeightUnit
CUSTOM - Enum constant in enum class io.fluxzero.common.MessageType: A message from a custom message topic.
cycle(Collection, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipTraversal: Returns the first reachable cycle, including its repeated closing node, or an empty list.

D

data() - Method in class io.fluxzero.common.api.Data: Returns this instance (for SerializedObject compatibility).
data() - Method in record class io.fluxzero.common.api.modeling.ModelEventDataBlock: Returns the value of the data record component.
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.
DATA_FORMAT - Static variable in class io.fluxzero.common.api.Metadata: Compact binary format used to carry metadata opaquely through the runtime.
DATA_TYPE - Static variable in class io.fluxzero.common.api.Metadata: Type stored in the Data envelope returned by Metadata.toData().
Data.ByteArrayView - Interface in io.fluxzero.common.api: Read-only view of a byte-array range for serializers that can consume a slice directly.
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[]) - Static method in class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder: Decodes one stored stream batch.
decode(byte[]) - Static method in class io.fluxzero.common.serialization.SerializedMessagePackCodec: Decodes zero or more consecutive serialized messages.
decode(byte[]) - Method in interface io.fluxzero.common.websocket.WebSocketTransportCodec: Decodes transport bytes into a protocol object.
decode(byte[], int, int) - Static method in class io.fluxzero.common.serialization.SerializedMessagePackCodec: Decodes consecutive serialized messages from a zero-copy byte range.
decode(ModelEventDataBlock) - Static method in class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder: Decodes one stored stream batch directly from a byte range.
decodeEnvelope(byte[], int) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Decodes exactly one native message envelope while retaining zero-copy payload and metadata views.
decodeEnvelopes(byte[], int) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Decodes a sequence while retaining zero-copy payload and metadata views.
decodeEnvelopes(byte[], int, int, int) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Decodes a native-envelope sequence from a byte range.
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.
decompress(byte[], int, int) - Method in enum class io.fluxzero.common.serialization.compression.CompressionAlgorithm: Decompresses one byte range without first copying that range into a temporary array.
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 - Enum constant in enum class io.fluxzero.common.api.modeling.ModelConflictPolicy: Inherit from the next broader model-commit scope.
DEFAULT_GC_CACHE_UTILIZATION_PERCENT - Static variable in class io.fluxzero.common.caching.MemoryPressureController.JvmMemoryPressureController
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_MAX_DEPTH - Static variable in class io.fluxzero.common.api.modeling.PlanModelDeletion
DEFAULT_MAX_MODELS - Static variable in class io.fluxzero.common.api.modeling.PlanModelDeletion
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_SAMPLE_SIZE - Static variable in class io.fluxzero.common.api.modeling.PlanModelDeletion
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, String) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy
DefaultTrackingStrategy(MessageStore, PositionStore, String) - Constructor for class io.fluxzero.common.tracking.DefaultTrackingStrategy: Creates a strategy whose JFR batch metrics identify the logical message log.
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
deleted() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange: Returns the value of the deleted record component.
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
DeleteModel - Class in io.fluxzero.common.api.modeling: Executes or resumes one explicit independent-model hard deletion.
DeleteModel() - Constructor for class io.fluxzero.common.api.modeling.DeleteModel
DeleteModel.Metric - Class in io.fluxzero.common.api.modeling
deleteOnParentDeletion() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
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
deletionFingerprint(String, ModelDeletionCascade, List) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Stable fingerprint for one ordered hard-deletion selection.
DESCENDANT - Enum constant in enum class io.fluxzero.common.api.search.ModelRelationConstraint.RelationDirection
descendantLineage(Collection, long, int, int, Function, Function, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves current and lifecycle-retained descendants at one boundary.
descendantLineage(Collection, long, int, int, Function, Function, Function, String, String) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves descendants with caller-specific bound failures.
descendants(Collection, ModelRelationshipTraversal.RelationshipLoader) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Traverses an already selected child index without recreating frontier and visit semantics.
DESCENDANTS - Enum constant in enum class io.fluxzero.common.api.modeling.GetModelGraph.TraversalDirection
DESCENDANTS - Enum constant in enum class io.fluxzero.common.api.modeling.ModelDeletionCascade: Select the requested model and every current or parent-deletion-detached descendant.
describe(CommitModels) - Static method in class io.fluxzero.common.modeling.ModelCommitAssignment: Describes target scope and optional work before positions are assigned.
Description(CommitModels, List, List, boolean, List, Set, List, ModelCommitAssignment.Aliases) - Constructor for record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Creates an instance of a Description record class.
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.
desired() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange: Returns the value of the desired record component.
detect(CommitModels, Map, ToLongFunction, ToLongFunction, Map) - Static method in class io.fluxzero.common.modeling.ModelCommitConflicts: Detects stale read-state and expected-sequence conflicts in stable request order.
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.
documentCollection() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the documentCollection record component.
documentCollection() - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.Head
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

edge() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
edges() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Result: Returns the value of the edges record component.
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(long) - Static method in class io.fluxzero.common.api.modeling.ModelStateIndexCodec: Returns an order-preserving representation of the complete signed long range.
encode(JsonType) - Method in interface io.fluxzero.common.websocket.WebSocketTransportCodec: Encodes a protocol object into transport bytes.
encodedMetadataContainsKey(byte[], int, int, String) - Static method in class io.fluxzero.common.api.SerializedMessage
encodedMetadataLongValue(byte[], int, int, String, long) - Static method in class io.fluxzero.common.api.SerializedMessage
encodedMetadataValue(byte[], int, int, String) - Static method in class io.fluxzero.common.api.SerializedMessage
encodeEnvelope(SerializedMessage) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Encodes one native message envelope.
encodeEnvelopes(List) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Encodes a sequence of concatenated native message envelopes.
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
ENTRIES - Enum constant in enum class io.fluxzero.common.caching.MemoryAwareCacheSupport.WeightUnit
Entry() - Constructor for class io.fluxzero.common.search.Document.Entry
Entry(String, String, long, long, String, int, long, long, boolean, long, String) - Constructor for record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Creates an instance of a Entry record class.
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
envelopeSize(SerializedMessage) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns the complete encoded size of one native message envelope.
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 class io.fluxzero.common.api.Metadata
equals(Object) - Method in record class io.fluxzero.common.api.modeling.ModelEventDataBlock: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.api.modeling.ModelGraphProjectionConfiguration.ModelRevision: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Step: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.api.search.GetModelMigrationsResult.Metric: Indicates whether some other object is "equal to" this one.
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.modeling.ModelCommitAssignment.Description: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipStep: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.modeling.ModelRelationshipQueries.ResolvedBoundary: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Result: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: 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(long) - Static method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Creates a boundary at an event index.
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.
eventIndex() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the value of the eventIndex record component.
eventIndex() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the eventIndex record component.
eventIndex(ModelCommitStep) - Static method in class io.fluxzero.common.modeling.ModelCommitAssignment: Returns the existing or newly assigned global event index carried by a commit step.
eventOrCurrent(long) - Static method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Creates an event boundary that retains current-state behavior when the event has no Model mapping.
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.
exact() - Method in record class io.fluxzero.common.modeling.ModelRelationshipQueries.ResolvedBoundary: Returns the value of the exact record component.
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
expand(GetModelEvents, GetModelEventsResult) - Static method in class io.fluxzero.common.api.modeling.ModelEventPageDecoder: Returns the logical page for a request.
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.
FACET_NAME - Static variable in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Internal facet marker that lets document trackers avoid inspecting ordinary document payloads.
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
FAIL - Enum constant in enum class io.fluxzero.common.api.modeling.ModelConflictPolicy: Reject a stale commit and let the client map the conflict to an application decision.
failed - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
failureType - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
fallbackToCurrent() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the value of the fallbackToCurrent record component.
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.
finalDeletedModelIds() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the finalDeletedModelIds record component.
finalDeletedParentIds() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipStep: Returns the value of the finalDeletedParentIds record component.
finish(FluxzeroJfr.Batch, Throwable) - Static method in class io.fluxzero.common.jfr.FluxzeroJfr: Completes and conditionally commits a batch event.
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.
firstIncompleteStateIndex() - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.Head
firstKey() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
firstStateIndex() - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Commit
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.
FluxzeroJfr - Class in io.fluxzero.common.jfr: Shared low-overhead JFR events for Fluxzero batch operations across SDK and Runtime components.
FluxzeroJfr.Batch - Class in io.fluxzero.common.jfr: One completed batch operation in the SDK or Runtime pipeline.
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, int) - Static method in class io.fluxzero.common.Backlog: Creates a backlog for an asynchronous consumer with a bounded number of in-flight batches.
forAsyncConsumer(ThrowingFunction, int, int, ErrorHandler) - Static method in class io.fluxzero.common.Backlog: Creates a bounded asynchronous backlog with a custom 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.
forAsyncConsumer(ThrowingFunction, int, ToLongFunction, long, int) - Static method in class io.fluxzero.common.Backlog: Creates an asynchronous backlog bounded by item count, cumulative item weight and in-flight batches.
forAsyncConsumer(ThrowingFunction, int, ToLongFunction, long, int, Duration) - Static method in class io.fluxzero.common.Backlog: Creates an asynchronous backlog bounded by item count, cumulative item weight and in-flight batches, with a bounded collection delay whenever an idle backlog starts flushing.
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.
forFormat(WebSocketTransportFormat, ObjectMapper, List) - Static method in class io.fluxzero.common.websocket.WebSocketTransportCodecs: Creates a codec with optional protocol-specific compact payload representations.
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: Deprecated, for removal: This API element is subject to removal in a future version.
Use Backlog.forAsyncConsumer(ThrowingFunction, int, int) with one in-flight batch.
forOrderedAsyncConsumer(ThrowingFunction, int) - Static method in class io.fluxzero.common.Backlog: Deprecated, for removal: This API element is subject to removal in a future version.
Use Backlog.forAsyncConsumer(ThrowingFunction, int, int) with one in-flight batch.
forOrderedAsyncConsumer(ThrowingFunction, int, ErrorHandler) - Static method in class io.fluxzero.common.Backlog: Deprecated, for removal: This API element is subject to removal in a future version.
Use Backlog.forAsyncConsumer(ThrowingFunction, int, int, ErrorHandler) with one in-flight batch.
forOrderedAsyncConsumer(ThrowingFunction, int, ToLongFunction, long) - Static method in class io.fluxzero.common.Backlog: Deprecated, for removal: This API element is subject to removal in a future version.
Use Backlog.forAsyncConsumer(ThrowingFunction, int, ToLongFunction, long, int) with one in-flight batch.
forOrderedAsyncConsumer(ThrowingFunction, int, ToLongFunction, long, Duration) - Static method in class io.fluxzero.common.Backlog: Deprecated, for removal: This API element is subject to removal in a future version.
Use Backlog.forAsyncConsumer(ThrowingFunction, int, ToLongFunction, long, int, Duration) with one in-flight batch.
forPayloadTarget(Class, Function, HandlerMatcher) - Static method in class io.fluxzero.common.handling.DefaultHandler: Creates a handler for methods declared on the message payload itself.
forRequest() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the durable selector form carried by a storage request.
forRequest(long) - Method in class io.fluxzero.common.api.modeling.CommitModelsResult: Copies this logical result with another transport request ID.
forRequest(long, boolean) - Method in class io.fluxzero.common.api.modeling.ModelDeletionResult: Returns this durable result correlated to a retrying request.
forTarget(Class, Object, HandlerMatcher) - Static method in class io.fluxzero.common.handling.DefaultHandler
from(Metadata) - Static method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Reads the manifest from document metadata when present.
from(SerializedDocument) - Static method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Reads the manifest from a composed graph document when present.
fromData(Data) - Static method in class io.fluxzero.common.api.Metadata: Restores metadata from its compact serialized representation without eagerly constructing keys, values or a backing map.
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
getAnnotatedPropertyValueOrNull(Object, Class) - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns the value of the first property carrying the given annotation, or null when the target, annotated property, or property value is absent.
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 complete serialized message 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 complete serialized message 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 complete serialized size of all messages within all batches.
getBytes() - Method in class io.fluxzero.common.api.eventsourcing.EventBatch: Calculates the complete serialized size of all messages within the batch.
getBytes() - Method in class io.fluxzero.common.api.modeling.CommitModels: Returns the complete serialized event-message bytes carried once by this commit.
getBytes() - Method in class io.fluxzero.common.api.modeling.ModelCommitStep: Complete serialized event-message bytes carried by this substep.
getBytes() - Method in class io.fluxzero.common.api.modeling.ModelDocumentMutation: Returns the serialized document payload size without counting protocol framing.
getBytes() - Method in class io.fluxzero.common.api.modeling.ModelSnapshotMutation: Returns the serialized value size without protocol framing.
getBytes() - Method in class io.fluxzero.common.api.search.BulkUpdateDocuments
getBytes() - Method in class io.fluxzero.common.api.SerializedMessage: Returns the exact size used by the compact binary transports.
getBytes() - Method in class io.fluxzero.common.api.tracking.MessageBatch: Calculates the complete serialized size of 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(String, String) - Constructor for class io.fluxzero.common.api.search.GetDocument
GetDocument(String, String, boolean) - 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(long, SerializedDocument) - Constructor for class io.fluxzero.common.api.search.GetDocumentResult
GetDocumentResult(long, SerializedDocument, ModelHeadState) - 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.
getLag() - Method in class io.fluxzero.common.api.modeling.ModelGraphProjectionStatus: Non-negative state-index lag at observation time.
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.
getMetadataLongValue(String, long) - Method in class io.fluxzero.common.api.SerializedMessage: Returns a decimal metadata value, or the fallback when absent or malformed.
getMetadataValue(String) - Method in class io.fluxzero.common.api.SerializedMessage: Returns one metadata value, or null when metadata or the key is absent.
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
GetModelChange - Class in io.fluxzero.common.api.modeling: Resolves the durable targets and exact state boundary of one independent-model commit substep.
GetModelChange() - Constructor for class io.fluxzero.common.api.modeling.GetModelChange
GetModelChange.Metric - Class in io.fluxzero.common.api.modeling: Target-free metric representation.
GetModelChangeResult - Class in io.fluxzero.common.api.modeling: Durable target identities and types for one model-commit substep.
GetModelChangeResult() - Constructor for class io.fluxzero.common.api.modeling.GetModelChangeResult
GetModelChangeResult.Metric - Class in io.fluxzero.common.api.modeling: Identity-free metric representation.
GetModelEvents - Class in io.fluxzero.common.api.modeling: Batch-loads independent model stream memberships at one namespace-wide state boundary.
GetModelEvents(List, ModelReadBoundary, long) - Constructor for class io.fluxzero.common.api.modeling.GetModelEvents
GetModelEvents.Metric - Class in io.fluxzero.common.api.modeling
GetModelEventsResult - Class in io.fluxzero.common.api.modeling: Model heads and stream memberships observed at one pinned GetModelEventsResult.stateIndex.
GetModelEventsResult(long, long, boolean, List, List) - Constructor for class io.fluxzero.common.api.modeling.GetModelEventsResult
GetModelEventsResult(long, long, boolean, List, List, long[], List, long[], List) - Constructor for class io.fluxzero.common.api.modeling.GetModelEventsResult
GetModelEventsResult(long, long, List, List) - Constructor for class io.fluxzero.common.api.modeling.GetModelEventsResult
GetModelEventsResult.Metric - Class in io.fluxzero.common.api.modeling
GetModelGraph - Class in io.fluxzero.common.api.modeling: Resolves one bounded independent-model relationship graph and optionally includes the first page of every selected model stream.
GetModelGraph(String, ModelReadBoundary, int, int, int, long, boolean) - Constructor for class io.fluxzero.common.api.modeling.GetModelGraph: Creates the ordinary single-root descendant query used by public Graph loads.
GetModelGraph(List, ModelReadBoundary, int, int, int, long, GetModelGraph.TraversalDirection, boolean) - Constructor for class io.fluxzero.common.api.modeling.GetModelGraph
GetModelGraph.Metric - Class in io.fluxzero.common.api.modeling
GetModelGraph.TraversalDirection - Enum Class in io.fluxzero.common.api.modeling
GetModelGraphProjectionStatus - Class in io.fluxzero.common.api.modeling: Requests freshness and backlog state for one materialized graph collection.
GetModelGraphProjectionStatus(String) - Constructor for class io.fluxzero.common.api.modeling.GetModelGraphProjectionStatus
GetModelGraphResult - Class in io.fluxzero.common.api.modeling: Temporal graph edges and one model-event page observed at the same pinned state boundary.
GetModelGraphResult(long, List, GetModelEventsResult) - Constructor for class io.fluxzero.common.api.modeling.GetModelGraphResult
GetModelGraphResult.Metric - Class in io.fluxzero.common.api.modeling
GetModelMigration - Class in io.fluxzero.common.api.search: Retrieves the production and staged direct documents needed to verify one Model migration.
GetModelMigration() - Constructor for class io.fluxzero.common.api.search.GetModelMigration
GetModelMigrationResult - Class in io.fluxzero.common.api.search: Production and staged state for an application-verified direct Model migration.
GetModelMigrationResult(long, SerializedDocument, Long, SerializedDocument, ModelHeadState) - Constructor for class io.fluxzero.common.api.search.GetModelMigrationResult
GetModelMigrationResult.Metric - Record Class in io.fluxzero.common.api.search: Content-free metrics representation.
GetModelMigrations - Class in io.fluxzero.common.api.search: Retrieves a bounded batch of staged direct Model migrations for application-level adoption.
GetModelMigrations(int) - Constructor for class io.fluxzero.common.api.search.GetModelMigrations
GetModelMigrationsResult - Class in io.fluxzero.common.api.search: A bounded batch of durable heads from the otherwise invisible Model-migration staging area.
GetModelMigrationsResult(long, List) - Constructor for class io.fluxzero.common.api.search.GetModelMigrationsResult
GetModelMigrationsResult.Metric - Record Class in io.fluxzero.common.api.search: Content-free metrics representation.
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 payload revision before any upcasting.
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
getRegisteredTypes() - Static method in class io.fluxzero.common.reflection.ReflectionUtils: Returns the loadable types from the generated application type registry.
getRelationCount() - Method in class io.fluxzero.common.api.modeling.ModelCommitStep: Number of desired current parent relationships carried by all targets.
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
getStoredTargetCount() - Method in class io.fluxzero.common.api.modeling.ModelCommitStep: Number of target streams receiving an event membership.
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.
getTypeNames() - Method in class io.fluxzero.common.serialization.DefaultTypeRegistry
getTypeNames() - Method in interface io.fluxzero.common.serialization.TypeRegistry: Returns the fully qualified names that make up this registry.
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
graph(GetModelGraph, long, boolean, Function, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves a graph while retaining evidence about the original selector that established its boundary.
graph(GetModelGraph, long, Function, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves one bounded relationship graph and its first stream page.
GRAPH_COMPONENT_COLLECTION_PREFIX - Static variable in class io.fluxzero.common.api.modeling.ModelDocumentMutation: Prefix for type-isolated internal graph-component collections.
graphAncestors(Collection, int, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves composable ancestors with one shared traversal policy.
graphComponentCollection(String) - Static method in class io.fluxzero.common.api.modeling.ModelDocumentMutation: Returns the private search collection for current graph-component documents of one model type.
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
HARD_DELETE - Enum constant in enum class io.fluxzero.common.api.modeling.ModelUpdateKind: A prepared physical model erasure fence.
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 class io.fluxzero.common.api.Metadata
hashCode() - Method in record class io.fluxzero.common.api.modeling.ModelEventDataBlock: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.api.modeling.ModelGraphProjectionConfiguration.ModelRevision: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Step: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.api.search.GetModelMigrationsResult.Metric: Returns a hash code value for this object.
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.modeling.ModelCommitAssignment.Description: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipStep: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.modeling.ModelRelationshipQueries.ResolvedBoundary: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Result: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns a hash code value for this object.
hashCode() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: 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.
hasMaterialization() - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Commit
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
hasSingleTargetResult() - Method in class io.fluxzero.common.api.modeling.CommitModelsResult: Returns whether this result contains exactly one committed target position.
hasTypeFilter() - Method in interface io.fluxzero.common.tracking.Tracker: Indicates whether Tracker.getTypeFilter() imposes an actual constraint.
hasTypeFilter() - Method in class io.fluxzero.common.tracking.WebSocketTracker
historical() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Indicates whether this selection refers to a durable historical boundary.
historyComplete() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the historyComplete record component.
historyComplete() - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.Head

I

id() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Returns the value of the id record component.
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
includeDocumentTombstones() - Method in interface io.fluxzero.common.tracking.Tracker
includeMessageBatch() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the value of the includeMessageBatch record component.
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, Collection, List, HandlerConfiguration) - Static method in class io.fluxzero.common.handling.HandlerInspector: Builds a matcher from centrally cached structural handler metadata.
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.api.modeling.ModelWebSocketCodec
INSTANCE - Enum constant in enum class io.fluxzero.common.api.tracking.TrackingWebSocketCodec
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.internal - package io.fluxzero.common.api.internal
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.jfr - package io.fluxzero.common.jfr
io.fluxzero.common.modeling - package io.fluxzero.common.modeling
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
isAccepted() - Method in class io.fluxzero.common.api.modeling.CommitModelsResult: Returns whether the runtime committed the commit.
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
isCompactResult(RequestResult) - Static method in class io.fluxzero.common.api.modeling.ModelCommitWireCodec: Returns whether a result can use the compact single-target wire representation.
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.modeling.ModelCommitAssignment.Aliases
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
isEnvelopeSequence(byte[]) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns whether the byte sequence starts with this codec's native-envelope signature.
isEnvelopeSequence(byte[], int, int) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns whether a byte range starts with this codec's native-envelope signature.
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
isGraphDocument(SerializedDocument) - Static method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns whether a document advertises the hidden typed-graph manifest without decoding its metadata.
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.
isRebaseRequired() - Method in class io.fluxzero.common.api.modeling.CommitModelsResult: Returns whether the runtime requests an internal apply-only rebase without rejecting the original event.
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.
itemCount - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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.
jdbcRoundTrips - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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.
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.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.
length() - Method in interface io.fluxzero.common.api.Data.ByteArrayView
length() - Method in record class io.fluxzero.common.api.modeling.ModelEventDataBlock: Returns the value of the length record component.
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.
load(Collection) - Method in interface io.fluxzero.common.modeling.ModelRelationshipTraversal.RelationshipLoader
load(Set) - Method in interface io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.ParentLoader
load(Set) - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.ChildLoader
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.
longsSize(long[]) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns the encoded size of one nullable length-prefixed long array.
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
markPossibleDuplicate() - Method in class io.fluxzero.common.api.modeling.CommitModels
markPossibleDuplicate() - Method in interface io.fluxzero.common.api.RetryAwareRequest: Marks the same logical request as a possible retry before it is sent again.
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.BetweenConstraint
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
maxDepth() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns the value of the maxDepth record component.
maxDepthMessage() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns the value of the maxDepthMessage record component.
maxEntryWeight() - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport
maxModels() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns the value of the maxModels record component.
maxModelsMessage() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns the value of the maxModelsMessage record component.
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.
mayMaterialize() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the mayMaterialize record component.
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_CACHE_UTILIZATION_PERCENT_PROPERTY - Static variable in interface io.fluxzero.common.caching.MemoryPressureController: Minimum occupied percentage of a cache's configured weight budget before sustained GC time alone may trigger trimming.
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: Post-GC 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
MemoryAwareCacheSupport(long, long, ToLongBiFunction, Comparator, MemoryPressureController, Duration, MemoryAwareCacheSupport.WeightUnit) - Constructor for class io.fluxzero.common.caching.MemoryAwareCacheSupport
MemoryAwareCacheSupport.WeightUnit - Enum Class in io.fluxzero.common.caching: Unit represented by a cache weight.
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.
mergeAll(Map, BiFunction) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
mergeAll(Map, BiFunction) - Method in interface io.fluxzero.common.caching.Cache: Merges a bounded group of candidate values into this cache.
mergeAll(Map, BiFunction) - Method in enum class io.fluxzero.common.caching.NoOpCache
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 - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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_KEY - Static variable in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Reserved document-metadata key containing the manifest.
METADATA_PATH_PREFIX - Static variable in class io.fluxzero.common.search.JacksonInverter
Metadata.Builder - Class in io.fluxzero.common.api: Builder for compact metadata whose keys and values are already strings.
metadataContainsKey(String) - Method in class io.fluxzero.common.api.SerializedMessage: Checks a metadata key without forcing callers to handle absent metadata.
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.modeling.CommitModels.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.CommitModelsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.DeleteModel.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.GetModelChange.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.GetModelChangeResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.GetModelEvents.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.GetModelEventsResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.GetModelGraph.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.GetModelGraphResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.ModelDeletionPlan.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.ModelDeletionResult.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.PlanModelDeletion.Metric
Metric() - Constructor for class io.fluxzero.common.api.modeling.TrackModelUpdatesResult.Metric
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.search.SearchModelDocuments.Metric
Metric() - Constructor for class io.fluxzero.common.api.search.SearchModelGraphDocuments.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
Metric(long, boolean, boolean, boolean) - Constructor for record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Creates an instance of a Metric record class.
Metric(long, int) - Constructor for record class io.fluxzero.common.api.search.GetModelMigrationsResult.Metric: Creates an instance of a Metric record class.
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
migratedDocumentPresent() - Method in record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Returns the value of the migratedDocumentPresent record component.
MIGRATION_COLLECTION - Static variable in class io.fluxzero.common.api.modeling.ModelDocumentMutation: Internal collection containing crash-safe direct-document state while published legacy events are being rebuilt.
migrationCount() - Method in record class io.fluxzero.common.api.search.GetModelMigrationsResult.Metric: Returns the value of the migrationCount record component.
migrationPresent() - Method in record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Returns the value of the migrationPresent record component.
millis() - Method in class io.fluxzero.common.DelegatingClock
MODEL_ID_FACET - Static variable in class io.fluxzero.common.api.modeling.ModelSnapshotMutation
ModelChangeTarget - Class in io.fluxzero.common.api.modeling: One model identity changed by a durable model-commit substep.
ModelChangeTarget() - Constructor for class io.fluxzero.common.api.modeling.ModelChangeTarget
ModelCommitAssignment - Class in io.fluxzero.common.modeling: Owns storage-neutral Model commit description, head assignment and accepted-result construction.
ModelCommitAssignment.AliasCollisionException - Exception Class in io.fluxzero.common.modeling: Signals that one alias would identify two different models.
ModelCommitAssignment.Aliases - Class in io.fluxzero.common.modeling: Final alias replacements and their requested owners in commit order.
ModelCommitAssignment.ChildLoader - Interface in io.fluxzero.common.modeling: Batch-loads current children for deleted parent IDs.
ModelCommitAssignment.Commit<H> - Class in io.fluxzero.common.modeling: One fully assigned commit.
ModelCommitAssignment.Description - Record Class in io.fluxzero.common.modeling: Storage-neutral work known before assignment.
ModelCommitAssignment.Head - Interface in io.fluxzero.common.modeling: Store head values needed to assign the next transition.
ModelCommitAssignment.HeadConsumer<H> - Interface in io.fluxzero.common.modeling: Receives assigned heads so a store can build only its own persistence representation.
ModelCommitAssignment.HeadFactory<H> - Interface in io.fluxzero.common.modeling: Constructs a compact store-specific head from the values assigned by this owner.
ModelCommitAssignment.RelationshipChange - Record Class in io.fluxzero.common.modeling: The desired parent set for one child after a relationship-changing target.
ModelCommitAssignment.RelationshipStep - Record Class in io.fluxzero.common.modeling: Relationship changes and final parent deletions applied at one state index.
ModelCommitAssignment.Session<H> - Class in io.fluxzero.common.modeling: Mutable ordering state for one atomic assignment batch.
ModelCommitConflict - Class in io.fluxzero.common.api.modeling: Current runtime positions for one model identity involved in a rejected model commit.
ModelCommitConflict() - Constructor for class io.fluxzero.common.api.modeling.ModelCommitConflict
ModelCommitConflicts - Class in io.fluxzero.common.modeling: Owns generic model-commit conflict detection and conflict-policy outcomes.
ModelCommitStep - Class in io.fluxzero.common.api.modeling: One ordered original event and all model targets affected by it.
ModelCommitStep() - Constructor for class io.fluxzero.common.api.modeling.ModelCommitStep
ModelCommitTarget - Class in io.fluxzero.common.api.modeling: Persistence and lifecycle effects of one original event on one independently stored model.
ModelCommitTarget() - Constructor for class io.fluxzero.common.api.modeling.ModelCommitTarget
ModelCommitTargetResult - Class in io.fluxzero.common.api.modeling: Resulting stream/head metadata for one committed target model.
ModelCommitTargetResult() - Constructor for class io.fluxzero.common.api.modeling.ModelCommitTargetResult
ModelCommitValidator - Class in io.fluxzero.common.api.modeling: Structural validation for the independent-model wire protocol.
ModelCommitWireCodec - Class in io.fluxzero.common.api.modeling: Compact websocket representation for the common one-event, one-target model commit.
ModelConflictPolicy - Enum Class in io.fluxzero.common.api.modeling: Runtime behavior when an commit-scoped model changed after the commit's readStateIndex.
ModelDeletionCascade - Enum Class in io.fluxzero.common.api.modeling: Required scope of an explicit independent-model hard deletion.
ModelDeletionPlan - Class in io.fluxzero.common.api.modeling: Bounded dry-run result for one explicit independent-model hard deletion.
ModelDeletionPlan() - Constructor for class io.fluxzero.common.api.modeling.ModelDeletionPlan
ModelDeletionPlan.Metric - Class in io.fluxzero.common.api.modeling
ModelDeletionResult - Class in io.fluxzero.common.api.modeling: Completed result of an idempotent independent-model hard deletion.
ModelDeletionResult() - Constructor for class io.fluxzero.common.api.modeling.ModelDeletionResult
ModelDeletionResult.Metric - Class in io.fluxzero.common.api.modeling
ModelDocumentMutation - Class in io.fluxzero.common.api.modeling: Optional direct current-document consequence of one model target transition.
ModelDocumentMutation() - Constructor for class io.fluxzero.common.api.modeling.ModelDocumentMutation
ModelEventDataBlock - Record Class in io.fluxzero.common.api.modeling: Byte-range view containing one persisted model-event block.
ModelEventDataBlock(byte[]) - Constructor for record class io.fluxzero.common.api.modeling.ModelEventDataBlock
ModelEventDataBlock(byte[], int, int) - Constructor for record class io.fluxzero.common.api.modeling.ModelEventDataBlock: Creates an instance of a ModelEventDataBlock record class.
ModelEventMembership - Class in io.fluxzero.common.api.modeling: Lightweight membership of one shared event payload in one model stream.
ModelEventMembership() - Constructor for class io.fluxzero.common.api.modeling.ModelEventMembership
ModelEventMetadata - Class in io.fluxzero.common.api.modeling: Reserved metadata keys identifying events emitted by an independent-model commit.
ModelEventPageDecoder - Class in io.fluxzero.common.api.modeling: Expands the persisted blocks in a canonical model-event page into its logical payloads and stream memberships.
ModelEventPayload - Class in io.fluxzero.common.api.modeling: One original serialized event payload shared by every returned target membership at this state index.
ModelEventPayload() - Constructor for class io.fluxzero.common.api.modeling.ModelEventPayload
ModelEventPayloadBlock - Class in io.fluxzero.common.api.modeling: One persisted global-event block transported without runtime-side decompression or re-encoding.
ModelEventPayloadBlock(long, int, boolean, byte[]) - Constructor for class io.fluxzero.common.api.modeling.ModelEventPayloadBlock
ModelEventStream - Class in io.fluxzero.common.api.modeling: Head and ordered event memberships for one requested model.
ModelEventStream() - Constructor for class io.fluxzero.common.api.modeling.ModelEventStream
ModelEventStreamRequest - Class in io.fluxzero.common.api.modeling: One bounded model-stream read inside GetModelEvents.
ModelEventStreamRequest() - Constructor for class io.fluxzero.common.api.modeling.ModelEventStreamRequest
ModelEventWireCodec - Class in io.fluxzero.common.api.modeling: Compact websocket representation for model-stream reads.
ModelGraphComposition - Class in io.fluxzero.common.api.search: Optional bounds for composing current independent-model documents into the documents returned by a search.
ModelGraphComposition(int, int, int, int, long) - Constructor for class io.fluxzero.common.api.search.ModelGraphComposition
ModelGraphDocumentManifest - Record Class in io.fluxzero.common.search: Hidden structural description carried by a composed independent-model graph document.
ModelGraphDocumentManifest(int, long, List, List, List) - Constructor for record class io.fluxzero.common.search.ModelGraphDocumentManifest: Creates an instance of a ModelGraphDocumentManifest record class.
ModelGraphDocumentManifest(long, List, List, List) - Constructor for record class io.fluxzero.common.search.ModelGraphDocumentManifest
ModelGraphDocumentManifest.Node - Record Class in io.fluxzero.common.search: One concrete placement in pre-order.
ModelGraphDocumentSearch - Class in io.fluxzero.common.search: Applies graph-view constraints, sorting, field selection and pagination after live graph composition.
ModelGraphDocumentStitcher - Class in io.fluxzero.common.search: Deterministically composes direct current model documents using explicit relationship paths.
ModelGraphEdge - Class in io.fluxzero.common.api.modeling: One temporal child-to-parent edge selected for a model graph.
ModelGraphEdge() - Constructor for class io.fluxzero.common.api.modeling.ModelGraphEdge
ModelGraphPathOverride - Class in io.fluxzero.common.api.modeling: Projection-local replacement for a canonical relationship path.
ModelGraphPathOverride(String, String) - Constructor for class io.fluxzero.common.api.modeling.ModelGraphPathOverride
ModelGraphProjectionConfiguration - Class in io.fluxzero.common.api.modeling: Durable definition of one asynchronous materialized model-graph document.
ModelGraphProjectionConfiguration(String, String, String, ModelGraphComposition, List, List) - Constructor for class io.fluxzero.common.api.modeling.ModelGraphProjectionConfiguration
ModelGraphProjectionConfiguration.ModelRevision - Record Class in io.fluxzero.common.api.modeling: One independently evolvable direct-document schema participating in a materialized Graph.
ModelGraphProjectionStatus - Class in io.fluxzero.common.api.modeling: Current progress of one asynchronous materialized graph projection.
ModelGraphProjectionStatus() - Constructor for class io.fluxzero.common.api.modeling.ModelGraphProjectionStatus
ModelHeadState - Class in io.fluxzero.common.api.modeling: Coordination head observed for one model at the response boundary.
ModelHeadState() - Constructor for class io.fluxzero.common.api.modeling.ModelHeadState
modelId() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the modelId record component.
modelIds() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Result: Returns the value of the modelIds record component.
ModelReadBoundary - Record Class in io.fluxzero.common.api.modeling: One current, state, commit or event boundary shared by every Model read.
ModelReadBoundary(Long, String, Integer, Long, boolean, boolean, boolean) - Constructor for record class io.fluxzero.common.api.modeling.ModelReadBoundary: Creates an instance of a ModelReadBoundary record class.
ModelRelationConstraint - Class in io.fluxzero.common.api.search: Current-state relationship constraint for independent model documents.
ModelRelationConstraint(ModelRelationConstraint.RelationDirection, SearchQuery, int, int, List, int, int) - Constructor for class io.fluxzero.common.api.search.ModelRelationConstraint
ModelRelationConstraint.RelationDirection - Enum Class in io.fluxzero.common.api.search: Relationship direction as observed from returned target documents.
ModelRelationship - Class in io.fluxzero.common.api.modeling: Desired outgoing relationship from a changed child model to one parent.
ModelRelationship() - Constructor for class io.fluxzero.common.api.modeling.ModelRelationship
ModelRelationshipCycleValidator - Class in io.fluxzero.common.api.modeling: Validates ordered relationship changes against a current parent graph without loading unrelated descendants.
ModelRelationshipCycleValidator.Change - Record Class in io.fluxzero.common.api.modeling: Complete desired parent-ID set for one changed child.
ModelRelationshipCycleValidator.ParentLoader - Interface in io.fluxzero.common.api.modeling: Batch-loads current parents for child IDs.
ModelRelationshipCycleValidator.Step - Record Class in io.fluxzero.common.api.modeling: One historically visible relationship boundary.
ModelRelationshipCycleValidator.ValidationException - Exception Class in io.fluxzero.common.api.modeling: Signals that the proposed relationship boundary could not be proven acyclic.
ModelRelationshipQueries - Class in io.fluxzero.common.modeling: Shared graph, ancestor, lineage and relationship-query policies for every Model store.
ModelRelationshipQueries.Relationship - Interface in io.fluxzero.common.modeling: Storage-independent view of one temporal child-to-parent relationship interval.
ModelRelationshipQueries.ResolvedBoundary - Record Class in io.fluxzero.common.modeling: State selected for a read and whether it came from the requested selector rather than an allowed fallback.
ModelRelationshipTraversal - Class in io.fluxzero.common.modeling: Shared breadth-first traversal mechanics for temporal model relationships.
ModelRelationshipTraversal.Policy - Record Class in io.fluxzero.common.modeling: Traversal bounds and the failure messages associated with exceeding them.
ModelRelationshipTraversal.RelationshipLoader<R> - Interface in io.fluxzero.common.modeling: Supplies the relationships for one breadth-first frontier without requiring materialization.
ModelRelationshipTraversal.Result - Record Class in io.fluxzero.common.modeling: Ordered traversal result, including edges only when an edge mapper was supplied.
ModelRevision(String, int) - Constructor for record class io.fluxzero.common.api.modeling.ModelGraphProjectionConfiguration.ModelRevision: Creates an instance of a ModelRevision record class.
ModelSnapshotMutation - Class in io.fluxzero.common.api.modeling: Optional serialized snapshot consequence of one model target transition.
ModelSnapshotMutation() - Constructor for class io.fluxzero.common.api.modeling.ModelSnapshotMutation
ModelStateIndexCodec - Class in io.fluxzero.common.api.modeling: Encodes opaque model state indices as fixed-width text that retains signed-long ordering.
ModelStreamBatchDecoder - Class in io.fluxzero.common.api.modeling: Decoder for the final persisted independent-model stream batch format.
ModelStreamBatchDecoder.Entry - Record Class in io.fluxzero.common.api.modeling: One independently addressable stored model membership.
modelType() - Method in record class io.fluxzero.common.api.modeling.ModelGraphProjectionConfiguration.ModelRevision: Returns the value of the modelType record component.
modelType() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the modelType record component.
modelType() - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.Head
ModelUpdate - Class in io.fluxzero.common.api.modeling: Resulting target heads of one committed model-commit substep.
ModelUpdate() - Constructor for class io.fluxzero.common.api.modeling.ModelUpdate
ModelUpdateKind - Enum Class in io.fluxzero.common.api.modeling: Durable change represented by a ModelUpdate.
ModelWebSocketCodec - Enum Class in io.fluxzero.common.api.modeling: Compact websocket representation for model commits and model-event reads.
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.
nestedEnvelopeSize(SerializedMessage) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns the size of a native envelope when embedded as one length-delimited wire value.
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.
Node(String, int, int, int, int, int) - Constructor for record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Creates an instance of a Node record class.
nodes() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns the value of the nodes record component.
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.api.modeling.ModelDeletionCascade: Select only the requested model.
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.
nullableLongSize(Long) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns the encoded size of one nullable long.
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.
offset() - Method in interface io.fluxzero.common.api.Data.ByteArrayView
offset() - Method in record class io.fluxzero.common.api.modeling.ModelEventDataBlock: Returns the value of the offset record component.
ofStrings(Map) - Static method in class io.fluxzero.common.api.Metadata: Creates immutable metadata from values that are already normalized to strings.
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
operation - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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.
ordinal() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Returns the value of the ordinal record component.
orTimeout(CompletableFuture, Duration) - Method in interface io.fluxzero.common.TaskScheduler: Sets a timeout for a CompletableFuture.
outputItemCount - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
ownedDescendants(Collection, Collection) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Returns descendants whose complete path from a supplied root owns the child lifecycle.
owners() - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Aliases

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.).
parent() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Returns the value of the parent record component.
parentId() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
parentIds() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change: Returns the value of the parentIds record component.
parentIds() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange
parentType() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
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() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
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.
payloadBytes() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the payloadBytes record component.
payloadClassKey() - Method in record class io.fluxzero.common.handling.HandlerMethodApplicability: Returns the value of the payloadClassKey record component.
peekInt(byte[], int) - Static method in class io.fluxzero.common.api.internal.BinaryWire
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.
PlanModelDeletion - Class in io.fluxzero.common.api.modeling: Creates a bounded, non-mutating hard-deletion plan.
PlanModelDeletion(String, ModelDeletionCascade) - Constructor for class io.fluxzero.common.api.modeling.PlanModelDeletion
PlanModelDeletion.Metric - Class in io.fluxzero.common.api.modeling
Policy(int, int, boolean, boolean, String, String) - Constructor for record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Creates an instance of a Policy record class.
position() - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
position() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
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.
preparationNanos - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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.
prepareAsyncInvocation() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
prepareAsyncInvocation() - Method in interface io.fluxzero.common.handling.HandlerInvoker: Registers framework lifecycle state on the dispatching thread before this invocation moves to an asynchronous worker.
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.
prepareEnvelope(SerializedMessage) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Prepares a message once for reuse by an enclosing transport codec.
prepareEnvelopes(List) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Prepares a message sequence, retaining the original list when every envelope is reusable.
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
PREVIOUS_STATE_INDEX_METADATA_KEY - Static variable in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Reserved tombstone metadata containing the last materialized state boundary before deletion.
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
productionDocumentPresent() - Method in record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Returns the value of the productionDocumentPresent record component.
propertyPath(String) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata
PropertySource - Interface in io.fluxzero.common.application: Represents a source of configuration properties.
publicationNanos - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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(String, String) - Method in class io.fluxzero.common.api.Metadata.Builder: Adds or replaces a metadata value.
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).
putAll(Map) - Method in class io.fluxzero.common.api.Metadata.Builder: Adds or replaces normalized metadata values.
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.
putTraceEntries(Metadata) - Method in class io.fluxzero.common.api.Metadata.Builder: Adds or replaces the trace entries from existing metadata without materializing an intermediate map.

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
queueBytes - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
queueDepth - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
queueWaitNanos - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch

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, boolean, Long, Long) - Constructor for class io.fluxzero.common.api.tracking.Read
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
readBoolean() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readBoundary(Metadata) - Static method in class io.fluxzero.common.api.modeling.ModelEventMetadata: Returns the commit boundary carried by metadata, or null when it is not a Model event.
readBoundary(Metadata, MessageType, Long) - Static method in class io.fluxzero.common.api.modeling.ModelEventMetadata: Returns the Model boundary carried by a Model event, or falls back to an existing global event index.
readByte() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readBytes() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readEnvelope() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readEnvelopeIndex(byte[], int, int, int) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Reads only the indexed routing field from one native message without materializing application data.
readEnvelopeSize(byte[], int, int, int) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns the complete size of the next native message envelope in a byte range.
reader - Static variable in class io.fluxzero.common.serialization.JsonUtils: Preconfigured JsonMapper for reading/deserializing objects from JSON, including type handling.
Reader(byte[], int) - Constructor for class io.fluxzero.common.api.internal.BinaryWire.Reader
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.
readInt() - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
readInt() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readLong() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readLongs(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readNullableInt() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readNullableLong() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
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(long, MessageBatch) - Constructor for class io.fluxzero.common.api.tracking.ReadResult
ReadResult(long, MessageBatch, long) - 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.
readSize(int, String) - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
readSize(int, String) - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readStateIndex() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the readStateIndex record component.
readString() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
readString(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
readStringEquals(String, int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
readStringLength(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
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.
readUnsignedByte() - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
reason() - Method in record class io.fluxzero.common.caching.MemoryAwareCacheSupportEviction: Returns the value of the reason record component.
rebase(long, String, List, long) - Static method in class io.fluxzero.common.api.modeling.CommitModelsResult: Requests an internal apply-only rebase at the supplied current boundary.
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
RegisterModelGraphProjection - Class in io.fluxzero.common.api.modeling: Idempotently registers an asynchronous materialized model-graph projection.
RegisterModelGraphProjection() - Constructor for class io.fluxzero.common.api.modeling.RegisterModelGraphProjection
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.
rejectDepthOverflow() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns the value of the rejectDepthOverflow record component.
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.
relatedModels(Set, ModelRelationConstraint, Function, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves models related at the configured depths and paths.
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
RelationshipChange(String, Set, boolean) - Constructor for record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange: Creates an instance of a RelationshipChange record class.
relationshipPath() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Returns the value of the relationshipPath record component.
relationshipPath(ModelGraphDocumentManifest.Node) - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns the relationship path referenced by a non-root node.
relationshipPaths() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns the value of the relationshipPaths record component.
relationshipStep(int) - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description
RelationshipStep(List, Set) - Constructor for record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipStep: Creates an instance of a RelationshipStep record class.
relationshipSteps() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the relationshipSteps record component.
remaining() - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
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
replacements() - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Aliases
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
Request(long) - Constructor for class io.fluxzero.common.api.Request: Restores a transport-assigned request identifier.
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(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
require(String) - Method in interface io.fluxzero.common.application.PropertySource: Retrieves the value of a property by name and throws if not present.
requireComplete() - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
requiresBatchSegmentOrder() - Method in class io.fluxzero.common.handling.HandlerInvoker.DelegatingHandlerInvoker
requiresBatchSegmentOrder() - Method in interface io.fluxzero.common.handling.HandlerInvoker: Whether asynchronous invocations in one tracked batch must retain the generic message-segment order.
requiresRequestContext(RequestResult) - Static method in class io.fluxzero.common.api.modeling.ModelCommitWireCodec: Returns whether a decoded transport result still needs its correlated request context.
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(ModelConflictPolicy) - Static method in enum class io.fluxzero.common.api.modeling.ModelConflictPolicy: Resolves a missing wire value to the compatibility default.
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.
resolve(Type, Class, Class) - Static method in class io.fluxzero.common.reflection.GenericTypeResolver: Resolves a type declared by declaringType in the generic context of contextType.
resolveBoundary(ModelReadBoundary, boolean, LongSupplier, BiFunction, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves a current, state, commit or event selector against one visible store boundary.
resolveBoundaryWithEvidence(ModelReadBoundary, boolean, LongSupplier, BiFunction, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipQueries: Resolves a boundary and records whether an event selector used its explicit current-state fallback.
resolved(long) - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Pins this selection to the durable state returned by storage.
resolved(long, boolean) - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Pins this selection while explicitly retaining or excluding active message-batch values.
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.
ResolvedBoundary(long, boolean) - Constructor for record class io.fluxzero.common.modeling.ModelRelationshipQueries.ResolvedBoundary: Creates an instance of a ResolvedBoundary record class.
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
restoreResultContext(RequestResult, CommitModels) - Static method in class io.fluxzero.common.api.modeling.ModelCommitWireCodec: Completes a compact decoded result with identities owned by its correlated request.
result() - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Commit
result(CommitModels, List, long) - Static method in class io.fluxzero.common.modeling.ModelCommitConflicts: Maps detected conflicts to the outcome required by the commit's resolved conflict policy.
Result(List, List) - Constructor for record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Result: Creates an instance of a Result record class.
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.
RETRY - Enum constant in enum class io.fluxzero.common.api.modeling.ModelConflictPolicy: Reject a stale commit and permit a bounded complete reevaluation against freshly loaded models and relations.
RetryAwareRequest - Interface in io.fluxzero.common.api: Request whose durable handler needs to distinguish an initial send from a transport retry.
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() - Method in record class io.fluxzero.common.api.modeling.ModelGraphProjectionConfiguration.ModelRevision: Returns the value of the revision record component.
revision() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Returns the value of the revision record component.
Revision - Annotation Interface in io.fluxzero.common.serialization: Specifies the revision number of a persistable object, such as a message payload, document, or model snapshot.
Revisioned payloads - Section in class io.fluxzero.common.serialization.JsonUtils
revisitAtDifferentDepths() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns the value of the revisitAtDifferentDepths record component.
RewriteModelGraphDocument - Class in io.fluxzero.common.api.search: Conditionally replaces one materialized model-graph document after application-level schema migration.
RewriteModelGraphDocument() - Constructor for class io.fluxzero.common.api.search.RewriteModelGraphDocument
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.CommitModels: Routes retries of the same commit consistently without choosing one target model as its owner.
routingKey() - Method in class io.fluxzero.common.api.modeling.DeleteModel
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.AdoptModelMigration
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.search.RewriteModelGraphDocument
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(int[], Position, int, long, Predicate, boolean) - 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.
scanBatch(Long, int, boolean, long, Predicate, boolean) - Method in interface io.fluxzero.common.tracking.MessageStore: Scans messages with optional document tombstones.
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.
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.
SearchModelDocuments - Class in io.fluxzero.common.api.search: Searches current independent model documents subject to bounded relationship constraints.
SearchModelDocuments(SearchDocuments, List) - Constructor for class io.fluxzero.common.api.search.SearchModelDocuments
SearchModelDocuments.Metric - Class in io.fluxzero.common.api.search
SearchModelGraphDocuments - Class in io.fluxzero.common.api.search: Searches independent model documents and composes their current child graph into every returned root document.
SearchModelGraphDocuments(SearchDocuments, List, ModelGraphComposition) - Constructor for class io.fluxzero.common.api.search.SearchModelGraphDocuments
SearchModelGraphDocuments(SearchDocuments, List, ModelGraphComposition, List) - Constructor for class io.fluxzero.common.api.search.SearchModelGraphDocuments
SearchModelGraphDocuments.Metric - Class in io.fluxzero.common.api.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.
SEQUENCE_NUMBER - Static variable in class io.fluxzero.common.api.modeling.ModelSnapshotMutation
sequenceNumber() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the sequenceNumber record component.
sequenceNumber() - Method in interface io.fluxzero.common.modeling.ModelCommitAssignment.Head
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() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Serializes this manifest for hidden search-document metadata.
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: A serialized message value.
SerializedMessage(Data, Metadata, String, Long) - Constructor for class io.fluxzero.common.api.SerializedMessage
SerializedMessagePackCodec - Class in io.fluxzero.common.serialization: Decodes the shared binary or legacy MessagePack representations used by the Fluxzero event store.
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
session(Function, ModelCommitAssignment.HeadFactory, long) - Static method in class io.fluxzero.common.modeling.ModelCommitAssignment: Starts an ordered assignment session in which later commits observe earlier assigned heads.
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
singleTarget() - Method in class io.fluxzero.common.api.modeling.CommitModels: Returns the sole target when this commit has one substep with one target, otherwise null.
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(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
skip(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Reader
skip(long) - Method in class io.fluxzero.common.LazyInputStream
skipString(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Cursor
snapshotKey(String, long) - Static method in class io.fluxzero.common.api.modeling.ModelSnapshotMutation: Stable immutable snapshot document key.
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.
source() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the source record component.
specializedMetadata(Class, Function) - Method in class io.fluxzero.common.reflection.ReflectionUtils.TypeMetadata: Returns type-specific structural metadata owned by this central type cache.
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().
startBatch(String, String, String, int, long, long, long) - Static method in class io.fluxzero.common.jfr.FluxzeroJfr: Starts one batch event, returning null without allocating an event when batch diagnostics are disabled.
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.
state(long, boolean) - Static method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Creates an exact state boundary with optional active message-batch visibility.
STATE_INDEX - Static variable in class io.fluxzero.common.api.modeling.ModelSnapshotMutation
stateIndex() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the value of the stateIndex record component.
stateIndex() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the stateIndex record component.
stateIndex() - Method in record class io.fluxzero.common.modeling.ModelRelationshipQueries.ResolvedBoundary: Returns the value of the stateIndex record component.
stateIndex() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns the value of the stateIndex record component.
status() - Method in record class io.fluxzero.common.handling.HandlerMethodPreparation: Returns the value of the status record component.
Step(List) - Constructor for record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Step: Creates an instance of a Step record class.
stitch(List, Collection, Map, ModelGraphComposition) - Static method in class io.fluxzero.common.search.ModelGraphDocumentStitcher: Composes every root document from the supplied current graph.
stitch(List, Collection, Map, ModelGraphComposition, long) - Static method in class io.fluxzero.common.search.ModelGraphDocumentStitcher: Composes every root document and records the exact model-state boundary in its hidden graph manifest.
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.
storageNanos - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
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
stringSize(String) - Static method in class io.fluxzero.common.api.internal.BinaryWire: Returns the encoded size of one nullable length-prefixed UTF-8 string.
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
subBatchCount - Variable in class io.fluxzero.common.jfr.FluxzeroJfr.Batch
submit(ThrowingRunnable) - Method in class io.fluxzero.common.InMemoryTaskScheduler
submit(ThrowingRunnable) - Method in interface io.fluxzero.common.TaskScheduler: Immediately schedules a task for execution.
substep() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns the value of the substep record component.
substep() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns the value of the substep record component.
SUBSTEP - Static variable in class io.fluxzero.common.api.modeling.ModelEventMetadata: Ordered substep within the model commit.
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
supplyAll(Iterable, Function, BiConsumer) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
supplyAll(Iterable, Function, BiConsumer) - Method in interface io.fluxzero.common.caching.Cache: Supplies every present value from an ordered group of lookups.
supplyAll(Iterable, Function, BiConsumer) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Supplies present values for an ordered group of lookups under one cache lock.
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

targetEquals(String) - Method in class io.fluxzero.common.api.SerializedMessage: Compares the target without an intermediate optional value.
targetIds() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the targetIds record component.
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
timestamp() - Method in record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Returns the value of the timestamp record component.
timestamp() - Method in record class io.fluxzero.common.api.search.GetModelMigrationsResult.Metric: Returns the value of the timestamp record component.
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
toByteArray() - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
toData() - Method in class io.fluxzero.common.api.Metadata: Returns the compact serialized representation of this metadata.
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
toDocument(String, long, long) - Method in class io.fluxzero.common.api.modeling.ModelSnapshotMutation: Creates the immutable search document after the runtime assigned its durable positions.
toExactByteArray() - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
toJsonData(JsonNode, Data) - Method in class io.fluxzero.common.search.JacksonInverter
toJsonNodeInstance(Object) - Method in class io.fluxzero.common.search.JacksonInverter
TOMBSTONE_METADATA_KEY - Static variable in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Reserved metadata marker for a deleted materialized graph root.
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.modeling.CommitModels: Returns a payload-free representation for operational metrics.
toMetric() - Method in class io.fluxzero.common.api.modeling.CommitModelsResult: Returns a target-ID-free metric representation.
toMetric() - Method in class io.fluxzero.common.api.modeling.DeleteModel
toMetric() - Method in class io.fluxzero.common.api.modeling.GetModelChange
toMetric() - Method in class io.fluxzero.common.api.modeling.GetModelChangeResult
toMetric() - Method in class io.fluxzero.common.api.modeling.GetModelEvents
toMetric() - Method in class io.fluxzero.common.api.modeling.GetModelEventsResult
toMetric() - Method in class io.fluxzero.common.api.modeling.GetModelGraph
toMetric() - Method in class io.fluxzero.common.api.modeling.GetModelGraphResult
toMetric() - Method in class io.fluxzero.common.api.modeling.ModelDeletionPlan
toMetric() - Method in class io.fluxzero.common.api.modeling.ModelDeletionResult
toMetric() - Method in class io.fluxzero.common.api.modeling.PlanModelDeletion
toMetric() - Method in class io.fluxzero.common.api.modeling.TrackModelUpdatesResult
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.GetModelMigrationResult
toMetric() - Method in class io.fluxzero.common.api.search.GetModelMigrationsResult
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.search.SearchModelDocuments
toMetric() - Method in class io.fluxzero.common.api.search.SearchModelGraphDocuments
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 record class io.fluxzero.common.api.modeling.ModelEventDataBlock: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.api.modeling.ModelGraphProjectionConfiguration.ModelRevision: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Change: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.Step: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.api.modeling.ModelStreamBatchDecoder.Entry: Returns a string representation of this record class.
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 record class io.fluxzero.common.api.search.GetModelMigrationResult.Metric: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.api.search.GetModelMigrationsResult.Metric: Returns a string representation of this record class.
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.modeling.ModelCommitAssignment.Description: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipChange: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.RelationshipStep: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.modeling.ModelRelationshipQueries.ResolvedBoundary: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Policy: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Result: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Returns a string representation of this record class.
toString() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: 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
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.
TrackingWebSocketCodec - Enum Class in io.fluxzero.common.api.tracking: Compact websocket representation for message publication and tracking.
TrackingWireCodec - Class in io.fluxzero.common.api.tracking: Compact binary websocket representation for message publication and tracking.
TrackModelUpdates - Class in io.fluxzero.common.api.modeling: Long-polls committed independent-model updates after a client-controlled state cursor.
TrackModelUpdates(long, int, long) - Constructor for class io.fluxzero.common.api.modeling.TrackModelUpdates: Creates a bounded model-update long poll.
TrackModelUpdates(long, int, long, long) - Constructor for class io.fluxzero.common.api.modeling.TrackModelUpdates: Creates a bounded model-update long poll with an explicit response metadata-byte limit.
TrackModelUpdatesResult - Class in io.fluxzero.common.api.modeling: One bounded page of model-commit updates returned by TrackModelUpdates.
TrackModelUpdatesResult() - Constructor for class io.fluxzero.common.api.modeling.TrackModelUpdatesResult
TrackModelUpdatesResult.Metric - Class in io.fluxzero.common.api.modeling
traverse(Collection, ModelRelationshipTraversal.Policy, ModelRelationshipTraversal.RelationshipLoader, Function, Function) - Static method in class io.fluxzero.common.modeling.ModelRelationshipTraversal: Traverses one relationship source without extra targets or per-level result handling.
traverse(Collection, ModelRelationshipTraversal.Policy, ModelRelationshipTraversal.RelationshipLoader, Function, Function, Function, BiConsumer) - Static method in class io.fluxzero.common.modeling.ModelRelationshipTraversal: Traverses one relationship source with optional extra targets and per-level result handling.
traverse(Collection, ModelRelationshipTraversal.Policy, List, Function, Function, Function, BiConsumer) - Static method in class io.fluxzero.common.modeling.ModelRelationshipTraversal: Traverses one or more ordered relationship sources using the supplied storage-specific selectors.
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.
tryDecode(byte[]) - Static method in class io.fluxzero.common.api.modeling.ModelCommitWireCodec: Decodes a compact batch, returning null when the payload uses the ordinary transport representation.
tryDecode(byte[]) - Static method in class io.fluxzero.common.api.modeling.ModelEventWireCodec: Decodes this codec's representation, or returns null for another transport format.
tryDecode(byte[]) - Static method in class io.fluxzero.common.api.tracking.TrackingWireCodec: Decodes this codec's representation, or returns null for another transport representation.
tryDecode(byte[], WebSocketTransportFormat) - Method in enum class io.fluxzero.common.api.modeling.ModelWebSocketCodec
tryDecode(byte[], WebSocketTransportFormat) - Method in enum class io.fluxzero.common.api.tracking.TrackingWebSocketCodec
tryDecode(byte[], WebSocketTransportFormat) - Method in interface io.fluxzero.common.websocket.WebSocketPayloadCodec: Returns the decoded value, or null when the bytes do not belong to this codec.
tryEncode(JsonType) - Static method in class io.fluxzero.common.api.modeling.ModelCommitWireCodec: Encodes a supported homogeneous request or result batch, returning null when the ordinary transport codec should be used.
tryEncode(JsonType) - Static method in class io.fluxzero.common.api.modeling.ModelEventWireCodec: Encodes a homogeneous compact model-event request or result batch.
tryEncode(JsonType) - Static method in class io.fluxzero.common.api.tracking.TrackingWireCodec: Encodes a supported tracking value, or returns null when the regular codec should be used.
tryEncode(JsonType, WebSocketTransportFormat) - Method in enum class io.fluxzero.common.api.modeling.ModelWebSocketCodec
tryEncode(JsonType, WebSocketTransportFormat) - Method in enum class io.fluxzero.common.api.tracking.TrackingWebSocketCodec
tryEncode(JsonType, WebSocketTransportFormat) - Method in interface io.fluxzero.common.websocket.WebSocketPayloadCodec: Returns a compact representation, or null when this codec does not own the value.
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
type() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest.Node: Returns the value of the type record component.
type(ModelGraphDocumentManifest.Node) - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns the concrete class name referenced by a node.
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
typeEquals(String) - Method in class io.fluxzero.common.api.SerializedMessage: Compares the serialized payload type.
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() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns the value of the types record component.
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

U

UNBOUNDED - Static variable in class io.fluxzero.common.api.search.ModelGraphComposition: Sentinel indicating that a composition dimension has no configured maximum.
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.
unstoredTargetIds() - Method in record class io.fluxzero.common.modeling.ModelCommitAssignment.Description: Returns the value of the unstoredTargetIds record component.
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.
updateAll(Iterable, Function, BiFunction) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
updateAll(Iterable, Function, BiFunction) - Method in interface io.fluxzero.common.caching.Cache: Applies an ordered group of updates while deriving each cache key from the update value.
updateAll(Iterable, Function, Function, BiFunction) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
updateAll(Iterable, Function, Function, BiFunction) - Method in interface io.fluxzero.common.caching.Cache: Applies an ordered group of updates using a possibly transient lookup key and a stable key for new entries.
updateAll(Iterable, Function, BiFunction) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Applies ordered updates under one cache lock and checks memory pressure once after the batch.
updateAll(Iterable, Function, Function, BiFunction) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Applies ordered updates while retaining a stable key only when an update inserts a new mapping.
updateAll(Map) - Method in class io.fluxzero.common.caching.AdaptiveObjectCache
updateAll(Map) - Method in interface io.fluxzero.common.caching.Cache: Applies independent per-key update functions as one bounded cache operation.
updateAll(Map, BiFunction) - Method in class io.fluxzero.common.caching.MemoryAwareCacheSupport: Applies independent updates under one cache lock and checks memory pressure once after the batch.
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
utf8Equals(byte[], int, int, String) - Static method in class io.fluxzero.common.api.internal.BinaryWire
utf8Length(String) - Static method in class io.fluxzero.common.api.internal.BinaryWire

V

validate(CommitModels) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates the structural model-commit wire contract.
validate(DeleteModel) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates one explicit model hard-deletion command.
validate(GetModelChange) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates one durable model-change lookup.
validate(GetModelEvents) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates one public batch model-stream read.
validate(GetModelGraph) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates one temporal model-graph request, including optional caller-imposed bounds.
validate(PlanModelDeletion) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates one bounded model hard-deletion dry run.
validate(List, ModelRelationshipCycleValidator.ParentLoader) - Static method in class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator: Validates ordered atomic relationship steps.
validate(Map) - Method in class io.fluxzero.common.modeling.ModelCommitAssignment.Aliases: Validates replacements against a store's current alias-to-model view.
validate(M, Object, Executable, Object[]) - Method in interface io.fluxzero.common.handling.MethodInvocationValidator
validateModelId(String) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates an exact persisted model identity.
validateRelationships(List, ModelRelationshipCycleValidator.ParentLoader, ModelCommitAssignment.ChildLoader) - Static method in class io.fluxzero.common.modeling.ModelCommitAssignment: Validates the ordered relationship effects described for one atomic assignment batch.
validateStateIndex(long) - Static method in class io.fluxzero.common.api.modeling.ModelCommitValidator: Validates a namespace model-state boundary.
Validation - Section in class io.fluxzero.common.api.search.SearchQuery
ValidationException(String) - Constructor for exception class io.fluxzero.common.api.modeling.ModelRelationshipCycleValidator.ValidationException
validFrom() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
validUntil() - Method in interface io.fluxzero.common.modeling.ModelRelationshipQueries.Relationship
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.modeling.GetModelGraph.TraversalDirection: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.api.modeling.ModelConflictPolicy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.api.modeling.ModelDeletionCascade: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.api.modeling.ModelUpdateKind: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.fluxzero.common.api.modeling.ModelWebSocketCodec: 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.ModelRelationConstraint.RelationDirection: 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.api.tracking.TrackingWebSocketCodec: 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.MemoryAwareCacheSupport.WeightUnit: 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.modeling.GetModelGraph.TraversalDirection: 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.modeling.ModelConflictPolicy: 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.modeling.ModelDeletionCascade: 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.modeling.ModelUpdateKind: 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.modeling.ModelWebSocketCodec: 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.ModelRelationConstraint.RelationDirection: 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.api.tracking.TrackingWebSocketCodec: 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.MemoryAwareCacheSupport.WeightUnit: 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.
version() - Method in record class io.fluxzero.common.search.ModelGraphDocumentManifest: Returns the value of the version record component.
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.
WebSocketPayloadCodec - Interface in io.fluxzero.common.websocket: Optional compact representation for a protocol-specific websocket payload.
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.
withExactBoundary(boolean) - Method in class io.fluxzero.common.api.modeling.GetModelEventsResult: Returns this result with explicit evidence whether the original selector resolved exactly.
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.
without(Collection) - Method in record class io.fluxzero.common.modeling.ModelRelationshipTraversal.Result: Returns all discovered model IDs except the supplied roots.
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.
withoutMessageBatch() - Method in record class io.fluxzero.common.api.modeling.ModelReadBoundary: Returns this boundary without active message-batch visibility.
withoutTracker(Tracker) - Method in class io.fluxzero.common.tracking.TrackerCluster: Removes the tracker from the cluster.
withPath(String) - Method in class io.fluxzero.common.api.modeling.ModelGraphEdge: Returns this edge with a projection-relative path.
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
writeBoolean(boolean) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeByte(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeBytes(byte[]) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeBytes(byte[], int, int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeEnvelope(SerializedMessage) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeFile(String, String) - Static method in class io.fluxzero.common.FileUtils: Writes a string to a file using UTF-8 encoding.
writeInt(int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeLong(long) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeLongs(long[]) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeNullableInt(Integer) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeNullableLong(Long) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
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.
Writer(int, int) - Constructor for class io.fluxzero.common.api.internal.BinaryWire.Writer
writeRaw(byte[]) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeRaw(byte[], int, int) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer
writeString(String) - Method in class io.fluxzero.common.api.internal.BinaryWire.Writer

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