Index

A B C D E F G H I J K L M N O P Q R S T V W
All Classes|All Packages

A

accept(List<T>) - Method in interface io.fluxcapacitor.common.Backlog.BatchConsumer

add(Collection<? extends T>) - Method in class io.fluxcapacitor.common.Backlog

add(T...) - Method in class io.fluxcapacitor.common.Backlog

addIfAbsent(String, String) - Method in class io.fluxcapacitor.common.api.Metadata

afterRetry(Exception) - Method in class io.fluxcapacitor.common.RetryStatus

all(Constraint...) - Static method in class io.fluxcapacitor.common.api.search.constraints.AllConstraint

all(List<Constraint>) - Static method in class io.fluxcapacitor.common.api.search.constraints.AllConstraint

ALL - io.fluxcapacitor.common.api.tracking.TrackingStrategy

AllConstraint - Class in io.fluxcapacitor.common.api.search.constraints

AllConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.AllConstraint

and(Constraint) - Method in interface io.fluxcapacitor.common.api.search.Constraint

any(Constraint...) - Static method in class io.fluxcapacitor.common.api.search.constraints.AnyConstraint

any(List<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 - 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

apply(K) - Method in class io.fluxcapacitor.common.ObjectUtils.MemoizingFunction

apply(T, U) - Method in class io.fluxcapacitor.common.ObjectUtils.MemoizingBiFunction

asBytes(Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils

asCompletableFuture() - Method in interface io.fluxcapacitor.common.Awaitable

asInteger(String) - Static method in class io.fluxcapacitor.common.SearchUtils

asJson(Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils

asPrettyJson(Object) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils

asSerializedDocument(Data<byte[]>) - Method in enum io.fluxcapacitor.common.search.DefaultDocumentSerializer

atLeast(Object, String) - Static method in class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint

await() - Method in interface io.fluxcapacitor.common.Awaitable

Awaitable - Interface in io.fluxcapacitor.common

awaitSilently() - Method in interface io.fluxcapacitor.common.Awaitable

B

Backlog<T> - Class in io.fluxcapacitor.common

Backlog(Backlog.BatchConsumer<T>) - Constructor for class io.fluxcapacitor.common.Backlog

Backlog(Backlog.BatchConsumer<T>, int) - Constructor for class io.fluxcapacitor.common.Backlog

Backlog(Backlog.BatchConsumer<T>, int, 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 - 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 in io.fluxcapacitor.common.api.search

BulkUpdateDocuments - Class in io.fluxcapacitor.common.api.search

BulkUpdateDocuments() - Constructor for class io.fluxcapacitor.common.api.search.BulkUpdateDocuments

C

callerClassFilter() - Static method in class io.fluxcapacitor.common.FileUtils

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

canHandle(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

canHandle(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerInvoker

canHandle(Object, M) - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker

canHandle(M) - Method in interface io.fluxcapacitor.common.handling.Handler

canHandle(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.DefaultHandler

checkPathBeforeEntry() - Method in class io.fluxcapacitor.common.api.search.constraints.BetweenConstraint

checkPathBeforeEntry() - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint

classExists(String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

classForName(String) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

ClientEvent - Interface in io.fluxcapacitor.common.api

clock - Static variable in class io.fluxcapacitor.common.IndexUtils

COMMAND - io.fluxcapacitor.common.MessageType

comparator - Static variable in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

compareTo(Document.Entry) - Method in class io.fluxcapacitor.common.search.Document.Entry

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 in io.fluxcapacitor.common.serialization.compression

CompressionUtils - Class in io.fluxcapacitor.common.serialization.compression

CompressionUtils() - Constructor for class io.fluxcapacitor.common.serialization.compression.CompressionUtils

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

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(String, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.ContainsConstraint

containsAnyKey(String...) - Method in class io.fluxcapacitor.common.api.Metadata

ContainsConstraint - Class in io.fluxcapacitor.common.api.search.constraints

ContainsConstraint(String, String) - Constructor for class io.fluxcapacitor.common.api.search.constraints.ContainsConstraint

containsKey(String) - Method in class io.fluxcapacitor.common.api.Metadata

convertGlobToRegex(String) - Static method in class io.fluxcapacitor.common.SearchUtils

Converts a standard POSIX Shell globbing pattern into a regular expression pattern.

convertValue(Object, Class<? extends T>) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils

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>, List<ParameterResolver<? super M>>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector

createHandler(Object, Class<? extends Annotation>, List<ParameterResolver<? super M>>, HandlerConfiguration) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector

currentTime() - Static method in class io.fluxcapacitor.common.IndexUtils

currentTimeMillis() - Static method in class io.fluxcapacitor.common.IndexUtils

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, 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

DefaultDocumentSerializer - Enum in io.fluxcapacitor.common.search

DefaultHandler() - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector.DefaultHandler

defaultHandlerConfiguration() - Static method in class io.fluxcapacitor.common.handling.HandlerConfiguration

defaultObjectMapper - Static variable in class io.fluxcapacitor.common.search.JacksonInverter

delete - 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 io.fluxcapacitor.common.search.Document.EntryType

deserialize(Data<byte[]>) - Method in enum io.fluxcapacitor.common.search.DefaultDocumentSerializer

determinesSpecificity() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ParameterSupplier

determinesSpecificity() - Method in interface io.fluxcapacitor.common.handling.ParameterResolver

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

Document - Class in io.fluxcapacitor.common.search

Document() - Constructor for class io.fluxcapacitor.common.search.Document

Document.Entry - Class in io.fluxcapacitor.common.search

Document.EntryType - Enum 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

E

empty() - Static method in class io.fluxcapacitor.common.api.Metadata

EMPTY_ARRAY - io.fluxcapacitor.common.search.Document.EntryType

EMPTY_OBJECT - io.fluxcapacitor.common.search.Document.EntryType

ensureAccessible(T) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

Entry() - Constructor for class io.fluxcapacitor.common.search.Document.Entry

entrySet() - Method in class io.fluxcapacitor.common.api.Metadata

equals(Object) - Method in class io.fluxcapacitor.common.api.Data

equals(Object) - Method in class io.fluxcapacitor.common.api.Request

ERROR - io.fluxcapacitor.common.MessageType

ErrorHandler<T> - Interface in io.fluxcapacitor.common

escapeFieldName(String) - Method in class io.fluxcapacitor.common.search.JacksonInverter

EVENT - 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

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(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

expectResult(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerInvoker

expectResult(Object, M) - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker

F

failed(Exception) - Static method in interface io.fluxcapacitor.common.Awaitable

FieldStats() - Constructor for class io.fluxcapacitor.common.api.search.DocumentStats.FieldStats

FileUtils - Class in io.fluxcapacitor.common

FileUtils() - Constructor for class io.fluxcapacitor.common.FileUtils

filterPaths(Predicate<Document.Path>) - Method in class io.fluxcapacitor.common.search.Document

find(String, String...) - Static method in class io.fluxcapacitor.common.api.search.constraints.FindConstraint

FindConstraint - Class in io.fluxcapacitor.common.api.search.constraints

FindConstraint() - Constructor for class io.fluxcapacitor.common.api.search.constraints.FindConstraint

fromDocument(Document) - Method in interface io.fluxcapacitor.common.search.Inverter

fromDocument(Document) - Method in class io.fluxcapacitor.common.search.JacksonInverter

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(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

fromJson(byte[], Class<T>) - 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

G

get() - Method in class io.fluxcapacitor.common.ObjectUtils.MemoizingSupplier

get(String) - Method in class io.fluxcapacitor.common.api.Metadata

get(String, Class<T>) - Method in class io.fluxcapacitor.common.api.Metadata

getAllMethods(Class<?>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

getAnnotatedFields(Object, 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(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

getAnnotation(Executable, Class<A>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

getAnnotations(Class<?>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

getAverage(List<BigDecimal>) - Static method in class io.fluxcapacitor.common.api.search.DocumentStats.FieldStats

getClient() - Method in interface io.fluxcapacitor.common.api.ClientEvent

getClientId() - Method in interface io.fluxcapacitor.common.api.ClientEvent

getCollection() - Method in interface io.fluxcapacitor.common.api.search.BulkUpdate

getCollectionElementType(Type) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

getComparator(List<String>) - Static method in class io.fluxcapacitor.common.api.search.DocumentStats

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

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

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

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

getFirstSequenceNumber() - Method in class io.fluxcapacitor.common.api.eventsourcing.EventBatch

getFormat() - Method in class io.fluxcapacitor.common.api.Data

getId() - Method in interface io.fluxcapacitor.common.api.search.BulkUpdate

getMatcher(Executable, List<ParameterResolver<? super M>>) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

getMatchingEntries(Predicate<Document.Path>) - Method in class io.fluxcapacitor.common.search.Document

getMethod(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

getMethod(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerInvoker

getMethod(Object, M) - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker

getMethod(M) - Method in interface io.fluxcapacitor.common.handling.Handler

getMethod(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.DefaultHandler

getOrDefault(String, String) - Method in class io.fluxcapacitor.common.api.Metadata

getParameterSuppliers(Executable, List<ParameterResolver<? super M>>) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

getPath() - Method in class io.fluxcapacitor.common.api.search.constraints.ExistsConstraint

getPath() - Method in class io.fluxcapacitor.common.api.search.constraints.PathConstraint

getRequestId() - Method in interface io.fluxcapacitor.common.api.QueryResult

getRequestId() - Method in class io.fluxcapacitor.common.api.Request

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

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

getTarget() - Method in interface io.fluxcapacitor.common.handling.Handler

getTarget() - Method in class io.fluxcapacitor.common.handling.HandlerInspector.DefaultHandler

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

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

getTypeAnnotation(Class<?>, Class<A>) - Static method in class io.fluxcapacitor.common.reflection.ReflectionUtils

getValue() - Method in class io.fluxcapacitor.common.api.Data

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

Guarantee - Enum in io.fluxcapacitor.common

H

handleError(Exception, T) - Method in interface io.fluxcapacitor.common.ErrorHandler

Handler<M> - Interface in io.fluxcapacitor.common.handling

HandlerConfiguration - Class in io.fluxcapacitor.common.handling

HandlerConfiguration() - Constructor for class io.fluxcapacitor.common.handling.HandlerConfiguration

HandlerException - Exception in io.fluxcapacitor.common.handling

HandlerException(String) - Constructor for exception io.fluxcapacitor.common.handling.HandlerException

HandlerInspector - Class in io.fluxcapacitor.common.handling

HandlerInspector() - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector

HandlerInspector.DefaultHandler<M> - Class in io.fluxcapacitor.common.handling

HandlerInspector.MethodHandlerInvoker<M> - Class in io.fluxcapacitor.common.handling

HandlerInspector.ObjectHandlerInvoker<M> - Class in io.fluxcapacitor.common.handling

HandlerInspector.ParameterSupplier<M> - Class in io.fluxcapacitor.common.handling

HandlerInvoker<M> - Interface in io.fluxcapacitor.common.handling

HandlerNotFoundException - Exception in io.fluxcapacitor.common.handling

HandlerNotFoundException(String) - Constructor for exception io.fluxcapacitor.common.handling.HandlerNotFoundException

hasHandlerMethods(Class<?>, Class<? extends Annotation>, 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.api.Request

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.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

ifTrue(boolean) - Static method in class io.fluxcapacitor.common.ObjectUtils

index - 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

indexForCurrentTime() - Static method in class io.fluxcapacitor.common.IndexUtils

indexFromMillis(long) - Static method in class io.fluxcapacitor.common.IndexUtils

indexFromTimestamp(Instant) - Static method in class io.fluxcapacitor.common.IndexUtils

indexIfNotExists - io.fluxcapacitor.common.api.search.BulkUpdate.Type

IndexUtils - Class in io.fluxcapacitor.common

Use 48 bits of the current time in milliseconds since epoch as the base of the index.

IndexUtils() - Constructor for class io.fluxcapacitor.common.IndexUtils

inspect(Class<?>, Class<? extends Annotation>, List<ParameterResolver<? super M>>, HandlerConfiguration) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector

instance - Static variable in class io.fluxcapacitor.common.api.search.NoOpConstraint

INSTANCE - io.fluxcapacitor.common.search.DefaultDocumentSerializer

invert(byte[], String, Map<Document.Entry, List<Document.Path>>) - Method in class io.fluxcapacitor.common.search.JacksonInverter

Inverter<T> - Interface in io.fluxcapacitor.common.search

invoke(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

invoke(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerInvoker

invoke(Object, M) - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker

invoke(M) - Method in interface io.fluxcapacitor.common.handling.Handler

invoke(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.DefaultHandler

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.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.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

isCached() - Method in class io.fluxcapacitor.common.ObjectUtils.MemoizingSupplier

isCached(K) - Method in class io.fluxcapacitor.common.ObjectUtils.MemoizingFunction

isCached(T, U) - Method in class io.fluxcapacitor.common.ObjectUtils.MemoizingBiFunction

isEmpty() - Method in class io.fluxcapacitor.common.api.eventsourcing.EventBatch

isEmpty() - Method in class io.fluxcapacitor.common.api.tracking.MessageBatch

isInteger(String) - Static method in class io.fluxcapacitor.common.SearchUtils

isMissedDeadline(long) - Static method in class io.fluxcapacitor.common.TimingUtils

isPassive(Annotation) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

isPassive(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

isPassive(Object, M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerInvoker

isPassive(Object, M) - Method in interface io.fluxcapacitor.common.handling.HandlerInvoker

isPassive(M) - Method in interface io.fluxcapacitor.common.handling.Handler

isPassive(M) - Method in class io.fluxcapacitor.common.handling.HandlerInspector.DefaultHandler

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(ObjectMapper) - Constructor for class io.fluxcapacitor.common.search.JacksonInverter

join(Awaitable) - Method in interface io.fluxcapacitor.common.Awaitable

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

L

lastMatch() - Method in class io.fluxcapacitor.common.api.search.SearchDocumentsResult

loadFile(File) - 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

LZ4 - io.fluxcapacitor.common.serialization.compression.CompressionAlgorithm

M

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(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.FindConstraint

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.NoOpConstraint

matches(Document) - Method in class io.fluxcapacitor.common.api.search.SearchQuery

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.FindConstraint

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(Parameter, M) - Method in interface io.fluxcapacitor.common.handling.ParameterResolver

matchForPath(Object, String) - Static method in class io.fluxcapacitor.common.api.search.constraints.MatchConstraint

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() - Constructor for class io.fluxcapacitor.common.ObjectUtils.MemoizingBiFunction

MemoizingFunction() - Constructor for class io.fluxcapacitor.common.ObjectUtils.MemoizingFunction

MemoizingSupplier(Supplier<T>) - Constructor for class io.fluxcapacitor.common.ObjectUtils.MemoizingSupplier

merge(Registration) - Method in interface io.fluxcapacitor.common.Registration

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

MessageType - Enum in io.fluxcapacitor.common

Metadata - Class in io.fluxcapacitor.common.api

MethodHandlerInvoker(Executable, Class<?>, List<ParameterResolver<? super M>>, Annotation) - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

methodIndex(Method, Class<?>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

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.ScheduledMessage.Metric

Metric() - Constructor for class io.fluxcapacitor.common.api.search.GetDocumentStatsResult.Metric

Metric() - Constructor for class io.fluxcapacitor.common.api.search.SearchDocumentsResult.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 - io.fluxcapacitor.common.MessageType

millisFromIndex(long) - Static method in class io.fluxcapacitor.common.IndexUtils

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

NEW - io.fluxcapacitor.common.api.tracking.TrackingStrategy

NONE - io.fluxcapacitor.common.Guarantee

noOp - Static variable in interface io.fluxcapacitor.common.api.search.Constraint

noOp() - Static method in interface io.fluxcapacitor.common.Registration

NoOpConstraint - Class in io.fluxcapacitor.common.api.search

NoOpConstraint() - Constructor for class io.fluxcapacitor.common.api.search.NoOpConstraint

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 - io.fluxcapacitor.common.MessageType

NULL - io.fluxcapacitor.common.search.Document.EntryType

NullCollectionsAsEmptyModule - Class in io.fluxcapacitor.common.serialization

NullCollectionsAsEmptyModule() - Constructor for class io.fluxcapacitor.common.serialization.NullCollectionsAsEmptyModule

NUMERIC - io.fluxcapacitor.common.search.Document.EntryType

O

ObjectHandlerInvoker() - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector.ObjectHandlerInvoker

objectMapper - Static variable in class io.fluxcapacitor.common.api.Metadata

ObjectUtils - Class in io.fluxcapacitor.common

ObjectUtils() - Constructor for class io.fluxcapacitor.common.ObjectUtils

ObjectUtils.MemoizingBiFunction<T,U,R> - Class in io.fluxcapacitor.common

ObjectUtils.MemoizingFunction<K,V> - Class in io.fluxcapacitor.common

ObjectUtils.MemoizingSupplier<T> - Class in io.fluxcapacitor.common

of(Object...) - Static method in class io.fluxcapacitor.common.api.Metadata

of(String, Object) - Static method in class io.fluxcapacitor.common.api.Metadata

of(Map<String, ?>) - Static method in class io.fluxcapacitor.common.api.Metadata

offsetFromIndex(long) - Static method in class io.fluxcapacitor.common.IndexUtils

or(Constraint) - Method in interface io.fluxcapacitor.common.api.search.Constraint

P

ParameterResolver<M> - Interface in io.fluxcapacitor.common.handling

ParameterSupplier() - Constructor for class io.fluxcapacitor.common.handling.HandlerInspector.ParameterSupplier

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

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

Q

QUERY - io.fluxcapacitor.common.MessageType

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(InputStream) - Static method in class io.fluxcapacitor.common.serialization.JsonUtils

ready() - Static method in interface io.fluxcapacitor.common.Awaitable

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

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

Request - Class in io.fluxcapacitor.common.api

Request() - Constructor for class io.fluxcapacitor.common.api.Request

RequestBatch<T extends JsonType> - Class in io.fluxcapacitor.common.api

RequestBatch() - Constructor for class io.fluxcapacitor.common.api.RequestBatch

ResetPosition - Class in io.fluxcapacitor.common.api.tracking

ResetPosition() - Constructor for class io.fluxcapacitor.common.api.tracking.ResetPosition

resolve(Parameter) - Method in interface io.fluxcapacitor.common.handling.ParameterResolver

RESULT - 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 Type in io.fluxcapacitor.common.serialization

S

Schedule - Class in io.fluxcapacitor.common.api.scheduling

Schedule() - Constructor for class io.fluxcapacitor.common.api.scheduling.Schedule

SCHEDULE - io.fluxcapacitor.common.MessageType

Schedule.Metric - Class in io.fluxcapacitor.common.api.scheduling

ScheduledMessage - Class in io.fluxcapacitor.common.api.scheduling

ScheduledMessage() - Constructor for class io.fluxcapacitor.common.api.scheduling.ScheduledMessage

ScheduledMessage.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

SearchHistogram - Class in io.fluxcapacitor.common.api.search

SearchHistogram() - Constructor for class io.fluxcapacitor.common.api.search.SearchHistogram

searchPath() - Static method in class io.fluxcapacitor.common.ServicePathBuilder

SearchQuery - Class in io.fluxcapacitor.common.api.search

SearchQuery() - Constructor for class io.fluxcapacitor.common.api.search.SearchQuery

SearchUtils - Class in io.fluxcapacitor.common

SearchUtils() - Constructor for class io.fluxcapacitor.common.SearchUtils

SENT - io.fluxcapacitor.common.Guarantee

serialize() - Method in enum io.fluxcapacitor.common.search.Document.EntryType

serialize(Document) - Method in enum io.fluxcapacitor.common.search.DefaultDocumentSerializer

SerializedDocument - Class in io.fluxcapacitor.common.api.search

SerializedDocument(Document) - Constructor for class io.fluxcapacitor.common.api.search.SerializedDocument

SerializedDocumentUpdate - Class in io.fluxcapacitor.common.api.search

SerializedDocumentUpdate() - Constructor for class io.fluxcapacitor.common.api.search.SerializedDocumentUpdate

SerializedMessage - Class in io.fluxcapacitor.common.api

SerializedMessage(Data<byte[]>, Metadata, String, Long) - Constructor for class io.fluxcapacitor.common.api.SerializedMessage

SerializedObject<T,S extends SerializedObject<T,S>> - Interface in io.fluxcapacitor.common.api

ServicePathBuilder - Class in io.fluxcapacitor.common

ServicePathBuilder() - Constructor for class io.fluxcapacitor.common.ServicePathBuilder

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

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.Backlog

size() - Method in class io.fluxcapacitor.common.api.search.SearchDocumentsResult

specificity(Class<?>) - Static method in class io.fluxcapacitor.common.handling.HandlerInspector.MethodHandlerInvoker

STORED - io.fluxcapacitor.common.Guarantee

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

T

TEXT - io.fluxcapacitor.common.search.Document.EntryType

time(Runnable, Consumer<Long>) - Static method in class io.fluxcapacitor.common.TimingUtils

time(Callable<T>, Consumer<Long>) - Static method in class io.fluxcapacitor.common.TimingUtils

timestampFromIndex(long) - Static method in class io.fluxcapacitor.common.IndexUtils

TimingUtils - Class in io.fluxcapacitor.common

TimingUtils() - Constructor for class io.fluxcapacitor.common.TimingUtils

toDocument(Data<byte[]>, String, String) - Method in interface io.fluxcapacitor.common.search.Inverter

toDocument(Data<byte[]>, String, String, Instant) - Method in interface io.fluxcapacitor.common.search.Inverter

toDocument(Data<byte[]>, String, String, Instant, Instant) - Method in interface io.fluxcapacitor.common.search.Inverter

toDocument(Data<byte[]>, String, String, Instant, Instant) - 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.ScheduledMessage

toMetric() - Method in class io.fluxcapacitor.common.api.search.BulkUpdateDocuments

toMetric() - Method in class io.fluxcapacitor.common.api.search.GetDocumentStatsResult

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.MessageBatch

toMetric() - Method in class io.fluxcapacitor.common.api.tracking.ReadFromIndexResult

toMetric() - Method in class io.fluxcapacitor.common.api.tracking.ReadResult

toMetric() - Method in class io.fluxcapacitor.common.api.VoidResult

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.HandlerInspector.DefaultHandler

TrackingStrategy - Enum in io.fluxcapacitor.common.api.tracking

V

value() - Method in annotation type io.fluxcapacitor.common.serialization.Revision

valueOf(String) - Static method in enum io.fluxcapacitor.common.api.search.BulkUpdate.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.fluxcapacitor.common.api.tracking.TrackingStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.fluxcapacitor.common.Guarantee

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.fluxcapacitor.common.MessageType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.fluxcapacitor.common.search.DefaultDocumentSerializer

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.fluxcapacitor.common.search.Document.EntryType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.fluxcapacitor.common.serialization.compression.CompressionAlgorithm

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.fluxcapacitor.common.api.search.BulkUpdate.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.fluxcapacitor.common.api.tracking.TrackingStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.fluxcapacitor.common.Guarantee

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.fluxcapacitor.common.MessageType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.fluxcapacitor.common.search.DefaultDocumentSerializer

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.fluxcapacitor.common.search.Document.EntryType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.fluxcapacitor.common.serialization.compression.CompressionAlgorithm

Returns an array containing the constants of this enum type, 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

with(Object...) - Method in class io.fluxcapacitor.common.api.Metadata

with(Metadata) - Method in class io.fluxcapacitor.common.api.Metadata

with(String, Object) - Method in class io.fluxcapacitor.common.api.Metadata

with(Map<String, ?>) - Method in class io.fluxcapacitor.common.api.Metadata

withData(Data<T>) - Method in class io.fluxcapacitor.common.api.Data

withData(Data<T>) - Method in interface io.fluxcapacitor.common.api.SerializedObject

without(String) - Method in class io.fluxcapacitor.common.api.Metadata

withoutIf(Predicate<String>) - Method in class io.fluxcapacitor.common.api.Metadata

withTrace(String, Object) - Method in class io.fluxcapacitor.common.api.Metadata

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 V W
All Classes|All Packages