Index

A B C D E F G H I J K L M N O P Q R S T U V W 
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
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,R> - Class in io.fluxcapacitor.common
 
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,R> - Interface in io.fluxcapacitor.common
 
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,R> - Interface in io.fluxcapacitor.common
 
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
 
A B C D E F G H I J K L M N O P Q R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form