Uses of Enum Class
io.fluxzero.common.Guarantee

Packages that use Guarantee

Package	Description
io.fluxzero.common
io.fluxzero.common.api
io.fluxzero.common.api.keyvalue
io.fluxzero.common.api.modeling
io.fluxzero.common.api.publishing
io.fluxzero.common.api.search
io.fluxzero.common.api.tracking
io.fluxzero.sdk
io.fluxzero.sdk.common.websocket
io.fluxzero.sdk.configuration
io.fluxzero.sdk.persisting.eventsourcing.client
io.fluxzero.sdk.persisting.keyvalue
io.fluxzero.sdk.persisting.keyvalue.client
io.fluxzero.sdk.persisting.search
io.fluxzero.sdk.persisting.search.client
io.fluxzero.sdk.publishing
io.fluxzero.sdk.publishing.client
io.fluxzero.sdk.scheduling
io.fluxzero.sdk.scheduling.client
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.web
io.fluxzero.testserver.scheduling

Uses of Guarantee in io.fluxzero.common

Subclasses with type arguments of type Guarantee in io.fluxzero.common

Modifier and Type	Class	Description
enum	Guarantee	Represents a delivery or completion guarantee for messages or state changes in Fluxzero.

Methods in io.fluxzero.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.fluxzero.common.api

Methods in io.fluxzero.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.fluxzero.common.api.keyvalue

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

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

Uses of Guarantee in io.fluxzero.common.api.modeling

Constructors in io.fluxzero.common.api.modeling with parameters of type Guarantee

Modifier	Constructor	Description
	CommitModels(String commitId, long readStateIndex, List<String> readModelIds, List<ModelCommitStep> substeps, ModelConflictPolicy conflictPolicy, Guarantee guarantee, boolean possibleDuplicate)
	CommitModels(String commitId, long readStateIndex, List<String> readModelIds, List<ModelCommitStep> substeps, ModelConflictPolicy conflictPolicy, Guarantee guarantee, boolean possibleDuplicate, boolean migration)
	CommitModelsWithAliasReads(long requestId, String commitId, long readStateIndex, List<String> readModelIds, List<ModelCommitStep> substeps, ModelConflictPolicy conflictPolicy, Guarantee guarantee, boolean possibleDuplicate, boolean migration, List<ModelRelationshipRead> readRelationships, List<String> readAliasIds)
	CommitModelsWithDeadlines(long requestId, String commitId, long readStateIndex, List<String> readModelIds, List<ModelCommitStep> substeps, ModelConflictPolicy conflictPolicy, Guarantee guarantee, boolean possibleDuplicate, boolean migration, List<ModelRelationshipRead> readRelationships, List<String> readAliasIds, List<ModelDeadlineUpdate> deadlineUpdates)
	CommitModelsWithDocumentProjections(long requestId, String commitId, long readStateIndex, List<String> readModelIds, List<ModelCommitStep> substeps, ModelConflictPolicy conflictPolicy, Guarantee guarantee, boolean possibleDuplicate, boolean migration, List<ModelRelationshipRead> readRelationships)
	CommitModelsWithIdentityReads(long requestId, String commitId, long readStateIndex, List<String> readModelIds, List<ModelCommitStep> substeps, ModelConflictPolicy conflictPolicy, Guarantee guarantee, boolean possibleDuplicate, boolean migration, List<ModelRelationshipRead> readRelationships, List<String> readAliasIds, List<ModelDeadlineUpdate> deadlineUpdates, List<ModelAliasObservation> aliasObservations)
	CommitModelsWithRelationships(long requestId, String commitId, long readStateIndex, List<String> readModelIds, List<ModelCommitStep> substeps, ModelConflictPolicy conflictPolicy, Guarantee guarantee, boolean possibleDuplicate, boolean migration, List<ModelRelationshipRead> readRelationships)

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

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

Modifier and Type	Method	Description
Guarantee	Append.getGuarantee()	Returns the requested delivery guarantee, defaulting to Guarantee.NONE when absent.
Guarantee	Truncate.getGuarantee()

Constructors in io.fluxzero.common.api.publishing with parameters of type Guarantee

Modifier	Constructor	Description
	Append(long requestId, MessageType messageType, List<SerializedMessage> messages, Guarantee guarantee)	Restores an append request received through an optimized transport representation.
	Append(MessageType messageType, List<SerializedMessage> messages, Guarantee guarantee)

Uses of Guarantee in io.fluxzero.common.api.search

Methods in io.fluxzero.common.api.search that return Guarantee

