Uses of Enum Class
io.fluxcapacitor.common.Guarantee

Packages that use Guarantee

Package	Description
io.fluxcapacitor.common
io.fluxcapacitor.common.api
io.fluxcapacitor.common.api.keyvalue
io.fluxcapacitor.common.api.publishing
io.fluxcapacitor.javaclient
io.fluxcapacitor.javaclient.persisting.eventsourcing.client
io.fluxcapacitor.javaclient.persisting.keyvalue
io.fluxcapacitor.javaclient.persisting.keyvalue.client
io.fluxcapacitor.javaclient.persisting.search
io.fluxcapacitor.javaclient.persisting.search.client
io.fluxcapacitor.javaclient.publishing
io.fluxcapacitor.javaclient.publishing.client
io.fluxcapacitor.javaclient.scheduling
io.fluxcapacitor.javaclient.scheduling.client
io.fluxcapacitor.javaclient.tracking.client
io.fluxcapacitor.javaclient.web
io.fluxcapacitor.testserver.scheduling

Uses of Guarantee in io.fluxcapacitor.common

Methods in io.fluxcapacitor.common that return Guarantee

Modifier and Type	Method	Description
static Guarantee	Guarantee.valueOf(String name)	Returns the enum constant of this class with the specified name.
static Guarantee[]	Guarantee.values()	Returns an array containing the constants of this enum class, in the order they are declared.

Uses of Guarantee in io.fluxcapacitor.common.api

Methods in io.fluxcapacitor.common.api that return Guarantee

Modifier and Type	Method	Description
abstract Guarantee	Command.getGuarantee()	Indicates the delivery guarantee required for this command.

Uses of Guarantee in io.fluxcapacitor.common.api.keyvalue

Methods in io.fluxcapacitor.common.api.keyvalue that return Guarantee

Modifier and Type	Method	Description
Guarantee	StoreValueIfAbsent.getGuarantee()
Guarantee	StoreValuesAndWait.getGuarantee()	Deprecated.

Uses of Guarantee in io.fluxcapacitor.common.api.publishing

Methods in io.fluxcapacitor.common.api.publishing that return Guarantee

Modifier and Type	Method	Description
Guarantee	Append.getGuarantee()

Uses of Guarantee in io.fluxcapacitor.javaclient

Methods in io.fluxcapacitor.javaclient with parameters of type Guarantee

Modifier and Type	Method	Description
static void	FluxCapacitor.sendAndForgetCommand(Object payload, Metadata metadata, Guarantee guarantee)	Sends a command with given payload and metadata and don't wait for a result.

Uses of Guarantee in io.fluxcapacitor.javaclient.persisting.eventsourcing.client

Methods in io.fluxcapacitor.javaclient.persisting.eventsourcing.client with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	EventStoreClient.deleteEvents(String aggregateId, Guarantee guarantee)	Deletes all events for a specific aggregate with a given delivery guarantee.
CompletableFuture<Void>	InMemoryEventStore.deleteEvents(String aggregateId, Guarantee guarantee)
CompletableFuture<Void>	WebSocketEventStoreClient.deleteEvents(String aggregateId, Guarantee guarantee)	Sends a delete command for the event stream of the specified aggregate.
CompletableFuture<Void>	EventStoreClient.storeEvents(String aggregateId, List<SerializedMessage> events, boolean storeOnly, Guarantee guarantee)	Stores events for a given aggregate with an explicit guarantee.
CompletableFuture<Void>	InMemoryEventStore.storeEvents(String aggregateId, List<SerializedMessage> events, boolean storeOnly, Guarantee guarantee)
CompletableFuture<Void>	WebSocketEventStoreClient.storeEvents(String aggregateId, List<SerializedMessage> events, boolean storeOnly, Guarantee guarantee)	Stores events for a specific aggregate, with control over store-only mode and delivery guarantee.

Uses of Guarantee in io.fluxcapacitor.javaclient.persisting.keyvalue

