Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractConverter<I,
O> - Class in io.fluxcapacitor.common.serialization - AbstractConverter() - Constructor for class io.fluxcapacitor.common.serialization.AbstractConverter
- accept() - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer0
- accept(Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer1
- accept(Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer2
- accept(Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer3
- accept(Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer4
- accept(Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer5
- accept(Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer6
- accept(Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer7
- accept(Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer8
- accept(Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer9
- accept(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Consumer10
- accept(List<T>) - Method in interface io.fluxcapacitor.common.Backlog.BatchConsumer
- accept(T) - Method in interface io.fluxcapacitor.common.ThrowingConsumer
- accept(T, U) - Method in interface io.fluxcapacitor.common.ThrowingBiConsumer
- add(Collection<? extends T>) - Method in class io.fluxcapacitor.common.Backlog
- add(T...) - Method in class io.fluxcapacitor.common.Backlog
- addIfAbsent(Object, Object) - Method in class io.fluxcapacitor.common.api.Metadata
- addIfAbsent(Map<?, ?>) - Method in class io.fluxcapacitor.common.api.Metadata
- adjustMaxSize(Tracker, int) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- afterRetry(Exception) - Method in class io.fluxcapacitor.common.RetryStatus
- ALGORITHM - Static variable in class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- all(Constraint...) - Static method in class io.fluxcapacitor.common.api.search.constraints.AllConstraint
- all(Collection<Constraint>) - Static method in class io.fluxcapacitor.common.api.search.constraints.AllConstraint
- AllConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- AllConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.AllConstraint
- ALWAYS_HANDLE - Static variable in interface io.fluxcapacitor.common.handling.HandlerFilter
- and(Constraint) - Method in interface io.fluxcapacitor.common.api.search.Constraint
- and(HandlerFilter) - Method in interface io.fluxcapacitor.common.handling.HandlerFilter
- and(MessageFilter<? super M>) - Method in interface io.fluxcapacitor.common.handling.MessageFilter
- andFinally(HandlerInvoker) - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- andThen(ThrowingBiConsumer<? super T, ? super U>) - Method in interface io.fluxcapacitor.common.ThrowingBiConsumer
- andThen(ThrowingConsumer<? super T>) - Method in interface io.fluxcapacitor.common.ThrowingConsumer
- andThen(ThrowingFunction<? super R, ? extends V>) - Method in interface io.fluxcapacitor.common.ThrowingBiFunction
- andThen(ThrowingFunction<? super R, ? extends V>) - Method in interface io.fluxcapacitor.common.ThrowingFunction
- andThen(PropertySource) - Method in interface io.fluxcapacitor.common.application.PropertySource
- any(Constraint...) - Static method in class io.fluxcapacitor.common.api.search.constraints.AnyConstraint
- any(Collection<Constraint>) - Static method in class io.fluxcapacitor.common.api.search.constraints.AnyConstraint
- AnyConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- AnyConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.AnyConstraint
- append(SerializedMessage...) - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- append(List<SerializedMessage>) - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- Append - Class in io.fluxcapacitor.common.api.publishing
- Append() - Constructor for class io.fluxcapacitor.common.api.publishing.Append
- Append.Metric - Class in io.fluxcapacitor.common.api.publishing
- AppendEvents - Class in io.fluxcapacitor.common.api.eventsourcing
- AppendEvents() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.AppendEvents
- AppendEvents.Metric - Class in io.fluxcapacitor.common.api.eventsourcing
- ApplicationEnvironmentPropertiesSource - Class in io.fluxcapacitor.common.application
- ApplicationEnvironmentPropertiesSource() - Constructor for class io.fluxcapacitor.common.application.ApplicationEnvironmentPropertiesSource
- ApplicationEnvironmentPropertiesSource(String) - Constructor for class io.fluxcapacitor.common.application.ApplicationEnvironmentPropertiesSource
- ApplicationPropertiesSource - Class in io.fluxcapacitor.common.application
- ApplicationPropertiesSource() - Constructor for class io.fluxcapacitor.common.application.ApplicationPropertiesSource
- apply() - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function0
- apply(Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function1
- apply(Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function2
- apply(Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function3
- apply(Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function4
- apply(Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function5
- apply(Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function6
- apply(Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function7
- apply(Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function8
- apply(Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function9
- apply(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface io.fluxcapacitor.common.reflection.DefaultMemberInvoker._Function10
- apply(K) - Method in class io.fluxcapacitor.common.DefaultMemoizingFunction
- apply(T) - Method in interface io.fluxcapacitor.common.ThrowingFunction
- apply(T, U) - Method in class io.fluxcapacitor.common.DefaultMemoizingBiFunction
- apply(T, U) - Method in interface io.fluxcapacitor.common.ThrowingBiFunction
- asBytes(Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- asCallable(ThrowingRunnable) - Static method in class io.fluxcapacitor.common.ObjectUtils
- asConsumer(ThrowingConsumer<T>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- asFacets(Metadata) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- asFunction(ThrowingFunction<T, R>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- asInstance(Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- asIntegerOrString(String) - Static method in class io.fluxcapacitor.common.SearchUtils
- asInvoker(Member) - Static method in class io.fluxcapacitor.common.reflection.DefaultMemberInvoker
- asInvoker(Member, boolean) - Static method in class io.fluxcapacitor.common.reflection.DefaultMemberInvoker
- asJson(Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- asKotlinFunction(Executable) - Static method in class io.fluxcapacitor.common.reflection.KotlinReflectionUtils
- asKotlinParameter(Parameter) - Static method in class io.fluxcapacitor.common.reflection.KotlinReflectionUtils
- asPrettyJson(Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- asPrimitive(Object) - Static method in class io.fluxcapacitor.common.SearchUtils
- asProperties(String) - Static method in class io.fluxcapacitor.common.ObjectUtils
- asRunnable(ThrowingRunnable) - Static method in class io.fluxcapacitor.common.ObjectUtils
- asRunnable(Callable<?>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- asStream(Object) - Static method in class io.fluxcapacitor.common.ObjectUtils
- asSupplier(Callable<T>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- atLeast(Object, String) - Static method in class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint
- AutoClosing - Class in io.fluxcapacitor.common.application
- AutoClosing() - Constructor for class io.fluxcapacitor.common.application.AutoClosing
- awaitTermination(long, TimeUnit) - Method in class io.fluxcapacitor.common.DirectExecutorService
B
- Backlog<T> - Class in io.fluxcapacitor.common
- Backlog(ThrowingFunction<List<T>, CompletableFuture<?>>) - Constructor for class io.fluxcapacitor.common.Backlog
- Backlog(ThrowingFunction<List<T>, CompletableFuture<?>>, int) - Constructor for class io.fluxcapacitor.common.Backlog
- Backlog(ThrowingFunction<List<T>, CompletableFuture<?>>, int, ErrorHandler<List<T>>) - Constructor for class io.fluxcapacitor.common.Backlog
- Backlog.BatchConsumer<T> - Interface in io.fluxcapacitor.common
- below(Object, String) - Static method in class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint
- between(Object, Object, String) - Static method in class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint
- BetweenConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- BetweenConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint
- BOOLEAN - Enum constant in enum class io.fluxcapacitor.common.search.Document.EntryType
- BooleanResult - Class in io.fluxcapacitor.common.api
- BooleanResult() - Constructor for class io.fluxcapacitor.common.api.BooleanResult
- BulkUpdate - Interface in io.fluxcapacitor.common.api.search
- BulkUpdate.Type - Enum Class in io.fluxcapacitor.common.api.search
- BulkUpdateDocuments - Class in io.fluxcapacitor.common.api.search
- BulkUpdateDocuments() - Constructor for class io.fluxcapacitor.common.api.search.BulkUpdateDocuments
- BulkUpdateDocuments.Metric - Class in io.fluxcapacitor.common.api.search
C
- call(Callable<?>) - Static method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- call(Callable<T>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- cancel() - Method in interface io.fluxcapacitor.common.Registration
- CancelSchedule - Class in io.fluxcapacitor.common.api.scheduling
- CancelSchedule() - Constructor for class io.fluxcapacitor.common.api.scheduling.CancelSchedule
- canDeserialize(Data<byte[]>) - Method in enum class io.fluxcapacitor.common.search.DefaultDocumentSerializer
- canHandle(SerializedMessage, int[]) - Method in interface io.fluxcapacitor.common.tracking.Tracker
- canHandle(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- canHandle(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerMatcher
- canHandle(M) - Method in interface io.fluxcapacitor.common.handling.HandlerMatcher
- ChaCha20Poly1305Encryption - Class in io.fluxcapacitor.common.encryption
-
Adopted from https://github.com/java-crypto/cross_platform_crypto
- ChaCha20Poly1305Encryption() - Constructor for class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- ChaCha20Poly1305Encryption(String) - Constructor for class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- checkPathBeforeEntry() - Method in class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint
- checkPathBeforeEntry() - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint
- claimSegment(Tracker) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- claimSegment(Tracker, PositionStore) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- claimSegment(Tracker, PositionStore) - Method in interface io.fluxcapacitor.common.tracking.TrackingStrategy
- ClaimSegment - Class in io.fluxcapacitor.common.api.tracking
- ClaimSegment(Read) - Constructor for class io.fluxcapacitor.common.api.tracking.ClaimSegment
- ClaimSegment(MessageType, String, String, long, boolean, String, boolean, Long, Long) - Constructor for class io.fluxcapacitor.common.api.tracking.ClaimSegment
- ClaimSegmentResult - Class in io.fluxcapacitor.common.api.tracking
- ClaimSegmentResult() - Constructor for class io.fluxcapacitor.common.api.tracking.ClaimSegmentResult
- ClaimSegmentResult.Metric - Class in io.fluxcapacitor.common.api.tracking
- classExists(String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- classForName(String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- classForName(String, Class<?>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- clear() - Method in class io.fluxcapacitor.common.DefaultMemoizingBiFunction
- clear() - Method in class io.fluxcapacitor.common.DefaultMemoizingFunction
- clear() - Method in class io.fluxcapacitor.common.DefaultMemoizingSupplier
- clear() - Method in interface io.fluxcapacitor.common.MemoizingBiFunction
- clear() - Method in interface io.fluxcapacitor.common.MemoizingFunction
- clear() - Method in interface io.fluxcapacitor.common.MemoizingSupplier
- clientControlledIndex() - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- clientControlledIndex() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- ClientEvent - Interface in io.fluxcapacitor.common.api
- clock() - Method in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- clock() - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
- close() - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- close() - Method in class io.fluxcapacitor.common.tracking.InMemoryPositionStore
- close() - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- close() - Method in interface io.fluxcapacitor.common.tracking.PositionStore
- close() - Method in interface io.fluxcapacitor.common.tracking.TrackingStrategy
- Command - Class in io.fluxcapacitor.common.api
- Command() - Constructor for class io.fluxcapacitor.common.api.Command
- COMMAND - Enum constant in enum class io.fluxcapacitor.common.MessageType
- comparator - Static variable in class io.fluxcapacitor.common.api.search.IndexedEntry
- comparator - Static variable in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- comparator - Static variable in interface io.fluxcapacitor.common.tracking.Tracker
- compareTo(FacetEntry) - Method in class io.fluxcapacitor.common.api.search.FacetEntry
- compareTo(IndexedEntry) - Method in class io.fluxcapacitor.common.api.search.IndexedEntry
- compareTo(Document.Entry) - Method in class io.fluxcapacitor.common.search.Document.Entry
- compareTo(Tracker) - Method in interface io.fluxcapacitor.common.tracking.Tracker
- completeResults(long, Throwable) - Method in class io.fluxcapacitor.common.Backlog
- compose(ThrowingFunction<? super V, ? extends T>) - Method in interface io.fluxcapacitor.common.ThrowingFunction
- compose(Function<? super K1, ? extends K>) - Method in interface io.fluxcapacitor.common.MemoizingFunction
- compose(Function<? super K1, Pair<? extends T, ? extends U>>) - Method in interface io.fluxcapacitor.common.MemoizingBiFunction
- compress(byte[]) - Static method in class io.fluxcapacitor.common.serialization.compression.CompressionUtils
- compress(byte[], CompressionAlgorithm) - Static method in class io.fluxcapacitor.common.serialization.compression.CompressionUtils
- CompressionAlgorithm - Enum Class in io.fluxcapacitor.common.serialization.compression
- CompressionUtils - Class in io.fluxcapacitor.common.serialization.compression
- CompressionUtils() - Constructor for class io.fluxcapacitor.common.serialization.compression.CompressionUtils
- compute(Stream<Document>, List<String>, List<String>) - Static method in class io.fluxcapacitor.common.api.search.DocumentStats
- computeClassForSpecificity() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- computeEntryMatcher() - Method in class io.fluxcapacitor.common.api.search.constraints.MatchConstraint
- computePathFilter() - Method in class io.fluxcapacitor.common.api.search.SearchDocuments
- computeSegment(String) - Static method in class io.fluxcapacitor.common.ConsistentHashing
- computeSegment(String, int) - Static method in class io.fluxcapacitor.common.ConsistentHashing
- computeSegment(String, Function<String, Integer>, int) - Static method in class io.fluxcapacitor.common.ConsistentHashing
- concat(Stream<? extends T>...) - Static method in class io.fluxcapacitor.common.ObjectUtils
- ConnectEvent - Class in io.fluxcapacitor.common.api
- ConnectEvent() - Constructor for class io.fluxcapacitor.common.api.ConnectEvent
- ConsistentHashing - Class in io.fluxcapacitor.common
- ConsistentHashing() - Constructor for class io.fluxcapacitor.common.ConsistentHashing
- Constraint - Interface in io.fluxcapacitor.common.api.search
- consumerPath(MessageType) - Static method in class io.fluxcapacitor.common.ServicePathBuilder
- contains() - Element in annotation interface io.fluxcapacitor.common.serialization.RegisterType
-
Specifies regular expression values found in the types that should be matched.
- contains(Metadata) - Method in class io.fluxcapacitor.common.api.Metadata
- contains(Tracker) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- contains(Object, Object) - Method in class io.fluxcapacitor.common.api.Metadata
- contains(String, boolean, boolean, boolean, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.ContainsConstraint
- contains(String, boolean, boolean, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.ContainsConstraint
- contains(String, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.ContainsConstraint
- containsAnyKey(Object...) - Method in class io.fluxcapacitor.common.api.Metadata
- ContainsConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- ContainsConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.ContainsConstraint
- containsKey(Object) - Method in class io.fluxcapacitor.common.api.Metadata
- containsProperty(String) - Method in interface io.fluxcapacitor.common.application.PropertySource
- convert(I) - Method in class io.fluxcapacitor.common.serialization.AbstractConverter
- convert(Data<byte[]>) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- convert(Data<I>) - Method in class io.fluxcapacitor.common.serialization.AbstractConverter
- convert(Data<I>) - Method in interface io.fluxcapacitor.common.serialization.Converter
- convertAnnotation(Annotation, Class<? extends T>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- Converter<I,
O> - Interface in io.fluxcapacitor.common.serialization - convertFormat(Data<byte[]>) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- convertFormat(Data<I>) - Method in interface io.fluxcapacitor.common.serialization.Converter
- convertIfKotlinClass(Object) - Static method in class io.fluxcapacitor.common.reflection.KotlinReflectionUtils
- convertValue(Object, TypeReference<T>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- convertValue(Object, Class<? extends T>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- convertValue(Object, Type) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- convertValue(Object, Function<TypeFactory, JavaType>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- copyFields(V, V) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- copyOf(Properties) - Static method in class io.fluxcapacitor.common.ObjectUtils
- CreateAuditTrail - Class in io.fluxcapacitor.common.api.search
- CreateAuditTrail() - Constructor for class io.fluxcapacitor.common.api.search.CreateAuditTrail
- createComparator(SearchDocuments) - Static method in class io.fluxcapacitor.common.search.Document
- createHandler(Object, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector
- createHandler(Object, Class<? extends Annotation>, List<ParameterResolver<? super M>>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector
- createHandler(Object, List<ParameterResolver<? super M>>, HandlerConfiguration<? super M>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector
- createHandler(Function<M, ?>, Class<?>, List<ParameterResolver<? super M>>, HandlerConfiguration<? super M>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector
- createSummarizer(JacksonInverter) - Static method in class io.fluxcapacitor.common.search.JacksonInverter
- CUSTOM - Enum constant in enum class io.fluxcapacitor.common.MessageType
D
- data() - Method in class io.fluxcapacitor.common.api.Data
- data() - Method in class io.fluxcapacitor.common.api.SerializedMessage
- data() - Method in interface io.fluxcapacitor.common.api.SerializedObject
- Data<T> - Class in io.fluxcapacitor.common.api
- Data(Supplier<T>, String, int, String) - Constructor for class io.fluxcapacitor.common.api.Data
- Data(T, String, int) - Constructor for class io.fluxcapacitor.common.api.Data
- Data(T, String, int, String) - Constructor for class io.fluxcapacitor.common.api.Data
- declaresField(Class<?>, String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- decompose() - Method in interface io.fluxcapacitor.common.api.search.Constraint
- decompress(byte[]) - Static method in class io.fluxcapacitor.common.serialization.compression.CompressionUtils
- decompress(byte[], CompressionAlgorithm) - Static method in class io.fluxcapacitor.common.serialization.compression.CompressionUtils
- decrypt(String) - Method in class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- decrypt(String) - Method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- decrypt(String) - Method in interface io.fluxcapacitor.common.encryption.Encryption
- decrypt(String) - Method in enum class io.fluxcapacitor.common.encryption.NoOpEncryption
- DecryptingPropertySource - Class in io.fluxcapacitor.common.application
- DecryptingPropertySource(PropertySource) - Constructor for class io.fluxcapacitor.common.application.DecryptingPropertySource
- DecryptingPropertySource(PropertySource, String) - Constructor for class io.fluxcapacitor.common.application.DecryptingPropertySource
- deduplicate(List<T>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- deduplicate(List<T>, Function<T, ?>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- deduplicate(List<T>, Function<T, ?>, boolean) - Static method in class io.fluxcapacitor.common.ObjectUtils
- defaultclock - Static variable in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- defaultDelay - Static variable in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- DefaultDocumentSerializer - Enum Class in io.fluxcapacitor.common.search
- DefaultEncryption - Class in io.fluxcapacitor.common.encryption
- DefaultEncryption() - Constructor for class io.fluxcapacitor.common.encryption.DefaultEncryption
- DefaultHandler<M> - Class in io.fluxcapacitor.common.handling
- DefaultHandler() - Constructor for class io.fluxcapacitor.common.handling.DefaultHandler
- DefaultMemberInvoker - Class in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer0 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer1 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer10 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer2 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer3 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer4 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer5 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer6 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer7 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer8 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Consumer9 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function0 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function1 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function10 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function2 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function3 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function4 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function5 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function6 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function7 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function8 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemberInvoker._Function9 - Interface in io.fluxcapacitor.common.reflection
- DefaultMemoizingBiFunction<T,
U, - Class in io.fluxcapacitor.commonR> - DefaultMemoizingBiFunction(BiFunction<T, U, R>) - Constructor for class io.fluxcapacitor.common.DefaultMemoizingBiFunction
- DefaultMemoizingBiFunction(BiFunction<T, U, R>, Duration, Clock) - Constructor for class io.fluxcapacitor.common.DefaultMemoizingBiFunction
- DefaultMemoizingFunction<K,
V> - Class in io.fluxcapacitor.common - DefaultMemoizingFunction(Function<K, V>) - Constructor for class io.fluxcapacitor.common.DefaultMemoizingFunction
- DefaultMemoizingSupplier<T> - Class in io.fluxcapacitor.common
- DefaultMemoizingSupplier(Supplier<T>) - Constructor for class io.fluxcapacitor.common.DefaultMemoizingSupplier
- DefaultMemoizingSupplier(Supplier<T>, Duration, Clock) - Constructor for class io.fluxcapacitor.common.DefaultMemoizingSupplier
- DefaultPropertySource - Class in io.fluxcapacitor.common.application
- DefaultPropertySource() - Constructor for class io.fluxcapacitor.common.application.DefaultPropertySource
- DefaultTrackingStrategy - Class in io.fluxcapacitor.common.tracking
-
Streaming strategy that allows multiple clients to concurrently consume a message stream.
- DefaultTrackingStrategy(MessageStore) - Constructor for class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- DefaultTrackingStrategy(MessageStore, TaskScheduler) - Constructor for class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- DefaultTrackingStrategy(MessageStore, TaskScheduler, int) - Constructor for class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- DefaultTrackingStrategy.WaitingTracker - Class in io.fluxcapacitor.common.tracking
- DefaultTypeRegistry - Class in io.fluxcapacitor.common.serialization
- DefaultTypeRegistry() - Constructor for class io.fluxcapacitor.common.serialization.DefaultTypeRegistry
- DefaultTypeRegistry(List<String>) - Constructor for class io.fluxcapacitor.common.serialization.DefaultTypeRegistry
- delegate - Variable in class io.fluxcapacitor.common.handling.Handler.DelegatingHandler
- delegate - Variable in class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- DelegatingClock - Class in io.fluxcapacitor.common
- DelegatingClock() - Constructor for class io.fluxcapacitor.common.DelegatingClock
- DelegatingHandler() - Constructor for class io.fluxcapacitor.common.handling.Handler.DelegatingHandler
- DelegatingHandlerInvoker() - Constructor for class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- delete - Enum constant in enum class io.fluxcapacitor.common.api.search.BulkUpdate.Type
- DeleteCollection - Class in io.fluxcapacitor.common.api.search
- DeleteCollection() - Constructor for class io.fluxcapacitor.common.api.search.DeleteCollection
- DeleteDocument - Class in io.fluxcapacitor.common.api.search.bulkupdate
- DeleteDocument() - Constructor for class io.fluxcapacitor.common.api.search.bulkupdate.DeleteDocument
- DeleteDocumentById - Class in io.fluxcapacitor.common.api.search
- DeleteDocumentById() - Constructor for class io.fluxcapacitor.common.api.search.DeleteDocumentById
- DeleteDocuments - Class in io.fluxcapacitor.common.api.search
- DeleteDocuments() - Constructor for class io.fluxcapacitor.common.api.search.DeleteDocuments
- DeleteEvents - Class in io.fluxcapacitor.common.api.eventsourcing
- DeleteEvents() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.DeleteEvents
- DeleteValue - Class in io.fluxcapacitor.common.api.keyvalue
- DeleteValue() - Constructor for class io.fluxcapacitor.common.api.keyvalue.DeleteValue
- deserialize(byte) - Static method in enum class io.fluxcapacitor.common.search.Document.EntryType
- deserialize(Data<byte[]>) - Method in enum class io.fluxcapacitor.common.search.DefaultDocumentSerializer
- deserializeDocument() - Method in class io.fluxcapacitor.common.api.search.SerializedDocument
- determineCommonAncestors(Collection<?>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- determinesSpecificity() - Method in interface io.fluxcapacitor.common.handling.ParameterResolver
- DirectExecutorService - Class in io.fluxcapacitor.common
- DirectExecutorService() - Constructor for class io.fluxcapacitor.common.DirectExecutorService
- disableJsonIgnore(ObjectMapper) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- DisconnectEvent - Class in io.fluxcapacitor.common.api
- DisconnectEvent() - Constructor for class io.fluxcapacitor.common.api.DisconnectEvent
- DisconnectTracker - Class in io.fluxcapacitor.common.api.tracking
- DisconnectTracker() - Constructor for class io.fluxcapacitor.common.api.tracking.DisconnectTracker
- disconnectTrackers(Predicate<Tracker>, boolean) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- disconnectTrackers(Predicate<Tracker>, boolean) - Method in interface io.fluxcapacitor.common.tracking.TrackingStrategy
- distinctByKey(Function<? super T, ?>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- Document - Class in io.fluxcapacitor.common.search
- Document() - Constructor for class io.fluxcapacitor.common.search.Document
- DOCUMENT - Enum constant in enum class io.fluxcapacitor.common.MessageType
- DOCUMENT_FORMAT - Static variable in class io.fluxcapacitor.common.api.Data
- Document.Entry - Class in io.fluxcapacitor.common.search
- Document.EntryType - Enum Class in io.fluxcapacitor.common.search
- Document.Path - Class in io.fluxcapacitor.common.search
- DocumentStats - Class in io.fluxcapacitor.common.api.search
- DocumentStats() - Constructor for class io.fluxcapacitor.common.api.search.DocumentStats
- DocumentStats.FieldStats - Class in io.fluxcapacitor.common.api.search
- DocumentUpdate - Class in io.fluxcapacitor.common.api.search
- DocumentUpdate() - Constructor for class io.fluxcapacitor.common.api.search.DocumentUpdate
E
- empty() - Static method in class io.fluxcapacitor.common.api.Metadata
- EMPTY_ARRAY - Enum constant in enum class io.fluxcapacitor.common.search.Document.EntryType
- EMPTY_OBJECT - Enum constant in enum class io.fluxcapacitor.common.search.Document.EntryType
- EMPTY_PATH - Static variable in class io.fluxcapacitor.common.search.Document.Path
- emptyRange - Static variable in class io.fluxcapacitor.common.tracking.TrackerCluster
- encrypt(String) - Method in class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- encrypt(String) - Method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- encrypt(String) - Method in interface io.fluxcapacitor.common.encryption.Encryption
- encrypt(String) - Method in enum class io.fluxcapacitor.common.encryption.NoOpEncryption
- Encryption - Interface in io.fluxcapacitor.common.encryption
- ensureAccessible(T) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- ensureMessageSegment(SerializedMessage) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- Entry() - Constructor for class io.fluxcapacitor.common.search.Document.Entry
- entrySet() - Method in class io.fluxcapacitor.common.api.Metadata
- EnvironmentVariablesSource - Enum Class in io.fluxcapacitor.common.application
- equals(Object) - Method in class io.fluxcapacitor.common.api.Data
- equals(Object) - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- equals(Object) - Method in class io.fluxcapacitor.common.tracking.WebSocketTracker
- ERROR - Enum constant in enum class io.fluxcapacitor.common.MessageType
- ErrorHandler<T> - Interface in io.fluxcapacitor.common
- ErrorResult - Class in io.fluxcapacitor.common.api
- ErrorResult() - Constructor for class io.fluxcapacitor.common.api.ErrorResult
- escapeFieldName(String) - Static method in class io.fluxcapacitor.common.SearchUtils
- EVENT - Enum constant in enum class io.fluxcapacitor.common.MessageType
- EventBatch - Class in io.fluxcapacitor.common.api.eventsourcing
- EventBatch() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.EventBatch
- EventBatch.Metric - Class in io.fluxcapacitor.common.api.eventsourcing
- eventSourcingPath() - Static method in class io.fluxcapacitor.common.ServicePathBuilder
- execute(Runnable) - Method in class io.fluxcapacitor.common.DirectExecutorService
- executeExpiredTasks() - Method in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- executeExpiredTasks() - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
- executeExpiredTasksAsync() - Method in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- exists(boolean, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.ExistsConstraint
- exists(String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.ExistsConstraint
- ExistsConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- ExistsConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.ExistsConstraint
- expectResult() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
- expectResult() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- expectResult() - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- expectResult() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.SimpleInvoker
F
- Facet - Annotation Interface in io.fluxcapacitor.common.search
-
Marker annotation on fields and methods that indicates that a property is to be used as facet when indexing a document for search.
- FacetConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- FacetConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.FacetConstraint
- FacetEntry - Class in io.fluxcapacitor.common.api.search
- FacetEntry() - Constructor for class io.fluxcapacitor.common.api.search.FacetEntry
- FacetStats - Class in io.fluxcapacitor.common.api.search
- FacetStats() - Constructor for class io.fluxcapacitor.common.api.search.FacetStats
- fallsInRange(int, int[]) - Static method in class io.fluxcapacitor.common.ConsistentHashing
- fallsInRange(String, int[]) - Static method in class io.fluxcapacitor.common.ConsistentHashing
- fallsInRange(String, int[], int) - Static method in class io.fluxcapacitor.common.ConsistentHashing
- FieldStats(List<Document>, String) - Constructor for class io.fluxcapacitor.common.api.search.DocumentStats.FieldStats
- FileUtils - Class in io.fluxcapacitor.common
- FileUtils() - Constructor for class io.fluxcapacitor.common.FileUtils
- filter(List<SerializedMessage>, int[], Position, Tracker) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- filterMessage(M, Parameter) - Method in interface io.fluxcapacitor.common.handling.ParameterResolver
- filterPaths(Predicate<Document.Path>) - Method in class io.fluxcapacitor.common.search.Document
- forAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>>) - Static method in class io.fluxcapacitor.common.Backlog
- forAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>>, int) - Static method in class io.fluxcapacitor.common.Backlog
- forAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>>, int, ErrorHandler<List<T>>) - Static method in class io.fluxcapacitor.common.Backlog
- forceThrow(Throwable) - Static method in class io.fluxcapacitor.common.ObjectUtils
- forConsumer(ThrowingConsumer<List<T>>) - Static method in class io.fluxcapacitor.common.Backlog
- forConsumer(ThrowingConsumer<List<T>>, int) - Static method in class io.fluxcapacitor.common.Backlog
- forConsumer(ThrowingConsumer<List<T>>, int, ErrorHandler<List<T>>) - Static method in class io.fluxcapacitor.common.Backlog
- forEach(Consumer<? super R>) - Method in class io.fluxcapacitor.common.DefaultMemoizingBiFunction
- forEach(Consumer<? super R>) - Method in interface io.fluxcapacitor.common.MemoizingBiFunction
- forEach(Consumer<? super V>) - Method in class io.fluxcapacitor.common.DefaultMemoizingFunction
- forEach(Consumer<? super V>) - Method in interface io.fluxcapacitor.common.MemoizingFunction
- formatSortable(Object) - Static method in class io.fluxcapacitor.common.api.search.IndexedEntry
- fromData(Data<byte[]>, Supplier<Document>) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- fromDocument(SerializedDocument) - Static method in class io.fluxcapacitor.common.api.search.bulkupdate.IndexDocument
- fromEncryptionKey(String) - Static method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- fromFile(Class<?>, String) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(Class<?>, String, JavaType) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(Class<?>, String, Class<T>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(Class<?>, String, Function<TypeFactory, JavaType>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(String) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(String...) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(String, JavaType) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(String, Class<T>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFile(String, Function<TypeFactory, JavaType>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFileAs(String) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromFileWith(String, Map<String, Object>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(byte[]) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(byte[], JavaType) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(byte[], Class<T>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(byte[], Type) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(byte[], Function<TypeFactory, JavaType>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(String) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(String, JavaType) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(String, Class<T>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(String, Type) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- fromJson(String, Function<TypeFactory, JavaType>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- FULL_SEGMENT - Static variable in class io.fluxcapacitor.common.api.tracking.Position
G
- generateNewEncryptionKey() - Static method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- GenericTypeResolver - Class in io.fluxcapacitor.common.reflection
- GenericTypeResolver() - Constructor for class io.fluxcapacitor.common.reflection.GenericTypeResolver
- get() - Method in class io.fluxcapacitor.common.DefaultMemoizingSupplier
- get(Object) - Method in class io.fluxcapacitor.common.api.Metadata
- get(Object, TypeReference<T>) - Method in class io.fluxcapacitor.common.api.Metadata
- get(Object, Class<T>) - Method in class io.fluxcapacitor.common.api.Metadata
- get(String) - Method in class io.fluxcapacitor.common.api.search.Group
- get(String) - Method in class io.fluxcapacitor.common.application.DecryptingPropertySource
- get(String) - Method in class io.fluxcapacitor.common.application.DefaultPropertySource
- get(String) - Method in enum class io.fluxcapacitor.common.application.EnvironmentVariablesSource
- get(String) - Method in class io.fluxcapacitor.common.application.JavaPropertiesSource
- get(String) - Method in enum class io.fluxcapacitor.common.application.NoOpPropertySource
- get(String) - Method in interface io.fluxcapacitor.common.application.PropertySource
- get(String) - Method in class io.fluxcapacitor.common.application.SimplePropertySource
- get(String, String) - Method in interface io.fluxcapacitor.common.application.PropertySource
- GetAggregateIds - Class in io.fluxcapacitor.common.api.modeling
- GetAggregateIds() - Constructor for class io.fluxcapacitor.common.api.modeling.GetAggregateIds
- GetAggregateIdsResult - Class in io.fluxcapacitor.common.api.modeling
- GetAggregateIdsResult() - Constructor for class io.fluxcapacitor.common.api.modeling.GetAggregateIdsResult
- getAlgorithm() - Method in class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- getAlgorithm() - Method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- getAlgorithm() - Method in interface io.fluxcapacitor.common.encryption.Encryption
- getAlgorithm() - Method in enum class io.fluxcapacitor.common.encryption.NoOpEncryption
- getAllMethods(Class<?>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedFields(Class<?>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedFields(Object, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedMethods(Class<?>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedMethods(Object, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedProperties(Class<?>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedProperty(Class<?>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedProperty(Object, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedPropertyValue(Object, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotatedPropertyValues(Object, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotation(AnnotatedElement, Class<A>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotation(Executable) - Method in class io.fluxcapacitor.common.handling.HandlerConfiguration
- getAnnotationAs(Annotation, Class<? extends Annotation>, Class<? extends T>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotationAs(Class<?>, Class<? extends Annotation>, Class<T>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getAnnotationAs(AnnotatedElement, Class<? extends Annotation>, Class<? extends T>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getBatch(int[], Position, int) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- getBatch(Tracker, PositionStore) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- getBatch(Tracker, PositionStore) - Method in interface io.fluxcapacitor.common.tracking.TrackingStrategy
- getBatch(Long, int) - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- getBatch(Long, int, boolean) - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- getBefore() - Method in class io.fluxcapacitor.common.api.search.SearchQuery
- getBoolean(String) - Method in interface io.fluxcapacitor.common.application.PropertySource
- getBoolean(String, boolean) - Method in interface io.fluxcapacitor.common.application.PropertySource
- getBytes(ByteBuffer) - Static method in class io.fluxcapacitor.common.ObjectUtils
- getCallerClass() - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getClient() - Method in interface io.fluxcapacitor.common.api.ClientEvent
- getClientId() - Method in interface io.fluxcapacitor.common.api.ClientEvent
- getClientId() - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- getClientId() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- getCollection() - Method in interface io.fluxcapacitor.common.api.search.BulkUpdate
- getCollectionElementType(AccessibleObject) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getCollectionElementType(Type) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getConsumerName() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- getContent(Class<?>, String) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- getContent(URI) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- getDeadline() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- getDocument() - Method in class io.fluxcapacitor.common.api.search.SerializedDocument
- GetDocument - Class in io.fluxcapacitor.common.api.search
- GetDocument() - Constructor for class io.fluxcapacitor.common.api.search.GetDocument
- GetDocumentResult - Class in io.fluxcapacitor.common.api.search
- GetDocumentResult() - Constructor for class io.fluxcapacitor.common.api.search.GetDocumentResult
- GetDocumentResult.Metric - Class in io.fluxcapacitor.common.api.search
- GetDocumentStats - Class in io.fluxcapacitor.common.api.search
- GetDocumentStats() - Constructor for class io.fluxcapacitor.common.api.search.GetDocumentStats
- GetDocumentStatsResult - Class in io.fluxcapacitor.common.api.search
- GetDocumentStatsResult() - Constructor for class io.fluxcapacitor.common.api.search.GetDocumentStatsResult
- GetDocumentStatsResult.Metric - Class in io.fluxcapacitor.common.api.search
- getEnclosingClass(AccessibleObject) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getEncryptionKey() - Method in class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- getEncryptionKey() - Method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- getEncryptionKey() - Method in interface io.fluxcapacitor.common.encryption.Encryption
- getEncryptionKey() - Method in enum class io.fluxcapacitor.common.encryption.NoOpEncryption
- getEnd() - Method in class io.fluxcapacitor.common.api.search.SerializedDocument
- getEnd() - Method in class io.fluxcapacitor.common.search.Document
- getEntries() - Method in class io.fluxcapacitor.common.api.Metadata
- getEntryAtPath(String) - Method in class io.fluxcapacitor.common.search.Document
- getEntryType(JsonToken) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- getEnvironment() - Static method in class io.fluxcapacitor.common.application.ApplicationEnvironmentPropertiesSource
- GetEvents - Class in io.fluxcapacitor.common.api.eventsourcing
- GetEvents() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.GetEvents
- GetEventsResult - Class in io.fluxcapacitor.common.api.eventsourcing
- GetEventsResult() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.GetEventsResult
- GetEventsResult.Metric - Class in io.fluxcapacitor.common.api.eventsourcing
- getFacets(Object) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- getFacets(Object, Metadata) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- getFacets(AccessibleObject, Object) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- GetFacetStats - Class in io.fluxcapacitor.common.api.search
- GetFacetStats() - Constructor for class io.fluxcapacitor.common.api.search.GetFacetStats
- GetFacetStatsResult - Class in io.fluxcapacitor.common.api.search
- GetFacetStatsResult() - Constructor for class io.fluxcapacitor.common.api.search.GetFacetStatsResult
- GetFacetStatsResult.Metric - Class in io.fluxcapacitor.common.api.search
- getField(Class<?>, String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getFieldAnnotation(Field, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getFieldValue(String, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getFirstTypeArgument(Type) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getFormat() - Method in class io.fluxcapacitor.common.api.Data
- getGenericPropertyType(AccessibleObject) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getGenericType(Class<?>, Class<?>) - Static method in class io.fluxcapacitor.common.reflection.GenericTypeResolver
- getGenericType(Class<?>, Class<?>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getGlobMatcher(String) - Static method in class io.fluxcapacitor.common.SearchUtils
-
Converts a standard POSIX Shell globbing pattern into a regular expression pattern.
- getGuarantee() - Method in class io.fluxcapacitor.common.api.Command
- getGuarantee() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValueIfAbsent
- getGuarantee() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValuesAndWait
- getGuarantee() - Method in class io.fluxcapacitor.common.api.publishing.Append
- getId() - Method in interface io.fluxcapacitor.common.api.HasId
- getId() - Method in interface io.fluxcapacitor.common.api.search.BulkUpdate
- getIndex(int) - Method in class io.fluxcapacitor.common.api.tracking.Position
- getIndexed(Object) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- getIndexedEntries(Object) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- getIndexedEntries(AccessibleObject, Object) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- getIndexedEntries(Predicate<Document.Path>) - Method in class io.fluxcapacitor.common.search.Document
- getInvoker(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- getInvoker(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerMatcher
- getInvoker(M) - Method in class io.fluxcapacitor.common.handling.DefaultHandler
- getInvoker(M) - Method in interface io.fluxcapacitor.common.handling.Handler
- getInvoker(T, M) - Method in interface io.fluxcapacitor.common.handling.HandlerMatcher
- getLastTrackerIndex() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- getLeastSpecificAllowedClass(Executable, Class<? extends Annotation>) - Method in interface io.fluxcapacitor.common.handling.MessageFilter
- getMatchingEntries(Predicate<Document.Path>) - Method in class io.fluxcapacitor.common.search.Document
- getMaxSize() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- getMechanism() - Method in class io.fluxcapacitor.common.serialization.GlobalTypeIdResolver
- getMember() - Method in interface io.fluxcapacitor.common.reflection.MemberInvoker
- getMemberAnnotation(Class<?>, String, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getMessageStore() - Method in interface io.fluxcapacitor.common.tracking.HasMessageStore
- getMessageStore() - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- getMetadata() - Method in interface io.fluxcapacitor.common.api.HasMetadata
- getMethod() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
- getMethod() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- getMethod() - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- getMethod() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.SimpleInvoker
- getMethod(Class<?>, String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getMethodAnnotation() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
- getMethodAnnotation() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- getMethodAnnotation() - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- getMethodAnnotation() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.SimpleInvoker
- getMethodAnnotation(Executable, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getMethodAnnotations(Executable, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getMethodOverrideHierarchy(Method) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getName(AccessibleObject) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getOrDefault(Object, String) - Method in class io.fluxcapacitor.common.api.Metadata
- getOriginalRevision() - Method in class io.fluxcapacitor.common.api.SerializedMessage
- getOrThrow(Object, Supplier<? extends X>) - Method in class io.fluxcapacitor.common.api.Metadata
- getOutputType() - Method in class io.fluxcapacitor.common.search.JacksonInverter
- getOutputType() - Method in class io.fluxcapacitor.common.serialization.AbstractConverter
- getOutputType() - Method in interface io.fluxcapacitor.common.serialization.Converter
- getPackageAndParentPackages(Package) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getPackageAnnotation(Package, Class<A>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getPackageAnnotations(Package) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getPackageAnnotations(Package, boolean) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getParameterIndex(Parameter) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getParameterName(Parameter) - Method in class io.fluxcapacitor.common.reflection.ParameterRegistry
- getParameterNames(Executable) - Method in class io.fluxcapacitor.common.reflection.ParameterRegistry
- getParameterOverrideHierarchy(Parameter) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getPaths() - Method in class io.fluxcapacitor.common.api.search.constraints.ExistsConstraint
- getPaths() - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint
- GetPosition - Class in io.fluxcapacitor.common.api.tracking
- GetPosition() - Constructor for class io.fluxcapacitor.common.api.tracking.GetPosition
- GetPositionResult - Class in io.fluxcapacitor.common.api.tracking
- GetPositionResult() - Constructor for class io.fluxcapacitor.common.api.tracking.GetPositionResult
- getPriority(Annotation) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- getProcessingDuration(Tracker) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- getPropertyAnnotation(String, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getPropertyName(AccessibleObject) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getPropertyType(AccessibleObject) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getPurgeDelay() - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- getPurgeDelay() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- GetRelationships - Class in io.fluxcapacitor.common.api.modeling
- GetRelationships() - Constructor for class io.fluxcapacitor.common.api.modeling.GetRelationships
- GetRelationshipsResult - Class in io.fluxcapacitor.common.api.modeling
- GetRelationshipsResult() - Constructor for class io.fluxcapacitor.common.api.modeling.GetRelationshipsResult
- getRequestId() - Method in interface io.fluxcapacitor.common.api.QueryResult
- getRevision() - Method in class io.fluxcapacitor.common.api.SerializedMessage
- getRevision() - Method in interface io.fluxcapacitor.common.api.SerializedObject
- GetSchedule - Class in io.fluxcapacitor.common.api.scheduling
- GetSchedule() - Constructor for class io.fluxcapacitor.common.api.scheduling.GetSchedule
- GetScheduleResult - Class in io.fluxcapacitor.common.api.scheduling
- GetScheduleResult() - Constructor for class io.fluxcapacitor.common.api.scheduling.GetScheduleResult
- GetSearchHistogram - Class in io.fluxcapacitor.common.api.search
- GetSearchHistogram() - Constructor for class io.fluxcapacitor.common.api.search.GetSearchHistogram
- GetSearchHistogramResult - Class in io.fluxcapacitor.common.api.search
- GetSearchHistogramResult() - Constructor for class io.fluxcapacitor.common.api.search.GetSearchHistogramResult
- getSegment(Tracker) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- getSimpleName(String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getSize() - Method in class io.fluxcapacitor.common.api.eventsourcing.EventBatch
- getSize() - Method in class io.fluxcapacitor.common.api.publishing.Append
- getSize() - Method in class io.fluxcapacitor.common.api.search.BulkUpdateDocuments
- getSize() - Method in class io.fluxcapacitor.common.api.search.IndexDocuments
- getSize() - Method in class io.fluxcapacitor.common.api.tracking.MessageBatch
- getSupportedSourceVersion() - Method in class io.fluxcapacitor.common.serialization.TypeRegistryProcessor
- getTargetClass() - Method in class io.fluxcapacitor.common.handling.DefaultHandler
- getTargetClass() - Method in class io.fluxcapacitor.common.handling.Handler.DelegatingHandler
- getTargetClass() - Method in interface io.fluxcapacitor.common.handling.Handler
- getTargetClass() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
- getTargetClass() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- getTargetClass() - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- getTargetClass() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.SimpleInvoker
- getTimestamp() - Method in interface io.fluxcapacitor.common.api.ClientEvent
- getTimestamp() - Method in interface io.fluxcapacitor.common.api.QueryResult
- getTraceEntries() - Method in class io.fluxcapacitor.common.api.Metadata
- getTrackerId() - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- getTrackerId() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- getTrackers() - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- getType() - Method in class io.fluxcapacitor.common.api.search.bulkupdate.DeleteDocument
- getType() - Method in interface io.fluxcapacitor.common.api.search.BulkUpdate
- getType() - Method in class io.fluxcapacitor.common.api.search.bulkupdate.IndexDocument
- getType() - Method in class io.fluxcapacitor.common.api.search.bulkupdate.IndexDocumentIfNotExists
- getType() - Method in class io.fluxcapacitor.common.api.SerializedMessage
- getType() - Method in interface io.fluxcapacitor.common.api.SerializedObject
- getTypeAnnotation(Class<?>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getTypeAnnotations(Class<?>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getTypeArgument(Type, int) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getTypeArguments(Type) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getTypeFilter() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- getTypeName(String) - Method in class io.fluxcapacitor.common.serialization.DefaultTypeRegistry
- getTypeName(String) - Method in enum class io.fluxcapacitor.common.serialization.NoOpTypeRegistry
- getTypeName(String) - Method in interface io.fluxcapacitor.common.serialization.TypeRegistry
- getValue() - Method in class io.fluxcapacitor.common.api.Data
- getValue(AccessibleObject, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- getValue(AccessibleObject, Object, boolean) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- GetValue - Class in io.fluxcapacitor.common.api.keyvalue
- GetValue() - Constructor for class io.fluxcapacitor.common.api.keyvalue.GetValue
- GetValueResult - Class in io.fluxcapacitor.common.api.keyvalue
- GetValueResult() - Constructor for class io.fluxcapacitor.common.api.keyvalue.GetValueResult
- GetValueResult.Metric - Class in io.fluxcapacitor.common.api.keyvalue
- getZone() - Method in class io.fluxcapacitor.common.DelegatingClock
- GlobalTypeIdResolver - Class in io.fluxcapacitor.common.serialization
- GlobalTypeIdResolver() - Constructor for class io.fluxcapacitor.common.serialization.GlobalTypeIdResolver
- Group - Class in io.fluxcapacitor.common.api.search
- Group(Map<String, String>) - Constructor for class io.fluxcapacitor.common.api.search.Group
- Guarantee - Enum Class in io.fluxcapacitor.common
- GZIP - Enum constant in enum class io.fluxcapacitor.common.serialization.compression.CompressionAlgorithm
H
- handleError(Throwable, T) - Method in interface io.fluxcapacitor.common.ErrorHandler
- Handler<M> - Interface in io.fluxcapacitor.common.handling
- Handler.DelegatingHandler<M> - Class in io.fluxcapacitor.common.handling
- HandlerConfiguration<M> - Class in io.fluxcapacitor.common.handling
- HandlerConfiguration() - Constructor for class io.fluxcapacitor.common.handling.HandlerConfiguration
- HandlerFilter - Interface in io.fluxcapacitor.common.handling
- HandlerInspector - Class in io.fluxcapacitor.common.handling
- HandlerInspector() - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector
- HandlerInspector.MethodHandlerMatcher<M> - Class in io.fluxcapacitor.common.handling
- HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker - Class in io.fluxcapacitor.common.handling
- HandlerInspector.ObjectHandlerMatcher<M> - Class in io.fluxcapacitor.common.handling
- HandlerInvoker - Interface in io.fluxcapacitor.common.handling
- HandlerInvoker.DelegatingHandlerInvoker - Class in io.fluxcapacitor.common.handling
- HandlerInvoker.SimpleInvoker - Class in io.fluxcapacitor.common.handling
- HandlerMatcher<T,
M> - Interface in io.fluxcapacitor.common.handling - has(Class<? extends Annotation>, Method) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- has(Class<? extends Annotation>, Parameter) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- HasDocument - Class in io.fluxcapacitor.common.api.search
- HasDocument() - Constructor for class io.fluxcapacitor.common.api.search.HasDocument
- hasHandlerMethods(Class<?>, HandlerConfiguration<?>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector
- hashCode() - Method in class io.fluxcapacitor.common.api.Data
- hashCode() - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- hashCode() - Method in class io.fluxcapacitor.common.tracking.WebSocketTracker
- HasId - Interface in io.fluxcapacitor.common.api
- HasMessageStore - Interface in io.fluxcapacitor.common.tracking
- HasMetadata - Interface in io.fluxcapacitor.common.api
- hasMissedDeadline() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- hasPathConstraint() - Method in interface io.fluxcapacitor.common.api.search.Constraint
- hasPathConstraint() - Method in class io.fluxcapacitor.common.api.search.constraints.AllConstraint
- hasPathConstraint() - Method in class io.fluxcapacitor.common.api.search.constraints.AnyConstraint
- hasPathConstraint() - Method in class io.fluxcapacitor.common.api.search.constraints.FacetConstraint
- hasPathConstraint() - Method in class io.fluxcapacitor.common.api.search.constraints.NotConstraint
- hasPathConstraint() - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint
- hasPathConstraint() - Method in class io.fluxcapacitor.common.api.search.NoOpConstraint
- hasProperty(String, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
I
- identityFunction - Static variable in class io.fluxcapacitor.common.search.Document
- idFromValue(Object) - Method in class io.fluxcapacitor.common.serialization.GlobalTypeIdResolver
- idFromValueAndType(Object, Class<?>) - Method in class io.fluxcapacitor.common.serialization.GlobalTypeIdResolver
- ifClass(Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- ifTrue(boolean) - Static method in class io.fluxcapacitor.common.ObjectUtils
- ignoreSegment() - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- ignoreSegment() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- index - Enum constant in enum class io.fluxcapacitor.common.api.search.BulkUpdate.Type
- IndexDocument - Class in io.fluxcapacitor.common.api.search.bulkupdate
- IndexDocument() - Constructor for class io.fluxcapacitor.common.api.search.bulkupdate.IndexDocument
- IndexDocumentIfNotExists - Class in io.fluxcapacitor.common.api.search.bulkupdate
- IndexDocumentIfNotExists() - Constructor for class io.fluxcapacitor.common.api.search.bulkupdate.IndexDocumentIfNotExists
- IndexDocuments - Class in io.fluxcapacitor.common.api.search
- IndexDocuments() - Constructor for class io.fluxcapacitor.common.api.search.IndexDocuments
- IndexDocuments.Metric - Class in io.fluxcapacitor.common.api.search
- Indexed - Annotation Interface in io.fluxcapacitor.common.search
-
Marker annotation on fields and getters that indicates that a property is to be indexed for sorting and filtering.
- IndexedEntry - Class in io.fluxcapacitor.common.api.search
- IndexedEntry(String, Object) - Constructor for class io.fluxcapacitor.common.api.search.IndexedEntry
- indexIfNotExists - Enum constant in enum class io.fluxcapacitor.common.api.search.BulkUpdate.Type
- init(ProcessingEnvironment) - Method in class io.fluxcapacitor.common.serialization.TypeRegistryProcessor
- InMemoryPositionStore - Class in io.fluxcapacitor.common.tracking
- InMemoryPositionStore() - Constructor for class io.fluxcapacitor.common.tracking.InMemoryPositionStore
- InMemoryTaskScheduler - Class in io.fluxcapacitor.common.tracking
- InMemoryTaskScheduler() - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(int) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(int, String) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(int, String, Clock) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(int, String, Clock, ExecutorService) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(int, Clock) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(String) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(String, Clock) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(String, Clock, ExecutorService) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler(Clock) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- InMemoryTaskScheduler.Task - Class in io.fluxcapacitor.common.tracking
- inspect(Class<?>, List<ParameterResolver<? super M>>, HandlerConfiguration<? super M>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector
- inspect(Class<?>, List<ParameterResolver<? super M>>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector
- instance - Static variable in class io.fluxcapacitor.common.api.search.NoOpConstraint
- INSTANCE - Enum constant in enum class io.fluxcapacitor.common.application.EnvironmentVariablesSource
- INSTANCE - Enum constant in enum class io.fluxcapacitor.common.application.NoOpPropertySource
- INSTANCE - Enum constant in enum class io.fluxcapacitor.common.encryption.NoOpEncryption
- INSTANCE - Enum constant in enum class io.fluxcapacitor.common.search.DefaultDocumentSerializer
- INSTANCE - Enum constant in enum class io.fluxcapacitor.common.serialization.NoOpTypeRegistry
- instant() - Method in class io.fluxcapacitor.common.DelegatingClock
- invert(byte[]) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- Inverter<T> - Interface in io.fluxcapacitor.common.search
- invoke() - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- invoke(Object) - Method in interface io.fluxcapacitor.common.reflection.MemberInvoker
- invoke(Object, int, IntFunction<?>) - Method in class io.fluxcapacitor.common.reflection.DefaultMemberInvoker
- invoke(Object, int, IntFunction<?>) - Method in interface io.fluxcapacitor.common.reflection.MemberInvoker
- invoke(Object, Object) - Method in interface io.fluxcapacitor.common.reflection.MemberInvoker
- invoke(Object, Object...) - Method in interface io.fluxcapacitor.common.reflection.MemberInvoker
- invoke(BiFunction<Object, Object, Object>) - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- invoke(BiFunction<Object, Object, Object>) - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.SimpleInvoker
- io.fluxcapacitor.common - package io.fluxcapacitor.common
- io.fluxcapacitor.common.api - package io.fluxcapacitor.common.api
- io.fluxcapacitor.common.api.eventsourcing - package io.fluxcapacitor.common.api.eventsourcing
- io.fluxcapacitor.common.api.keyvalue - package io.fluxcapacitor.common.api.keyvalue
- io.fluxcapacitor.common.api.modeling - package io.fluxcapacitor.common.api.modeling
- io.fluxcapacitor.common.api.publishing - package io.fluxcapacitor.common.api.publishing
- io.fluxcapacitor.common.api.scheduling - package io.fluxcapacitor.common.api.scheduling
- io.fluxcapacitor.common.api.search - package io.fluxcapacitor.common.api.search
- io.fluxcapacitor.common.api.search.bulkupdate - package io.fluxcapacitor.common.api.search.bulkupdate
- io.fluxcapacitor.common.api.search.constraints - package io.fluxcapacitor.common.api.search.constraints
- io.fluxcapacitor.common.api.tracking - package io.fluxcapacitor.common.api.tracking
- io.fluxcapacitor.common.application - package io.fluxcapacitor.common.application
- io.fluxcapacitor.common.encryption - package io.fluxcapacitor.common.encryption
- io.fluxcapacitor.common.handling - package io.fluxcapacitor.common.handling
- io.fluxcapacitor.common.reflection - package io.fluxcapacitor.common.reflection
- io.fluxcapacitor.common.search - package io.fluxcapacitor.common.search
- io.fluxcapacitor.common.serialization - package io.fluxcapacitor.common.serialization
- io.fluxcapacitor.common.serialization.compression - package io.fluxcapacitor.common.serialization.compression
- io.fluxcapacitor.common.tracking - package io.fluxcapacitor.common.tracking
- isActive(Tracker) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- isAnnotationPresent(Class<?>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- isAnnotationPresent(Parameter, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- isCached() - Method in class io.fluxcapacitor.common.DefaultMemoizingSupplier
- isCached() - Method in interface io.fluxcapacitor.common.MemoizingSupplier
- isCached(K) - Method in class io.fluxcapacitor.common.DefaultMemoizingFunction
- isCached(K) - Method in interface io.fluxcapacitor.common.MemoizingFunction
- isCached(T, U) - Method in class io.fluxcapacitor.common.DefaultMemoizingBiFunction
- isCached(T, U) - Method in interface io.fluxcapacitor.common.MemoizingBiFunction
- isConstant(Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- isEmpty() - Method in class io.fluxcapacitor.common.api.eventsourcing.EventBatch
- isEmpty() - Method in class io.fluxcapacitor.common.api.tracking.MessageBatch
- isEmpty() - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- isEmptyRange(int[]) - Static method in class io.fluxcapacitor.common.ConsistentHashing
- isEncrypted(String) - Method in class io.fluxcapacitor.common.encryption.ChaCha20Poly1305Encryption
- isEncrypted(String) - Method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- isEncrypted(String) - Method in interface io.fluxcapacitor.common.encryption.Encryption
- isEncrypted(String) - Method in enum class io.fluxcapacitor.common.encryption.NoOpEncryption
- isEncryptedWithKnownAlgorithm(String) - Method in class io.fluxcapacitor.common.encryption.DefaultEncryption
- isFilterMessageTarget() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- isIgnoreMessageTarget() - Method in class io.fluxcapacitor.common.api.tracking.Read
- isInteger(String) - Static method in class io.fluxcapacitor.common.SearchUtils
- isKotlinReflectionSupported() - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- isLongPath(String) - Static method in class io.fluxcapacitor.common.search.Document.Path
- isMethodAnnotationPresent(Class<?>, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- isMissedDeadline(long) - Static method in class io.fluxcapacitor.common.TimingUtils
- isMissedDeadline(Clock, long) - Static method in class io.fluxcapacitor.common.TimingUtils
- isNew(int[]) - Method in class io.fluxcapacitor.common.api.tracking.Position
- isNewIndex(int, Long) - Method in class io.fluxcapacitor.common.api.tracking.Position
- isNewMessage(SerializedMessage) - Method in class io.fluxcapacitor.common.api.tracking.Position
- isNullable(Parameter) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- ISO_FULL - Static variable in class io.fluxcapacitor.common.SearchUtils
- isOrHas(Annotation, Class<? extends Annotation>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- isPassive() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
- isPassive() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- isPassive() - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- isPassive() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.SimpleInvoker
- isPassive(Annotation) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- isShutdown() - Method in class io.fluxcapacitor.common.DirectExecutorService
- isStatic(Executable) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- isStopped() - Method in class io.fluxcapacitor.common.application.AutoClosing
- isTerminated() - Method in class io.fluxcapacitor.common.DirectExecutorService
- iterate(T, UnaryOperator<T>, Predicate<T>) - Static method in class io.fluxcapacitor.common.ObjectUtils
J
- JacksonInverter - Class in io.fluxcapacitor.common.search
- JacksonInverter() - Constructor for class io.fluxcapacitor.common.search.JacksonInverter
- JacksonInverter(JsonMapper) - Constructor for class io.fluxcapacitor.common.search.JacksonInverter
- JavaPropertiesSource - Class in io.fluxcapacitor.common.application
- JavaPropertiesSource(Properties) - Constructor for class io.fluxcapacitor.common.application.JavaPropertiesSource
- join(PropertySource...) - Static method in interface io.fluxcapacitor.common.application.PropertySource
- join(List<? extends HandlerInvoker>) - Static method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- JSON_FORMAT - Static variable in class io.fluxcapacitor.common.api.Data
- JsonType - Interface in io.fluxcapacitor.common.api
- JsonUtils - Class in io.fluxcapacitor.common.serialization
- JsonUtils() - Constructor for class io.fluxcapacitor.common.serialization.JsonUtils
K
- KeyValuePair - Class in io.fluxcapacitor.common.api.keyvalue
- KeyValuePair() - Constructor for class io.fluxcapacitor.common.api.keyvalue.KeyValuePair
- keyValuePath() - Static method in class io.fluxcapacitor.common.ServicePathBuilder
- KotlinReflectionUtils - Class in io.fluxcapacitor.common.reflection
- KotlinReflectionUtils() - Constructor for class io.fluxcapacitor.common.reflection.KotlinReflectionUtils
L
- lastMatch() - Method in class io.fluxcapacitor.common.api.search.SearchDocumentsResult
- letterOrNumber - Static variable in class io.fluxcapacitor.common.SearchUtils
- loadFile(File) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(File, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(Class<?>, String) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(Class<?>, String, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(String) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(String, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(URI) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(URI, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- loadFile(URL, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- loadProperties(String) - Static method in class io.fluxcapacitor.common.application.ApplicationEnvironmentPropertiesSource
- loadProperties(String) - Static method in class io.fluxcapacitor.common.FileUtils
- lookAhead(String, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.LookAheadConstraint
- LookAheadConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- LookAheadConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.LookAheadConstraint
- lowestIndexForSegment(int[]) - Method in class io.fluxcapacitor.common.api.tracking.Position
- LZ4 - Enum constant in enum class io.fluxcapacitor.common.serialization.compression.CompressionAlgorithm
M
- map(ThrowingFunction<T, M>) - Method in class io.fluxcapacitor.common.api.Data
- match(Object, boolean, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.MatchConstraint
- match(Object, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.MatchConstraint
- MatchConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- MatchConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.MatchConstraint
- matches(SerializedDocument) - Method in class io.fluxcapacitor.common.api.search.SearchQuery
- matches(Document) - Method in interface io.fluxcapacitor.common.api.search.Constraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.constraints.AllConstraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.constraints.AnyConstraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.constraints.FacetConstraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.constraints.LookAheadConstraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.constraints.NotConstraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.constraints.QueryConstraint
- matches(Document) - Method in class io.fluxcapacitor.common.api.search.NoOpConstraint
- matches(Document.Entry) - Method in class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint
- matches(Document.Entry) - Method in class io.fluxcapacitor.common.api.search.constraints.ContainsConstraint
- matches(Document.Entry) - Method in class io.fluxcapacitor.common.api.search.constraints.ExistsConstraint
- matches(Document.Entry) - Method in class io.fluxcapacitor.common.api.search.constraints.LookAheadConstraint
- matches(Document.Entry) - Method in class io.fluxcapacitor.common.api.search.constraints.MatchConstraint
- matches(Document.Entry) - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint
- matches(Document.Entry) - Method in class io.fluxcapacitor.common.api.search.constraints.QueryConstraint
- matches(Parameter, Annotation, M) - Method in interface io.fluxcapacitor.common.handling.ParameterResolver
- matches(Parameter, Annotation, M) - Method in class io.fluxcapacitor.common.handling.TypedParameterResolver
- matchFacet(FacetEntry) - Static method in class io.fluxcapacitor.common.api.search.constraints.FacetConstraint
- matchFacet(String, Object) - Static method in class io.fluxcapacitor.common.api.search.constraints.FacetConstraint
- matchingMethods(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- matchingMethods(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerMatcher
- matchingMethods(M) - Method in interface io.fluxcapacitor.common.handling.HandlerMatcher
- MAX_SEGMENT - Static variable in class io.fluxcapacitor.common.api.tracking.Position
- maxTimeout() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- MemberInvoker - Interface in io.fluxcapacitor.common.reflection
- memoize(BiFunction<T, U, R>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- memoize(Function<K, V>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- memoize(Supplier<T>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- MemoizingBiFunction<T,
U, - Interface in io.fluxcapacitor.commonR> - MemoizingFunction<K,
V> - Interface in io.fluxcapacitor.common - MemoizingSupplier<T> - Interface in io.fluxcapacitor.common
- merge(Position) - Method in class io.fluxcapacitor.common.api.tracking.Position
- merge(Registration) - Method in interface io.fluxcapacitor.common.Registration
- merge(Properties, Properties) - Static method in class io.fluxcapacitor.common.ObjectUtils
- merge(T, Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- MessageBatch - Class in io.fluxcapacitor.common.api.tracking
- MessageBatch() - Constructor for class io.fluxcapacitor.common.api.tracking.MessageBatch
- MessageBatch.Metric - Class in io.fluxcapacitor.common.api.tracking
- MessageFilter<M> - Interface in io.fluxcapacitor.common.handling
- MessageStore - Interface in io.fluxcapacitor.common.tracking
- MessageType - Enum Class in io.fluxcapacitor.common
- Metadata - Class in io.fluxcapacitor.common.api
- MethodHandlerInvoker() - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
- MethodHandlerMatcher(Executable, Class<?>, List<ParameterResolver<? super M>>, HandlerConfiguration<? super M>) - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- methodIndex(Method, Class<?>) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- methodMatches(Class<?>, Executable) - Method in class io.fluxcapacitor.common.handling.HandlerConfiguration
- Metric() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.AppendEvents.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.EventBatch.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.eventsourcing.GetEventsResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.keyvalue.GetValueResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.keyvalue.StoreValueIfAbsent.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.keyvalue.StoreValues.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.keyvalue.StoreValuesAndWait.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.publishing.Append.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.scheduling.Schedule.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.scheduling.SerializedSchedule.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.search.BulkUpdateDocuments.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.search.GetDocumentResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.search.GetDocumentStatsResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.search.GetFacetStatsResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.search.IndexDocuments.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.search.SearchDocumentsResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.tracking.ClaimSegmentResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.tracking.MessageBatch.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.tracking.ReadFromIndexResult.Metric
- Metric() - Constructor for class io.fluxcapacitor.common.api.tracking.ReadResult.Metric
- METRICS - Enum constant in enum class io.fluxcapacitor.common.MessageType
- Monitored<T> - Interface in io.fluxcapacitor.common
- Murmur3 - Class in io.fluxcapacitor.common
-
The MurmurHash3 algorithm was created by Austin Appleby and placed in the public domain.
- Murmur3() - Constructor for class io.fluxcapacitor.common.Murmur3
- murmurhash3_x86_32(CharSequence) - Static method in class io.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.common.handling.HandlerFilter
- newInstance() - Static method in class io.fluxcapacitor.common.DirectExecutorService
- newNamedWorkStealingPool(int, String) - Static method in class io.fluxcapacitor.common.ObjectUtils
- newObjectNode(Object...) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- newPosition() - Static method in class io.fluxcapacitor.common.api.tracking.Position
- newThreadFactory(String) - Static method in class io.fluxcapacitor.common.ObjectUtils
- newThreadName(String) - Static method in class io.fluxcapacitor.common.ObjectUtils
- NONE - Enum constant in enum class io.fluxcapacitor.common.Guarantee
- NONE - Enum constant in enum class io.fluxcapacitor.common.serialization.compression.CompressionAlgorithm
- noOp() - Static method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- noOp() - Static method in interface io.fluxcapacitor.common.Registration
- noOpBiPredicate() - Static method in class io.fluxcapacitor.common.ObjectUtils
- NoOpConstraint - Class in io.fluxcapacitor.common.api.search
- NoOpConstraint() - Constructor for class io.fluxcapacitor.common.api.search.NoOpConstraint
- NoOpEncryption - Enum Class in io.fluxcapacitor.common.encryption
- noOpPredicate() - Static method in class io.fluxcapacitor.common.ObjectUtils
- NoOpPropertySource - Enum Class in io.fluxcapacitor.common.application
- NoOpTypeRegistry - Enum Class in io.fluxcapacitor.common.serialization
- normalize(String) - Static method in class io.fluxcapacitor.common.SearchUtils
- normalizeJson(byte[]) - Static method in class io.fluxcapacitor.common.SearchUtils
- normalizePath(String) - Static method in class io.fluxcapacitor.common.SearchUtils
- not(Constraint) - Static method in class io.fluxcapacitor.common.api.search.constraints.NotConstraint
- NotConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- NotConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.NotConstraint
- NOTIFICATION - Enum constant in enum class io.fluxcapacitor.common.MessageType
- NULL - Enum constant in enum class io.fluxcapacitor.common.search.Document.EntryType
- NullCollectionsAsEmptyModule - Class in io.fluxcapacitor.common.serialization
- NullCollectionsAsEmptyModule() - Constructor for class io.fluxcapacitor.common.serialization.NullCollectionsAsEmptyModule
- NUMERIC - Enum constant in enum class io.fluxcapacitor.common.search.Document.EntryType
O
- ObjectHandlerMatcher() - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerMatcher
- objectMapper - Static variable in class io.fluxcapacitor.common.api.Metadata
- ObjectUtils - Class in io.fluxcapacitor.common
- ObjectUtils() - Constructor for class io.fluxcapacitor.common.ObjectUtils
- of(Class<?>) - Static method in class io.fluxcapacitor.common.reflection.ParameterRegistry
- of(Object...) - Static method in class io.fluxcapacitor.common.api.Metadata
- of(Object, Object) - Static method in class io.fluxcapacitor.common.api.Metadata
- of(String...) - Static method in class io.fluxcapacitor.common.api.search.Group
- of(Map<?, ?>) - Static method in class io.fluxcapacitor.common.api.Metadata
- onClusterUpdate(TrackerCluster) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- onShutdown() - Method in class io.fluxcapacitor.common.application.AutoClosing
-
Override to do something on shutdown
- onUpdate(List<SerializedMessage>) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- or(Constraint) - Method in interface io.fluxcapacitor.common.api.search.Constraint
- or(HandlerFilter) - Method in interface io.fluxcapacitor.common.handling.HandlerFilter
- orTimeout(CompletableFuture<R>, Duration) - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
P
- Pair<T,
U> - Class in io.fluxcapacitor.common - Pair() - Constructor for class io.fluxcapacitor.common.Pair
- ParameterRegistry - Class in io.fluxcapacitor.common.reflection
- ParameterRegistry() - Constructor for class io.fluxcapacitor.common.reflection.ParameterRegistry
- ParameterResolver<M> - Interface in io.fluxcapacitor.common.handling
- parseObject(JsonParser, Map<Document.Entry, List<Document.Path>>, String) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- Path() - Constructor for class io.fluxcapacitor.common.search.Document.Path
- PathConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- PathConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.PathConstraint
- pathPredicate(String) - Static method in class io.fluxcapacitor.common.search.Document.Path
- position(Tracker, PositionStore, int[]) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- position(String) - Method in class io.fluxcapacitor.common.tracking.InMemoryPositionStore
- position(String) - Method in interface io.fluxcapacitor.common.tracking.PositionStore
- Position - Class in io.fluxcapacitor.common.api.tracking
- Position(int[], long) - Constructor for class io.fluxcapacitor.common.api.tracking.Position
- Position(long) - Constructor for class io.fluxcapacitor.common.api.tracking.Position
- PositionStore - Interface in io.fluxcapacitor.common.tracking
- prepareInvoker(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher
- process(Set<? extends TypeElement>, RoundEnvironment) - Method in class io.fluxcapacitor.common.serialization.TypeRegistryProcessor
- processToken(JsonToken, Map<Document.Entry, List<Document.Path>>, String, JsonParser) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- producerPath(MessageType) - Static method in class io.fluxcapacitor.common.ServicePathBuilder
- PropertySource - Interface in io.fluxcapacitor.common.application
- purgeCeasedTrackers(Duration) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- purgeCeasedTrackers(Instant) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- purgeTrackers(Predicate<Tracker>) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
Q
- query(String, boolean, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.QueryConstraint
- query(String, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.QueryConstraint
- QUERY - Enum constant in enum class io.fluxcapacitor.common.MessageType
- QueryConstraint - Class in io.fluxcapacitor.common.api.search.constraints
- QueryConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.QueryConstraint
- QueryResult - Interface in io.fluxcapacitor.common.api
R
- Read - Class in io.fluxcapacitor.common.api.tracking
- Read() - Constructor for class io.fluxcapacitor.common.api.tracking.Read
- reader - Static variable in class io.fluxcapacitor.common.serialization.JsonUtils
- ReadFromIndex - Class in io.fluxcapacitor.common.api.tracking
- ReadFromIndex() - Constructor for class io.fluxcapacitor.common.api.tracking.ReadFromIndex
- ReadFromIndexResult - Class in io.fluxcapacitor.common.api.tracking
- ReadFromIndexResult() - Constructor for class io.fluxcapacitor.common.api.tracking.ReadFromIndexResult
- ReadFromIndexResult.Metric - Class in io.fluxcapacitor.common.api.tracking
- readProperty(String, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- ReadResult - Class in io.fluxcapacitor.common.api.tracking
- ReadResult() - Constructor for class io.fluxcapacitor.common.api.tracking.ReadResult
- ReadResult.Metric - Class in io.fluxcapacitor.common.api.tracking
- readTree(byte[]) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- readTree(InputStream) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- readTree(String) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- ReflectionUtils - Class in io.fluxcapacitor.common.reflection
- ReflectionUtils() - Constructor for class io.fluxcapacitor.common.reflection.ReflectionUtils
- registerMonitor(Consumer<List<T>>) - Method in class io.fluxcapacitor.common.Backlog
- registerMonitor(Consumer<T>) - Method in interface io.fluxcapacitor.common.Monitored
- RegisterType - Annotation Interface in io.fluxcapacitor.common.serialization
-
Annotation to mark a type or package that should be registered in the
TypeRegistry. - registerValue(Document.EntryType, String, String, Map<Document.Entry, List<Document.Path>>) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- Registration - Interface in io.fluxcapacitor.common
- Relationship - Class in io.fluxcapacitor.common.api.modeling
- Relationship() - Constructor for class io.fluxcapacitor.common.api.modeling.Relationship
- remove(K) - Method in class io.fluxcapacitor.common.DefaultMemoizingFunction
- remove(K) - Method in interface io.fluxcapacitor.common.MemoizingFunction
- remove(T, U) - Method in class io.fluxcapacitor.common.DefaultMemoizingBiFunction
- remove(T, U) - Method in interface io.fluxcapacitor.common.MemoizingBiFunction
- RepairRelationships - Class in io.fluxcapacitor.common.api.modeling
- RepairRelationships() - Constructor for class io.fluxcapacitor.common.api.modeling.RepairRelationships
- Request - Class in io.fluxcapacitor.common.api
- Request() - Constructor for class io.fluxcapacitor.common.api.Request
- RequestBatch<T> - Class in io.fluxcapacitor.common.api
- RequestBatch() - Constructor for class io.fluxcapacitor.common.api.RequestBatch
- require(String) - Method in interface io.fluxcapacitor.common.application.PropertySource
- resetPosition(String, long) - Method in class io.fluxcapacitor.common.tracking.InMemoryPositionStore
- resetPosition(String, long) - Method in interface io.fluxcapacitor.common.tracking.PositionStore
- ResetPosition - Class in io.fluxcapacitor.common.api.tracking
- ResetPosition() - Constructor for class io.fluxcapacitor.common.api.tracking.ResetPosition
- resolve(Parameter, Annotation) - Method in interface io.fluxcapacitor.common.handling.ParameterResolver
- RESULT - Enum constant in enum class io.fluxcapacitor.common.MessageType
- ResultBatch - Class in io.fluxcapacitor.common.api
- ResultBatch() - Constructor for class io.fluxcapacitor.common.api.ResultBatch
- RetryConfiguration - Class in io.fluxcapacitor.common
- RetryConfiguration() - Constructor for class io.fluxcapacitor.common.RetryConfiguration
- retryOnFailure(Runnable, Duration) - Static method in class io.fluxcapacitor.common.TimingUtils
- retryOnFailure(Runnable, Duration, Predicate<Exception>) - Static method in class io.fluxcapacitor.common.TimingUtils
- retryOnFailure(Callable<T>, RetryConfiguration) - Static method in class io.fluxcapacitor.common.TimingUtils
- retryOnFailure(Callable<T>, Duration) - Static method in class io.fluxcapacitor.common.TimingUtils
- retryOnFailure(Callable<T>, Duration, Predicate<Exception>) - Static method in class io.fluxcapacitor.common.TimingUtils
- RetryStatus - Class in io.fluxcapacitor.common
- RetryStatus() - Constructor for class io.fluxcapacitor.common.RetryStatus
- Revision - Annotation Interface in io.fluxcapacitor.common.serialization
- routingKey() - Method in class io.fluxcapacitor.common.api.Command
- routingKey() - Method in class io.fluxcapacitor.common.api.eventsourcing.AppendEvents
- routingKey() - Method in class io.fluxcapacitor.common.api.eventsourcing.DeleteEvents
- routingKey() - Method in class io.fluxcapacitor.common.api.keyvalue.DeleteValue
- routingKey() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValueIfAbsent
- routingKey() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValues
- routingKey() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValuesAndWait
- routingKey() - Method in class io.fluxcapacitor.common.api.modeling.RepairRelationships
- routingKey() - Method in class io.fluxcapacitor.common.api.modeling.UpdateRelationships
- routingKey() - Method in class io.fluxcapacitor.common.api.publishing.Append
- routingKey() - Method in class io.fluxcapacitor.common.api.scheduling.CancelSchedule
- routingKey() - Method in class io.fluxcapacitor.common.api.search.BulkUpdateDocuments
- routingKey() - Method in class io.fluxcapacitor.common.api.search.CreateAuditTrail
- routingKey() - Method in class io.fluxcapacitor.common.api.search.DeleteCollection
- routingKey() - Method in class io.fluxcapacitor.common.api.search.DeleteDocumentById
- routingKey() - Method in class io.fluxcapacitor.common.api.search.DeleteDocuments
- routingKey() - Method in class io.fluxcapacitor.common.api.search.IndexDocuments
- routingKey() - Method in class io.fluxcapacitor.common.api.tracking.DisconnectTracker
- routingKey() - Method in class io.fluxcapacitor.common.api.tracking.ResetPosition
- routingKey() - Method in class io.fluxcapacitor.common.api.tracking.StorePosition
- run() - Method in interface io.fluxcapacitor.common.ThrowingRunnable
- run() - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy.WaitingTracker
- run(ThrowingRunnable) - Static method in interface io.fluxcapacitor.common.handling.HandlerInvoker
- run(ThrowingRunnable) - Static method in class io.fluxcapacitor.common.ObjectUtils
S
- safeResolve(URI, String) - Static method in class io.fluxcapacitor.common.FileUtils
- schedule(long, ThrowingRunnable) - Method in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- schedule(long, ThrowingRunnable) - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
- schedule(Duration, ThrowingRunnable) - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
- schedule(Instant, ThrowingRunnable) - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
- Schedule - Class in io.fluxcapacitor.common.api.scheduling
- Schedule() - Constructor for class io.fluxcapacitor.common.api.scheduling.Schedule
- SCHEDULE - Enum constant in enum class io.fluxcapacitor.common.MessageType
- Schedule.Metric - Class in io.fluxcapacitor.common.api.scheduling
- schedulingPath() - Static method in class io.fluxcapacitor.common.ServicePathBuilder
- SearchDocuments - Class in io.fluxcapacitor.common.api.search
- SearchDocuments() - Constructor for class io.fluxcapacitor.common.api.search.SearchDocuments
- SearchDocumentsResult - Class in io.fluxcapacitor.common.api.search
- SearchDocumentsResult() - Constructor for class io.fluxcapacitor.common.api.search.SearchDocumentsResult
- SearchDocumentsResult.Metric - Class in io.fluxcapacitor.common.api.search
- SearchExclude - Annotation Interface in io.fluxcapacitor.common.search
-
Marker annotation that indicates that a property is to be ignored when indexing a document for search.
- SearchHistogram - Class in io.fluxcapacitor.common.api.search
- SearchHistogram() - Constructor for class io.fluxcapacitor.common.api.search.SearchHistogram
- searchIgnoreCache - Static variable in class io.fluxcapacitor.common.search.JacksonInverter
- SearchInclude - Annotation Interface in io.fluxcapacitor.common.search
-
Marker annotation that indicates that a property is to be included when indexing a document for search.
- searchPath() - Static method in class io.fluxcapacitor.common.ServicePathBuilder
- SearchQuery - Class in io.fluxcapacitor.common.api.search
- SearchQuery(List<String>, Instant, Instant, boolean, boolean, List<Constraint>) - Constructor for class io.fluxcapacitor.common.api.search.SearchQuery
- SearchUtils - Class in io.fluxcapacitor.common
- SearchUtils() - Constructor for class io.fluxcapacitor.common.SearchUtils
- send(MessageBatch) - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- send(MessageBatch) - Method in interface io.fluxcapacitor.common.tracking.Tracker
- send(MessageBatch) - Method in class io.fluxcapacitor.common.tracking.WebSocketTracker
- sendEmptyBatch(MessageBatch) - Method in interface io.fluxcapacitor.common.tracking.Tracker
- SENT - Enum constant in enum class io.fluxcapacitor.common.Guarantee
- serialize() - Method in enum class io.fluxcapacitor.common.search.Document.EntryType
- serialize(Document) - Method in enum class io.fluxcapacitor.common.search.DefaultDocumentSerializer
- SerializedDocument - Class in io.fluxcapacitor.common.api.search
- SerializedDocument(Document) - Constructor for class io.fluxcapacitor.common.api.search.SerializedDocument
- SerializedDocument(String, Long, Long, String, Data<byte[]>, String, Set<FacetEntry>, Set<IndexedEntry>) - Constructor for class io.fluxcapacitor.common.api.search.SerializedDocument
- SerializedMessage - Class in io.fluxcapacitor.common.api
- SerializedMessage(Data<byte[]>, Metadata, String, Long) - Constructor for class io.fluxcapacitor.common.api.SerializedMessage
- SerializedObject<T> - Interface in io.fluxcapacitor.common.api
- SerializedSchedule - Class in io.fluxcapacitor.common.api.scheduling
- SerializedSchedule() - Constructor for class io.fluxcapacitor.common.api.scheduling.SerializedSchedule
- SerializedSchedule.Metric - Class in io.fluxcapacitor.common.api.scheduling
- ServicePathBuilder - Class in io.fluxcapacitor.common
- ServicePathBuilder() - Constructor for class io.fluxcapacitor.common.ServicePathBuilder
- setDelegate(Clock) - Method in class io.fluxcapacitor.common.DelegatingClock
- setField(Field, Object, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- setField(String, Object, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- setRetentionTime(Duration) - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- SetRetentionTime - Class in io.fluxcapacitor.common.api.publishing
- SetRetentionTime() - Constructor for class io.fluxcapacitor.common.api.publishing.SetRetentionTime
- setupModule(Module.SetupContext) - Method in class io.fluxcapacitor.common.serialization.NullCollectionsAsEmptyModule
- setupModule(Module.SetupContext) - Method in class io.fluxcapacitor.common.serialization.StripStringsModule
- shutdown() - Method in class io.fluxcapacitor.common.DirectExecutorService
- shutdown() - Method in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- shutdown() - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
- shutDown() - Method in class io.fluxcapacitor.common.Backlog
- shutdownNow() - Method in class io.fluxcapacitor.common.DirectExecutorService
- signature(Executable) - Static method in class io.fluxcapacitor.common.reflection.ParameterRegistry
- signature(ExecutableElement) - Static method in class io.fluxcapacitor.common.reflection.ParameterRegistry
- SimpleInvoker() - Constructor for class io.fluxcapacitor.common.handling.HandlerInvoker.SimpleInvoker
- SimplePropertySource - Class in io.fluxcapacitor.common.application
- SimplePropertySource() - Constructor for class io.fluxcapacitor.common.application.SimplePropertySource
- SimpleTracker - Class in io.fluxcapacitor.common.tracking
- SimpleTracker(String, int, Consumer<MessageBatch>) - Constructor for class io.fluxcapacitor.common.tracking.SimpleTracker
- singleTracker() - Method in interface io.fluxcapacitor.common.tracking.Tracker
- size() - Method in class io.fluxcapacitor.common.api.search.SearchDocumentsResult
- split(String) - Static method in class io.fluxcapacitor.common.search.Document.Path
- splitInSegments() - Method in class io.fluxcapacitor.common.api.tracking.Position
- splitInTerms(String) - Static method in class io.fluxcapacitor.common.SearchUtils
- STORED - Enum constant in enum class io.fluxcapacitor.common.Guarantee
- storePosition(String, int[], long) - Method in class io.fluxcapacitor.common.tracking.InMemoryPositionStore
- storePosition(String, int[], long) - Method in interface io.fluxcapacitor.common.tracking.PositionStore
- StorePosition - Class in io.fluxcapacitor.common.api.tracking
- StorePosition() - Constructor for class io.fluxcapacitor.common.api.tracking.StorePosition
- StoreValueIfAbsent - Class in io.fluxcapacitor.common.api.keyvalue
- StoreValueIfAbsent() - Constructor for class io.fluxcapacitor.common.api.keyvalue.StoreValueIfAbsent
- StoreValueIfAbsent.Metric - Class in io.fluxcapacitor.common.api.keyvalue
- StoreValues - Class in io.fluxcapacitor.common.api.keyvalue
- StoreValues() - Constructor for class io.fluxcapacitor.common.api.keyvalue.StoreValues
- StoreValues.Metric - Class in io.fluxcapacitor.common.api.keyvalue
- StoreValuesAndWait - Class in io.fluxcapacitor.common.api.keyvalue
- StoreValuesAndWait() - Constructor for class io.fluxcapacitor.common.api.keyvalue.StoreValuesAndWait
- StoreValuesAndWait.Metric - Class in io.fluxcapacitor.common.api.keyvalue
- StringResult - Class in io.fluxcapacitor.common.api
- StringResult() - Constructor for class io.fluxcapacitor.common.api.StringResult
- StripStringsModule - Class in io.fluxcapacitor.common.serialization
- StripStringsModule() - Constructor for class io.fluxcapacitor.common.serialization.StripStringsModule
- submit(ThrowingRunnable) - Method in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- submit(ThrowingRunnable) - Method in interface io.fluxcapacitor.common.tracking.TaskScheduler
- substituteProperties(String) - Method in interface io.fluxcapacitor.common.application.PropertySource
- substitutionPattern - Static variable in interface io.fluxcapacitor.common.application.PropertySource
- summarize(Object) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- SystemPropertiesSource - Class in io.fluxcapacitor.common.application
- SystemPropertiesSource() - Constructor for class io.fluxcapacitor.common.application.SystemPropertiesSource
T
- Task(ThrowingRunnable, long) - Constructor for class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler.Task
- TaskScheduler - Interface in io.fluxcapacitor.common.tracking
- termPattern - Static variable in class io.fluxcapacitor.common.SearchUtils
- test(Class<?>, Executable) - Method in interface io.fluxcapacitor.common.handling.HandlerFilter
- test(M, Executable, Class<? extends Annotation>) - Method in interface io.fluxcapacitor.common.handling.MessageFilter
- TEXT - Enum constant in enum class io.fluxcapacitor.common.search.Document.EntryType
- ThrowingBiConsumer<T,
U> - Interface in io.fluxcapacitor.common - ThrowingBiFunction<T,
U, - Interface in io.fluxcapacitor.commonR> - ThrowingConsumer<T> - Interface in io.fluxcapacitor.common
- ThrowingFunction<T,
R> - Interface in io.fluxcapacitor.common - ThrowingRunnable - Interface in io.fluxcapacitor.common
- time(Runnable, Consumer<Long>) - Static method in class io.fluxcapacitor.common.TimingUtils
- time(Runnable, Consumer<Long>, TemporalUnit) - Static method in class io.fluxcapacitor.common.TimingUtils
- time(Callable<T>, Consumer<Long>) - Static method in class io.fluxcapacitor.common.TimingUtils
- time(Callable<T>, Consumer<Long>, TemporalUnit) - Static method in class io.fluxcapacitor.common.TimingUtils
- TimingUtils - Class in io.fluxcapacitor.common
- TimingUtils() - Constructor for class io.fluxcapacitor.common.TimingUtils
- toDocument(Object, String, int, String, String, Instant, Instant, Metadata) - Method in interface io.fluxcapacitor.common.search.Inverter
- toDocument(Object, String, int, String, String, Instant, Instant, Metadata) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- toJsonData(JsonNode, Data<byte[]>) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- toJsonNode(Document.Entry) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- toJsonNode(Object) - Method in class io.fluxcapacitor.common.search.JacksonInverter
- toMetric() - Method in class io.fluxcapacitor.common.api.eventsourcing.AppendEvents
- toMetric() - Method in class io.fluxcapacitor.common.api.eventsourcing.EventBatch
- toMetric() - Method in class io.fluxcapacitor.common.api.eventsourcing.GetEventsResult
- toMetric() - Method in interface io.fluxcapacitor.common.api.JsonType
- toMetric() - Method in class io.fluxcapacitor.common.api.keyvalue.GetValueResult
- toMetric() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValueIfAbsent
- toMetric() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValues
- toMetric() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValuesAndWait
- toMetric() - Method in class io.fluxcapacitor.common.api.publishing.Append
- toMetric() - Method in class io.fluxcapacitor.common.api.scheduling.Schedule
- toMetric() - Method in class io.fluxcapacitor.common.api.scheduling.SerializedSchedule
- toMetric() - Method in class io.fluxcapacitor.common.api.search.BulkUpdateDocuments
- toMetric() - Method in class io.fluxcapacitor.common.api.search.GetDocumentResult
- toMetric() - Method in class io.fluxcapacitor.common.api.search.GetDocumentStatsResult
- toMetric() - Method in class io.fluxcapacitor.common.api.search.GetFacetStatsResult
- toMetric() - Method in class io.fluxcapacitor.common.api.search.IndexDocuments
- toMetric() - Method in class io.fluxcapacitor.common.api.search.SearchDocumentsResult
- toMetric() - Method in class io.fluxcapacitor.common.api.tracking.ClaimSegmentResult
- toMetric() - Method in class io.fluxcapacitor.common.api.tracking.MessageBatch
- toMetric() - Method in class io.fluxcapacitor.common.api.tracking.ReadFromIndexResult
- toMetric() - Method in class io.fluxcapacitor.common.api.tracking.ReadResult
- toSortableString(Number) - Static method in class io.fluxcapacitor.common.api.search.IndexedEntry
- toString() - Method in class io.fluxcapacitor.common.api.eventsourcing.AppendEvents
- toString() - Method in class io.fluxcapacitor.common.api.eventsourcing.EventBatch
- toString() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValueIfAbsent
- toString() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValues
- toString() - Method in class io.fluxcapacitor.common.api.keyvalue.StoreValuesAndWait
- toString() - Method in class io.fluxcapacitor.common.api.Metadata
- toString() - Method in class io.fluxcapacitor.common.api.publishing.Append
- toString() - Method in class io.fluxcapacitor.common.api.scheduling.Schedule
- toString() - Method in class io.fluxcapacitor.common.api.search.BulkUpdateDocuments
- toString() - Method in class io.fluxcapacitor.common.api.search.IndexDocuments
- toString() - Method in class io.fluxcapacitor.common.api.tracking.MessageBatch
- toString() - Method in class io.fluxcapacitor.common.handling.DefaultHandler
- toString() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerMatcher.MethodHandlerInvoker
- toString() - Method in class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker
- toString() - Method in class io.fluxcapacitor.common.tracking.SimpleTracker
- toString() - Method in class io.fluxcapacitor.common.tracking.WebSocketTracker
- Tracker - Interface in io.fluxcapacitor.common.tracking
- TrackerCluster - Class in io.fluxcapacitor.common.tracking
- TrackerCluster(int) - Constructor for class io.fluxcapacitor.common.tracking.TrackerCluster
- TrackingStrategy - Interface in io.fluxcapacitor.common.tracking
- tryAccept(Consumer<? super T>) - Static method in class io.fluxcapacitor.common.ObjectUtils
- tryCatch(Runnable) - Static method in class io.fluxcapacitor.common.ObjectUtils
- tryLoadFile(File) - Static method in class io.fluxcapacitor.common.FileUtils
- tryLoadFile(File, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- tryLoadFile(Class<?>, String) - Static method in class io.fluxcapacitor.common.FileUtils
- tryLoadFile(Class<?>, String, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- tryLoadFile(String) - Static method in class io.fluxcapacitor.common.FileUtils
- tryLoadFile(String, Charset) - Static method in class io.fluxcapacitor.common.FileUtils
- tryRun(Runnable) - Static method in class io.fluxcapacitor.common.ObjectUtils
- tryRunTask(InMemoryTaskScheduler.Task) - Method in class io.fluxcapacitor.common.tracking.InMemoryTaskScheduler
- TypedParameterResolver<M> - Class in io.fluxcapacitor.common.handling
- TypedParameterResolver() - Constructor for class io.fluxcapacitor.common.handling.TypedParameterResolver
- typeFactory() - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- typeFromId(DatabindContext, String) - Method in class io.fluxcapacitor.common.serialization.GlobalTypeIdResolver
- TypeRegistry - Interface in io.fluxcapacitor.common.serialization
- TypeRegistryProcessor - Class in io.fluxcapacitor.common.serialization
- TypeRegistryProcessor() - Constructor for class io.fluxcapacitor.common.serialization.TypeRegistryProcessor
- TYPES_FILE - Static variable in class io.fluxcapacitor.common.serialization.TypeRegistryProcessor
U
- unescapeFieldName(String) - Static method in class io.fluxcapacitor.common.SearchUtils
- unwrap(Class<T>) - Method in interface io.fluxcapacitor.common.tracking.MessageStore
- unwrapException(Throwable) - Static method in class io.fluxcapacitor.common.ObjectUtils
- UpdateRelationships - Class in io.fluxcapacitor.common.api.modeling
- UpdateRelationships() - Constructor for class io.fluxcapacitor.common.api.modeling.UpdateRelationships
V
- value() - Element in annotation interface io.fluxcapacitor.common.search.Facet
-
Optional argument that defines the name of the facet.
- value() - Element in annotation interface io.fluxcapacitor.common.search.Indexed
-
Optional argument that defines the name of the indexed property.
- value() - Element in annotation interface io.fluxcapacitor.common.search.SearchExclude
-
Optional argument that defines whether this annotation is active (
true) or not (false). - value() - Element in annotation interface io.fluxcapacitor.common.serialization.Revision
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.api.search.BulkUpdate.Type
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.application.EnvironmentVariablesSource
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.application.NoOpPropertySource
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.encryption.NoOpEncryption
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.Guarantee
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.MessageType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.search.DefaultDocumentSerializer
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.search.Document.EntryType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.serialization.compression.CompressionAlgorithm
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.fluxcapacitor.common.serialization.NoOpTypeRegistry
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class io.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.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.fluxcapacitor.common.serialization.NoOpTypeRegistry
-
Returns an array containing the constants of this enum class, in the order they are declared.
- valueToTree(Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils
- VoidResult - Class in io.fluxcapacitor.common.api
- VoidResult() - Constructor for class io.fluxcapacitor.common.api.VoidResult
W
- waitForMessages(Tracker, MessageBatch, PositionStore) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- waitForUpdate(Tracker, MessageBatch, Runnable) - Method in class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy
- WaitingTracker() - Constructor for class io.fluxcapacitor.common.tracking.DefaultTrackingStrategy.WaitingTracker
- WEBREQUEST - Enum constant in enum class io.fluxcapacitor.common.MessageType
- WEBRESPONSE - Enum constant in enum class io.fluxcapacitor.common.MessageType
- WebSocketTracker - Class in io.fluxcapacitor.common.tracking
- WebSocketTracker(Read, MessageType, String, String, Consumer<MessageBatch>) - Constructor for class io.fluxcapacitor.common.tracking.WebSocketTracker
- with(Metadata) - Method in class io.fluxcapacitor.common.api.Metadata
- with(Object...) - Method in class io.fluxcapacitor.common.api.Metadata
- with(Object, Object) - Method in class io.fluxcapacitor.common.api.Metadata
- with(Map<?, ?>) - Method in class io.fluxcapacitor.common.api.Metadata
- withActiveTracker(Tracker) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- withData(Data<byte[]>) - Method in class io.fluxcapacitor.common.api.SerializedMessage
- withData(Data<T>) - Method in class io.fluxcapacitor.common.api.Data
- withData(Data<T>) - Method in interface io.fluxcapacitor.common.api.SerializedObject
- withLastTrackerIndex(Long) - Method in interface io.fluxcapacitor.common.tracking.Tracker
- without(Object) - Method in class io.fluxcapacitor.common.api.Metadata
- withoutIf(Predicate<String>) - Method in class io.fluxcapacitor.common.api.Metadata
- withoutTracker(Tracker) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- withPaths(List<String>) - Method in class io.fluxcapacitor.common.api.search.constraints.ExistsConstraint
- withPaths(List<String>) - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint
- withTrace(Object, Object) - Method in class io.fluxcapacitor.common.api.Metadata
- withWaitingTracker(Tracker) - Method in class io.fluxcapacitor.common.tracking.TrackerCluster
- withZone(ZoneId) - Method in class io.fluxcapacitor.common.DelegatingClock
- writeFile(String, String) - Static method in class io.fluxcapacitor.common.FileUtils
- writeProperty(String, Object, Object) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils
- writer - Static variable in class io.fluxcapacitor.common.serialization.JsonUtils
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form