Modifier and Type	Method	Description
Guarantee	CollectionSearchCommand.getGuarantee()

Constructors in io.fluxzero.common.api.search with parameters of type Guarantee

Modifier	Constructor	Description
	AdoptModelMigration(String modelId, String collection, Long expectedDocumentIndex, long expectedStateIndex, Guarantee guarantee)
	AdoptModelMigrationWithSource(String modelId, String collection, Long expectedDocumentIndex, long expectedStateIndex, Guarantee guarantee, String sourceCollection)
	DeleteDocuments(SearchQuery query, Guarantee guarantee)	Creates a deletion command that uses the runtime's default batch size.

Uses of Guarantee in io.fluxzero.common.api.tracking

Methods in io.fluxzero.common.api.tracking with parameters of type Guarantee

Modifier and Type	Method	Description
static StorePosition	StorePosition.fromJson(MessageType messageType, String consumer, int[] segment, long lastIndex, Guarantee guarantee)	Creates and validates a position update for an unscoped stream.
static StorePosition	StorePosition.fromJson(MessageType messageType, String consumer, int[] segment, long lastIndex, Guarantee guarantee, String topic)	Creates a position request from JSON properties, validating that the segment has two ordered boundaries within the supported segment range.

Constructors in io.fluxzero.common.api.tracking with parameters of type Guarantee

Modifier	Constructor	Description
	StorePosition(MessageType messageType, String consumer, int[] segment, long lastIndex, Guarantee guarantee)	Creates a position update for an unscoped stream.

Uses of Guarantee in io.fluxzero.sdk

Methods in io.fluxzero.sdk with parameters of type Guarantee