Methods in io.fluxcapacitor.javaclient.persisting.keyvalue with parameters of type Guarantee

Modifier and Type	Method	Description
void	DefaultKeyValueStore.store(String key, Object value, Guarantee guarantee)
void	KeyValueStore.store(String key, Object value, Guarantee guarantee)	Stores a value under the given key with the specified delivery guarantee.

Uses of Guarantee in io.fluxcapacitor.javaclient.persisting.keyvalue.client

Methods in io.fluxcapacitor.javaclient.persisting.keyvalue.client with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemoryKeyValueStore.deleteValue(String key, Guarantee guarantee)
CompletableFuture<Void>	KeyValueClient.deleteValue(String key, Guarantee guarantee)	Deletes the value associated with the given key.
CompletableFuture<Void>	WebsocketKeyValueClient.deleteValue(String key, Guarantee guarantee)
CompletableFuture<Void>	InMemoryKeyValueStore.putValue(String key, Data<byte[]> value, Guarantee guarantee)
CompletableFuture<Void>	KeyValueClient.putValue(String key, Data<byte[]> value, Guarantee guarantee)	Adds or replaces the given value in the key value store.
CompletableFuture<Void>	WebsocketKeyValueClient.putValue(String key, Data<byte[]> value, Guarantee guarantee)

Uses of Guarantee in io.fluxcapacitor.javaclient.persisting.search

Methods in io.fluxcapacitor.javaclient.persisting.search with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	DefaultDocumentStore.bulkUpdate(Collection<? extends BulkUpdate> updates, Guarantee guarantee)
CompletableFuture<Void>	DocumentStore.bulkUpdate(Collection<? extends BulkUpdate> updates, Guarantee guarantee)	Applies a batch of document updates, using given Guarantee.
CompletableFuture<Void>	DefaultDocumentStore.index(@NonNull Object object, Object id, Object collection, Instant begin, Instant end, Metadata metadata, Guarantee guarantee, boolean ifNotExists)
CompletableFuture<Void>	DefaultDocumentStore.index(Collection<?> objects, Object collection, String idPath, String beginPath, String endPath, Guarantee guarantee, boolean ifNotExists)
<T> CompletableFuture<Void>	DefaultDocumentStore.index(Collection<? extends T> objects, Object collection, Function<? super T,?> idFunction, Function<? super T,Instant> beginFunction, Function<? super T,Instant> endFunction, Guarantee guarantee, boolean ifNotExists)
CompletableFuture<Void>	DefaultIndexOperation.index(Guarantee guarantee)
CompletableFuture<Void>	DocumentStore.index(@NotNull Object object, Object id, Object collection, Instant begin, Instant end, Metadata metadata, Guarantee guarantee, boolean ifNotExists)	Indexes a document with the specified guarantees, metadata, and if-not-exists condition.
default CompletableFuture<Void>	DocumentStore.index(@NotNull Object object, Object id, Object collection, Instant begin, Instant end, Guarantee guarantee, boolean ifNotExists)	Indexes a document with the specified guarantees, metadata, and if-not-exists condition.
CompletableFuture<Void>	DocumentStore.index(Collection<?> objects, Object collection, String idPath, String beginPath, String endPath, Guarantee guarantee, boolean ifNotExists)	Indexes a collection of objects using functional accessors for ID and time intervals.
<T> CompletableFuture<Void>	DocumentStore.index(Collection<? extends T> objects, Object collection, Function<? super T,?> idFunction, Function<? super T,Instant> beginFunction, Function<? super T,Instant> endFunction, Guarantee guarantee, boolean ifNotExists)	Indexes a collection of objects using functional accessors for ID and time intervals.
CompletableFuture<Void>	IndexOperation.index(Guarantee guarantee)	Executes the indexing operation with the provided guarantee.
default void	IndexOperation.indexAndWait(Guarantee guarantee)	Executes the indexing operation with the specified guarantee and blocks until it is completed.

