Package io.fluxcapacitor.common
package io.fluxcapacitor.common
-
ClassDescriptionBacklog<T>A thread-safe batching queue that asynchronously flushes its content to a consumer in configurable batch sizes.A function that consumes a batch of items and returns a future that completes when processing is done.Utility class for computing segment assignments using consistent hashing.DefaultMemoizingBiFunction<T,
U, R> A default implementation of theMemoizingBiFunctioninterface that memoizes (caches) results of aBiFunctionbased on a pair of input arguments.A default implementation of theMemoizingFunctioninterface that provides caching functionality for computed function results.A default implementation of theMemoizingSupplierinterface that memoizes (caches) the result of a computation performed by a suppliedSupplier.A simple implementation ofAbstractExecutorServicethat executes tasks directly in the calling thread without using any worker threads.ErrorHandler<T>Functional interface for handling errors during tasks.Utility class for reading and writing files and classpath resources.Represents a delivery or completion guarantee for messages or state changes in Flux Capacitor.An in-memory implementation of theTaskSchedulerinterface, enabling scheduling and execution of tasks in a virtualized time environment.MemoizingBiFunction<T,U, R> ABiFunctionthat memoizes (caches) its results based on a pair of input arguments.MemoizingFunction<K,V> AFunctionthat memoizes (caches) its results by key.ASupplierthat memoizes (caches) the result of a single computation.Enumerates the types of messages recognized and routed by the Flux platform.Monitored<T>Represents a resource or component that can be monitored.The MurmurHash3 algorithm was created by Austin Appleby and placed in the public domain.Utility class for common object handling, memoization, concurrency, stream processing, and error handling.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.Configuration for retry behavior when executing a task usingTimingUtils.retryOnFailure(java.lang.Runnable, java.time.Duration).Represents the current status of a retry operation.Utility class for search-related functionality such as term normalization, path transformation, glob pattern matching, and primitive value extraction.Utility class for constructing internal service endpoint paths used to route messages to the Flux platform.Interface for in-memory scheduling of tasks in a way that supports deterministic testing and virtualized time.ThrowingBiConsumer<T,U> BiConsumer-like interface whoseThrowingBiConsumer.accept(Object, Object)method may throw a checkedException.ThrowingBiFunction<T,U, R> Variant ofBiFunctionwhoseThrowingBiFunction.apply(Object, Object)method is allowed to throw a checkedException.Functional counterpart toConsumerthat allows theThrowingConsumer.accept(Object)method to throw a checkedException.ThrowingFunction<T,R> Runnable-like interface whoseThrowingRunnable.run()method is allowed to throw a checkedException.Utility class for measuring execution time and retrying operations with configurable backoff and error handling.