Modifier and Type	Method	Description
static <R> CompletableFuture<R>	Fluxzero.query(Request<R> payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.
static <R> CompletableFuture<R>	Fluxzero.query(Object payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.
static <R> R	Fluxzero.queryAndWait(Request<R> payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.
static <R> R	Fluxzero.queryAndWait(Object payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.
static void	Fluxzero.sendAndForgetCommand(Object payload, Metadata metadata, Guarantee guarantee)	Sends a command with given payload and metadata and don't wait for a result.
static <R> CompletableFuture<R>	Fluxzero.sendCommand(Request<R> payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.
static <R> CompletableFuture<R>	Fluxzero.sendCommand(Object payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.
static <R> R	Fluxzero.sendCommandAndWait(Request<R> payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.
static <R> R	Fluxzero.sendCommandAndWait(Object payload, Metadata metadata, Guarantee guarantee)	Uses the given publication guarantee for this request; completion still represents its business response.

Uses of Guarantee in io.fluxzero.sdk.common.websocket

Methods in io.fluxzero.sdk.common.websocket that return Guarantee

Modifier and Type	Method	Description
protected Guarantee	AbstractWebsocketClient.resolveGuarantee(Guarantee guarantee)	Resolves standalone client defaults once configured at client construction.

Methods in io.fluxzero.sdk.common.websocket with parameters of type Guarantee

Modifier and Type	Method	Description
protected Guarantee	AbstractWebsocketClient.resolveGuarantee(Guarantee guarantee)	Resolves standalone client defaults once configured at client construction.

Uses of Guarantee in io.fluxzero.sdk.configuration

Methods in io.fluxzero.sdk.configuration that return Guarantee

Modifier and Type	Method	Description
static Guarantee	ApplicationProperties.getDefaultDeliveryGuarantee(PropertySource propertySource)	Resolves the application delivery default using the owning component's property source.
static Guarantee	ApplicationProperties.getRequestDeliveryGuarantee(PropertySource propertySource)	Resolves request/reply delivery from the shared ApplicationProperties.DEFAULT_DELIVERY_GUARANTEE_PROPERTY.

Uses of Guarantee in io.fluxzero.sdk.persisting.eventsourcing.client

Methods in io.fluxzero.sdk.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.fluxzero.sdk.persisting.keyvalue

Methods in io.fluxzero.sdk.persisting.keyvalue with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	DefaultKeyValueStore.delete(String key, Guarantee guarantee)
CompletableFuture<Void>	KeyValueStore.delete(String key, Guarantee guarantee)	Removes a value asynchronously with the specified delivery guarantee.
CompletableFuture<Void>	DefaultKeyValueStore.store(String key, Object value, Guarantee guarantee)
CompletableFuture<Void>	KeyValueStore.store(String key, Object value, Guarantee guarantee)	Stores a value under the given key with the specified delivery guarantee.
DefaultKeyValueStore	DefaultKeyValueStore.withDefaultGuarantee(Guarantee guarantee)	Configures the concrete application delivery default before first use; namespace stores inherit it.

Uses of Guarantee in io.fluxzero.sdk.persisting.keyvalue.client

Methods in io.fluxzero.sdk.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.fluxzero.sdk.persisting.search

Methods in io.fluxzero.sdk.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.DefaultSearch.delete(int batchSize, Guarantee guarantee)
default CompletableFuture<Void>	Search.delete(int batchSize, Guarantee guarantee)	Deletes matching documents with an explicit delivery guarantee.
CompletableFuture<Void>	DefaultDocumentStore.deleteDocument(Object id, Object collection, Guarantee guarantee)
CompletableFuture<Void>	DocumentStore.deleteDocument(Object id, Object collection, Guarantee guarantee)	Deletes a document from the collection, using given Guarantee.
CompletableFuture<Void>	BulkUpdateBuilder.execute(Guarantee guarantee)	Applies the configured update operations using the given guarantee.
default void	BulkUpdateBuilder.executeAndWait(Guarantee guarantee)	Applies the configured update operations using the given guarantee and waits for completion.
CompletableFuture<Void>	DefaultDocumentStore.index(@NonNull Object object, @NonNull Object id, @NonNull 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 guarantee, 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 guarantee, 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 the supplied ID/time accessors and delivery guarantee.
<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 the supplied ID/time accessors and delivery guarantee.
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.
CompletableFuture<Void>	DefaultDocumentStore.moveDocument(Object id, Object collection, Object targetCollection, Guarantee guarantee)
CompletableFuture<Void>	DocumentStore.moveDocument(Object id, Object collection, Object targetCollection, Guarantee guarantee)	Moves a document to the target collection, using the given Guarantee.
DefaultDocumentStore	DefaultDocumentStore.withDefaultGuarantee(Guarantee guarantee)	Configures the concrete application delivery default before first use; namespace copies inherit it.

Uses of Guarantee in io.fluxzero.sdk.persisting.search.client

Methods in io.fluxzero.sdk.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, int batchSize)
CompletableFuture<Void>	InMemorySearchStore.delete(String documentId, String collection, Guarantee guarantee)
default CompletableFuture<Void>	SearchClient.delete(SearchQuery query, Guarantee guarantee)	Deletes documents matching a given query.
CompletableFuture<Void>	SearchClient.delete(SearchQuery query, Guarantee guarantee, int batchSize)	Deletes documents matching a given query using the requested batch size.
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, int batchSize)
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)
CompletableFuture<Void>	InMemorySearchStore.move(SearchQuery query, String targetCollection, Guarantee guarantee)
CompletableFuture<Void>	InMemorySearchStore.move(String documentId, String collection, String targetCollection, Guarantee guarantee)
CompletableFuture<Void>	SearchClient.move(SearchQuery query, String targetCollection, Guarantee guarantee)	Moves documents matching a given query to the given target collection.
CompletableFuture<Void>	SearchClient.move(String documentId, String collection, String targetCollection, Guarantee guarantee)	Moves a document to another collection.
CompletableFuture<Void>	WebSocketSearchClient.move(SearchQuery query, String targetCollection, Guarantee guarantee)
CompletableFuture<Void>	WebSocketSearchClient.move(String documentId, String collection, String targetCollection, Guarantee guarantee)
CompletableFuture<Void>	InMemorySearchStore.rewriteModelGraphDocument(SerializedDocument replacement, String expectedManifest, Guarantee guarantee)
default CompletableFuture<Void>	SearchClient.rewriteModelGraphDocument(SerializedDocument document, String expectedManifest, Guarantee guarantee)	Conditionally replaces one materialized model-graph document while its manifest still matches the handled version.
CompletableFuture<Void>	WebSocketSearchClient.rewriteModelGraphDocument(SerializedDocument document, String expectedManifest, Guarantee guarantee)

Uses of Guarantee in io.fluxzero.sdk.publishing

Methods in io.fluxzero.sdk.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 Fluxzero 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(Guarantee guarantee, Message... errors)
CompletableFuture<Void>	DefaultErrorGateway.report(Object payload, Metadata metadata, Guarantee guarantee)
CompletableFuture<Void>	ErrorGateway.report(Guarantee guarantee, Message... errors)	Reports one or more error messages with the given delivery 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.
default <R> CompletableFuture<R>	CommandGateway.send(Request<R> payload, Metadata metadata, Guarantee guarantee)	Sends a typed request with a per-call publication guarantee and returns its business response future.
default <R> CompletableFuture<R>	CommandGateway.send(Object payload, Metadata metadata, Guarantee guarantee)	Sends a request with the given publication guarantee.
<R> CompletableFuture<R>	DefaultCommandGateway.send(Request<R> payload, Metadata metadata, Guarantee guarantee)
<R> CompletableFuture<R>	DefaultCommandGateway.send(Object payload, Metadata metadata, Guarantee guarantee)
<R> CompletableFuture<R>	DefaultQueryGateway.send(Request<R> payload, Metadata metadata, Guarantee guarantee)
<R> CompletableFuture<R>	DefaultQueryGateway.send(Object payload, Metadata metadata, Guarantee guarantee)
default <R> CompletableFuture<R>	GenericGateway.send(Request<R> payload, Metadata metadata, Guarantee guarantee)	Sends a typed request with a per-call publication guarantee and returns its business response future.
default <R> CompletableFuture<R>	GenericGateway.send(Object payload, Metadata metadata, Guarantee guarantee)	Sends a request with the given publication guarantee.
default <R> CompletableFuture<R>	QueryGateway.send(Request<R> payload, Metadata metadata, Guarantee guarantee)	Sends a typed request with a per-call publication guarantee and returns its business response future.
default <R> CompletableFuture<R>	QueryGateway.send(Object payload, Metadata metadata, Guarantee guarantee)	Sends a request with the given publication 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>	DefaultGenericGateway.sendAndForget(Guarantee guarantee, UnaryOperator<SerializedMessage> interceptor, Message... messages)
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.
CompletableFuture<Void>	GenericGateway.sendAndForget(Guarantee guarantee, UnaryOperator<SerializedMessage> interceptor, Message... messages)	Sends multiple Message objects with a 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.
default <R> R	CommandGateway.sendAndWait(Request<R> payload, Metadata metadata, Guarantee guarantee)	Sends a typed request with a per-call publication guarantee and waits for its business response.
default <R> R	CommandGateway.sendAndWait(Object payload, Metadata metadata, Guarantee guarantee)	Sends a request with a per-call publication guarantee and waits for its business response.
<R> R	DefaultCommandGateway.sendAndWait(Request<R> payload, Metadata metadata, Guarantee guarantee)
<R> R	DefaultCommandGateway.sendAndWait(Object payload, Metadata metadata, Guarantee guarantee)
<R> R	DefaultGenericGateway.sendAndWait(Object payload, Metadata metadata, Guarantee guarantee)
<R> R	DefaultQueryGateway.sendAndWait(Request<R> payload, Metadata metadata, Guarantee guarantee)
<R> R	DefaultQueryGateway.sendAndWait(Object payload, Metadata metadata, Guarantee guarantee)
default <R> R	GenericGateway.sendAndWait(Request<R> payload, Metadata metadata, Guarantee guarantee)	Sends a typed request with a per-call publication guarantee and waits for its business response.
default <R> R	GenericGateway.sendAndWait(Object payload, Metadata metadata, Guarantee guarantee)	Sends a request with a per-call publication guarantee and waits for its business response.
default <R> R	QueryGateway.sendAndWait(Request<R> payload, Metadata metadata, Guarantee guarantee)	Sends a typed request with a per-call publication guarantee and waits for its business response.
default <R> R	QueryGateway.sendAndWait(Object payload, Metadata metadata, Guarantee guarantee)	Sends a request with a per-call publication guarantee and waits for its business response.
CompletableFuture<Message>	DefaultGenericGateway.sendForMessage(Message message, Duration timeout, Guarantee guarantee)
default CompletableFuture<Message>	GenericGateway.sendForMessage(Message message, Duration timeout, Guarantee guarantee)	Sends a full request with a per-call publication guarantee and effective timeout.
default List<CompletableFuture<Message>>	CommandGateway.sendForMessages(Guarantee guarantee, Message... messages)	Sends full request messages with one publication guarantee and returns business response futures in input order.
List<CompletableFuture<Message>>	DefaultCommandGateway.sendForMessages(Guarantee guarantee, Message... messages)
List<CompletableFuture<Message>>	DefaultGenericGateway.sendForMessages(Guarantee guarantee, Message... messages)
List<CompletableFuture<Message>>	DefaultQueryGateway.sendForMessages(Guarantee guarantee, Message... messages)
default List<CompletableFuture<Message>>	GenericGateway.sendForMessages(Guarantee guarantee, Message... messages)	Sends full request messages with one publication guarantee and returns business response futures in input order.
default List<CompletableFuture<Message>>	QueryGateway.sendForMessages(Guarantee guarantee, Message... messages)	Sends full request messages with one publication guarantee and returns business response futures in input order.
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.
CompletableFuture<Void>	DefaultGenericGateway.truncate(Guarantee guarantee)
CompletableFuture<Void>	GenericGateway.truncate(Guarantee guarantee)	Truncates this gateway's message log and clears associated tracking positions.
DefaultGenericGateway	DefaultGenericGateway.withDefaultGuarantee(Guarantee guarantee)	Configures the concrete application delivery default before first use.
DefaultResultGateway	DefaultResultGateway.withDefaultGuarantee(Guarantee guarantee)	Configures the concrete application delivery default before first use; namespace copies inherit it.
DefaultGenericGateway	DefaultGenericGateway.withRequestGuarantee(Guarantee guarantee)	Configures remote request/reply delivery before first use.

Uses of Guarantee in io.fluxzero.sdk.publishing.client

Methods in io.fluxzero.sdk.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)
CompletableFuture<Void>	GatewayClient.truncate(Guarantee guarantee)	Truncates the underlying gateway's message log and clears its tracking positions.
CompletableFuture<Void>	WebsocketGatewayClient.truncate(Guarantee guarantee)

Uses of Guarantee in io.fluxzero.sdk.scheduling

Methods in io.fluxzero.sdk.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.
DefaultMessageScheduler	DefaultMessageScheduler.withDefaultGuarantee(Guarantee guarantee)	Configures the concrete application delivery default before first use; namespace copies inherit it.

Uses of Guarantee in io.fluxzero.sdk.scheduling.client

Methods in io.fluxzero.sdk.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)
CompletableFuture<Void>	InMemoryScheduleStore.scheduleBoundToParents(Guarantee guarantee, Map<String,Long> parents, SerializedSchedule... schedules)
default CompletableFuture<Void>	SchedulingClient.scheduleBoundToParents(Guarantee guarantee, Map<String,Long> parents, SerializedSchedule... schedules)	Stores schedules with previously acquired bindings, without rebinding recreated parents.
CompletableFuture<Void>	WebsocketSchedulingClient.scheduleBoundToParents(Guarantee guarantee, Map<String,Long> parents, SerializedSchedule... schedules)
default CompletableFuture<Void>	SchedulingClient.scheduleWithParents(Guarantee guarantee, List<String> parentIds, SerializedSchedule... schedules)	Schedules messages owned by the current lifetime of each committed Model parent.

Uses of Guarantee in io.fluxzero.sdk.tracking.client

Methods in io.fluxzero.sdk.tracking.client with parameters of type Guarantee

Modifier and Type	Method	Description
CompletableFuture<Void>	LocalTrackingClient.append(Guarantee guarantee, SerializedMessage... messages)
CompletableFuture<Void>	CachingTrackingClient.disconnectTerminatedTracker(String consumer, String trackerId, Guarantee guarantee)
default CompletableFuture<Void>	TrackingClient.disconnectTerminatedTracker(String consumer, String trackerId, Guarantee guarantee)	Releases a terminated local tracker, including any abandoned asynchronous reads still completing.
CompletableFuture<Void>	WebsocketTrackingClient.disconnectTerminatedTracker(String consumer, String trackerId, Guarantee guarantee)
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)
CompletableFuture<Void>	LocalTrackingClient.truncate(Guarantee guarantee)

Uses of Guarantee in io.fluxzero.sdk.web

Methods in io.fluxzero.sdk.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 the outbound close message.
CompletableFuture<Void>	WebResponseGateway.respond(Object payload, Metadata metadata, String target, Integer requestId, Guarantee guarantee)
CompletableFuture<Void>	DefaultWebRequestGateway.sendAndForget(Guarantee guarantee, WebRequest... requests)
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.
WebResponseGateway	WebResponseGateway.withDefaultGuarantee(Guarantee guarantee)	Configures the concrete application delivery default before first use; namespace copies inherit it.

Uses of Guarantee in io.fluxzero.testserver.scheduling

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

Modifier and Type	Method	Description
CompletableFuture<Void>	TestServerScheduleStore.schedule(Guarantee guarantee, SerializedSchedule... schedules)
CompletableFuture<Void>	TestServerScheduleStore.scheduleBoundToParents(Guarantee guarantee, Map<String,Long> parents, SerializedSchedule... schedules)