Uses of Guarantee in io.fluxcapacitor.javaclient.persisting.search.client

Methods in io.fluxcapacitor.javaclient.persisting.search.client with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemorySearchStore.bulkUpdate(Collection<DocumentUpdate> updates, Guarantee guarantee)
CompletableFuture<Void>	SearchClient.bulkUpdate(Collection<DocumentUpdate> updates, Guarantee guarantee)	Performs a batch update on a set of documents.
CompletableFuture<Void>	WebSocketSearchClient.bulkUpdate(Collection<DocumentUpdate> batch, Guarantee guarantee)
CompletableFuture<Void>	InMemorySearchStore.delete(SearchQuery query, Guarantee guarantee)
CompletableFuture<Void>	InMemorySearchStore.delete(String documentId, String collection, Guarantee guarantee)
CompletableFuture<Void>	SearchClient.delete(SearchQuery query, Guarantee guarantee)	Deletes documents matching a given query.
CompletableFuture<Void>	SearchClient.delete(String documentId, String collection, Guarantee guarantee)	Deletes a document by its unique id and collection name.
CompletableFuture<Void>	WebSocketSearchClient.delete(SearchQuery query, Guarantee guarantee)
CompletableFuture<Void>	WebSocketSearchClient.delete(String documentId, String collection, Guarantee guarantee)
CompletableFuture<Void>	InMemorySearchStore.deleteCollection(String collection, Guarantee guarantee)
CompletableFuture<Void>	SearchClient.deleteCollection(String collection, Guarantee guarantee)	Deletes an entire document collection and all its contents.
CompletableFuture<Void>	WebSocketSearchClient.deleteCollection(String collection, Guarantee guarantee)
CompletableFuture<Void>	InMemorySearchStore.index(List<SerializedDocument> documents, Guarantee guarantee, boolean ifNotExists)
CompletableFuture<Void>	SearchClient.index(List<SerializedDocument> documents, Guarantee guarantee, boolean ifNotExists)	Indexes a list of serialized documents into the search engine.
CompletableFuture<Void>	WebSocketSearchClient.index(List<SerializedDocument> documents, Guarantee guarantee, boolean ifNotExists)

Uses of Guarantee in io.fluxcapacitor.javaclient.publishing

Methods in io.fluxcapacitor.javaclient.publishing with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	DefaultEventGateway.publish(Guarantee guarantee, Object... messages)
CompletableFuture<Void>	DefaultEventGateway.publish(Message message, Guarantee guarantee)
CompletableFuture<Void>	DefaultMetricsGateway.publish(Object payload, Metadata metadata, Guarantee guarantee)
CompletableFuture<Void>	EventGateway.publish(Guarantee guarantee, Object... messages)	Publishes one or more event messages with a specific delivery guarantee.
CompletableFuture<Void>	EventGateway.publish(Message message, Guarantee guarantee)	Publishes the given Message to Flux Capacitor and/or local handlers.
CompletableFuture<Void>	MetricsGateway.publish(Object payload, Metadata metadata, Guarantee guarantee)	Publishes a metrics message with the specified metadata and delivery guarantee.
CompletableFuture<Void>	DefaultErrorGateway.report(Object payload, Metadata metadata, Guarantee guarantee)
CompletableFuture<Void>	ErrorGateway.report(Object payload, Metadata metadata, Guarantee guarantee)	Reports an error with the given payload, metadata, and delivery guarantee.
CompletableFuture<Void>	DefaultResultGateway.respond(Object payload, Metadata metadata, String target, Integer requestId, Guarantee guarantee)
CompletableFuture<Void>	ResultGateway.respond(Object payload, Metadata metadata, String target, Integer requestId, Guarantee guarantee)	Sends a response with the specified payload, metadata, target, request ID, and delivery guarantee.
CompletableFuture<Void>	CommandGateway.sendAndForget(Guarantee guarantee, Object... messages)	Sends multiple commands with a delivery guarantee without waiting for results.
void	CommandGateway.sendAndForget(Object payload, Metadata metadata, Guarantee guarantee)	Sends a command with metadata and delivery guarantee, without waiting for a result.
CompletableFuture<Void>	DefaultGenericGateway.sendAndForget(Guarantee guarantee, Message... messages)
CompletableFuture<Void>	DefaultWebRequestGateway.sendAndForget(Guarantee guarantee, WebRequest... requests)
CompletableFuture<Void>	GenericGateway.sendAndForget(Guarantee guarantee, Message... messages)	Sends multiple Message objects with a guarantee.
default CompletableFuture<Void>	GenericGateway.sendAndForget(Guarantee guarantee, Object... messages)	Sends multiple messages asynchronously with a specified delivery guarantee.
default CompletableFuture<Void>	GenericGateway.sendAndForget(Message message, Guarantee guarantee)	Sends a Message asynchronously with a given guarantee.
default void	GenericGateway.sendAndForget(Object payload, Metadata metadata, Guarantee guarantee)	Sends a message with payload, metadata, and delivery guarantee asynchronously.
CompletableFuture<Void>	WebRequestGateway.sendAndForget(Guarantee guarantee, WebRequest... requests)	Sends one or more web requests without waiting for a response.
CompletableFuture<Void>	DefaultGenericGateway.setRetentionTime(Duration duration, Guarantee guarantee)
CompletableFuture<Void>	GenericGateway.setRetentionTime(Duration duration, Guarantee guarantee)	Set a new retention duration for the underlying gateway's message log.

Uses of Guarantee in io.fluxcapacitor.javaclient.publishing.client

Methods in io.fluxcapacitor.javaclient.publishing.client with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	GatewayClient.append(Guarantee guarantee, SerializedMessage... messages)	Append the given messages to the gateway, applying the given delivery Guarantee.
CompletableFuture<Void>	WebsocketGatewayClient.append(Guarantee guarantee, SerializedMessage... messages)
CompletableFuture<Void>	GatewayClient.setRetentionTime(Duration duration, Guarantee guarantee)	Set a new retention duration for the underlying gateway's message log.
CompletableFuture<Void>	WebsocketGatewayClient.setRetentionTime(Duration duration, Guarantee guarantee)

Uses of Guarantee in io.fluxcapacitor.javaclient.scheduling

Methods in io.fluxcapacitor.javaclient.scheduling with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	DefaultMessageScheduler.schedule(Schedule message, boolean ifAbsent, Guarantee guarantee)
CompletableFuture<Void>	MessageScheduler.schedule(Schedule message, boolean ifAbsent, Guarantee guarantee)	Schedule the given Schedule object, optionally skipping if already present, using the specified guarantee.
CompletableFuture<Void>	DefaultMessageScheduler.scheduleCommand(Schedule schedule, boolean ifAbsent, Guarantee guarantee)
CompletableFuture<Void>	MessageScheduler.scheduleCommand(Schedule message, boolean ifAbsent, Guarantee guarantee)	Schedule a command using the given scheduling settings, using the provided Guarantee.

Uses of Guarantee in io.fluxcapacitor.javaclient.scheduling.client

Methods in io.fluxcapacitor.javaclient.scheduling.client with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemoryScheduleStore.cancelSchedule(String scheduleId, Guarantee guarantee)
CompletableFuture<Void>	SchedulingClient.cancelSchedule(String scheduleId, Guarantee guarantee)	Cancel a scheduled message using the provided delivery guarantee.
CompletableFuture<Void>	WebsocketSchedulingClient.cancelSchedule(String scheduleId, Guarantee guarantee)
CompletableFuture<Void>	InMemoryScheduleStore.schedule(Guarantee guarantee, SerializedSchedule... schedules)
CompletableFuture<Void>	SchedulingClient.schedule(Guarantee guarantee, SerializedSchedule... schedules)	Schedule one or more serialized schedules with a specified Guarantee.
CompletableFuture<Void>	WebsocketSchedulingClient.schedule(Guarantee guarantee, SerializedSchedule... schedules)

Uses of Guarantee in io.fluxcapacitor.javaclient.tracking.client

Methods in io.fluxcapacitor.javaclient.tracking.client with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	LocalTrackingClient.append(Guarantee guarantee, SerializedMessage... messages)
CompletableFuture<Void>	CachingTrackingClient.disconnectTracker(String consumer, String trackerId, boolean sendFinalEmptyBatch, Guarantee guarantee)
CompletableFuture<Void>	LocalTrackingClient.disconnectTracker(String consumer, String trackerId, boolean sendFinalEmptyBatch, Guarantee guarantee)
CompletableFuture<Void>	TrackingClient.disconnectTracker(String consumer, String trackerId, boolean sendFinalEmptyBatch, Guarantee guarantee)	Disconnects the specified tracker from its segment with the specified delivery guarantee.
CompletableFuture<Void>	WebsocketTrackingClient.disconnectTracker(String consumer, String trackerId, boolean sendFinalEmptyBatch, Guarantee guarantee)
CompletableFuture<Void>	CachingTrackingClient.resetPosition(String consumer, long lastIndex, Guarantee guarantee)
CompletableFuture<Void>	LocalTrackingClient.resetPosition(String consumer, long lastIndex, Guarantee guarantee)
CompletableFuture<Void>	TrackingClient.resetPosition(String consumer, long lastIndex, Guarantee guarantee)	Resets the consumer's tracking position to a given index with a specific delivery guarantee.
CompletableFuture<Void>	WebsocketTrackingClient.resetPosition(String consumer, long lastIndex, Guarantee guarantee)
CompletableFuture<Void>	LocalTrackingClient.setRetentionTime(Duration duration, Guarantee guarantee)
CompletableFuture<Void>	CachingTrackingClient.storePosition(String consumer, int[] segment, long lastIndex, Guarantee guarantee)
CompletableFuture<Void>	LocalTrackingClient.storePosition(String consumer, int[] segment, long lastIndex, Guarantee guarantee)
CompletableFuture<Void>	TrackingClient.storePosition(String consumer, int[] segment, long lastIndex, Guarantee guarantee)	Stores the last successfully processed position for a consumer with a specific delivery guarantee.
CompletableFuture<Void>	WebsocketTrackingClient.storePosition(String consumer, int[] segment, long lastIndex, Guarantee guarantee)

Uses of Guarantee in io.fluxcapacitor.javaclient.web

Methods in io.fluxcapacitor.javaclient.web with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	DefaultSocketSession.close(int code, Guarantee guarantee)
CompletableFuture<Void>	SocketSession.close(int closeReason, Guarantee guarantee)	Closes the WebSocket session with the specified close reason and delivery guarantee.
default CompletableFuture<Void>	SocketSession.close(Guarantee guarantee)	Closes the WebSocket session with the specified guarantee for handling pending operations.
CompletableFuture<Void>	WebResponseGateway.respond(Object payload, Metadata metadata, String target, Integer requestId, Guarantee guarantee)
CompletableFuture<Void>	DefaultSocketSession.sendMessage(Object value, Guarantee guarantee)
CompletableFuture<Void>	SocketSession.sendMessage(Object value, Guarantee guarantee)	Sends a message over the WebSocket session with the specified delivery guarantee.
CompletableFuture<Void>	DefaultSocketSession.sendPing(Object value, Guarantee guarantee)
CompletableFuture<Void>	SocketSession.sendPing(Object value, Guarantee guarantee)	Sends a ping message with the specified value to the WebSocket session.

Uses of Guarantee in io.fluxcapacitor.testserver.scheduling

Methods in io.fluxcapacitor.testserver.scheduling with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	TestServerScheduleStore.schedule(Guarantee guarantee, SerializedSchedule... schedules)