Uses of Class
io.fluxzero.sdk.modeling.CommitAttempt

Packages that use CommitAttempt

Package	Description
io.fluxzero.sdk.modeling
io.fluxzero.sdk.persisting.repository

Uses of CommitAttempt in io.fluxzero.sdk.modeling

Methods in io.fluxzero.sdk.modeling that return CommitAttempt

Modifier and Type	Method	Description
static CommitAttempt	CommitAttempt.create(long readStateIndex, MutationPlan.Resolution resolution, Map<String, ? extends Entity<?>> loadedModels)	Creates a loaded begin-state for one resolved target set.
static CommitAttempt	CommitAttempt.createSingle(long readStateIndex, String modelId, Class<?> modelType, MutationPlan.Access access, List<String> sourceProperties, Entity<?> entity)	Creates the allocation-minimal begin-state used by a direct single-model strategy.
static CommitAttempt	CommitAttempt.currentReadContext(ModelRepository repository)	Returns this repository's active mutation read context, never an event-replay or escaped async context.
static CommitAttempt	CommitAttempt.currentReplayContext(ModelRepository repository)	Returns this repository's active replay input; never borrows another application's or namespace's context.
static CommitAttempt	ModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable)	Overlays pending exact values without changing the durable context's pinned state boundary.
static CommitAttempt	ModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable, Object repositoryOwner)	Overlays only pending values produced by this repository family at the durable boundary.
CommitAttempt	CommitAttempt.withAliasResolutions(Map<String,String> aliases)	Retains the lookup names that resolved injected read-only targets, including unresolved aliases.
CommitAttempt	CommitAttempt.withAncestorReads(ModelAncestorResolver.AncestorReads reads)	Retains identity-only proof used to resolve indirect injected Models at this context's pinned boundary.
CommitAttempt	CommitAttempt.withDeferredBoundary(LongSupplier verification)	Internal single-document loading provenance; copies share the same one-time verification.
CommitAttempt	CommitAttempt.withReplayReads(ModelRepository repository, ModelReadBoundary boundary)	Binds replay reads to their original input without joining live mutation/conflict tracking.

Methods in io.fluxzero.sdk.modeling with parameters of type CommitAttempt

Modifier and Type	Method	Description
static CommitAttempt	ModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable)	Overlays pending exact values without changing the durable context's pinned state boundary.
static CommitAttempt	ModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable, Object repositoryOwner)	Overlays only pending values produced by this repository family at the durable boundary.
static Object	ModelReducer.replay(MutationPlan plan, DeserializingMessage event, CommitAttempt context, String targetModelId)	Replays the event for one target Model through the compiled plan's reducer using the supplied attempt context, returning the reconstructed value.
static Object	ModelReducer.replay(MutationPlan plan, DeserializingMessage event, CommitAttempt context, String targetModelId, BiFunction<MutationPlan.Resolution, CommitAttempt, CommitAttempt> dependencies)	Replays with late-bound embedded dependencies at the stored event's historical boundary.

Method parameters in io.fluxzero.sdk.modeling with type arguments of type CommitAttempt

Modifier and Type	Method	Description
static Object	ModelReducer.replay(MutationPlan plan, DeserializingMessage event, CommitAttempt context, String targetModelId, BiFunction<MutationPlan.Resolution, CommitAttempt, CommitAttempt> dependencies)	Replays with late-bound embedded dependencies at the stored event's historical boundary.
static Object	ModelReducer.replay(MutationPlan plan, DeserializingMessage event, CommitAttempt context, String targetModelId, BiFunction<MutationPlan.Resolution, CommitAttempt, CommitAttempt> dependencies)	Replays with late-bound embedded dependencies at the stored event's historical boundary.

Uses of CommitAttempt in io.fluxzero.sdk.persisting.repository

Methods in io.fluxzero.sdk.persisting.repository that return CommitAttempt

Modifier and Type	Method	Description
CommitAttempt	DefaultModelRepository.loadContext(MutationPlan.Resolution resolution)	Loads all direct commit targets at one state boundary.
CommitAttempt	DefaultModelRepository.loadContext(MutationPlan.Resolution resolution, Long maxStateIndex, Map<String,Object> stagedValues, boolean includeMessageBatch)	Loads a commit context with an explicit choice whether pending values from the surrounding tracking batch should be overlaid.
CommitAttempt	DefaultModelRepository.loadContext(MutationPlan.Resolution resolution, Long maxStateIndex, Map<String,Object> stagedValues, boolean includeMessageBatch, boolean migration)	Loads a commit attempt for the resolved Models at the supplied maximum state index, with staged values and the requested message-batch and migration visibility.
default CommitAttempt	ModelRepository.loadContext(MutationPlan.Resolution resolution)	Loads all model parameters for one selected message handler at one repository boundary.
CommitAttempt	DefaultModelRepository.loadCurrentContext(MutationPlan.Resolution resolution, Map<String,Object> stagedValues, boolean includeMessageBatch)	Loads one transaction's initial context at a freshly observed storage boundary.
CommitAttempt	DefaultModelRepository.loadDeferredDocumentContext(MutationPlan.Resolution resolution)	Internal fast preparation for a direct DOCUMENT target; pending mutations retain eager preparation.
CommitAttempt	DefaultModelRepository.loadRebaseContext(MutationPlan.Resolution resolution, Long maxStateIndex, Map<String,Object> stagedValues, boolean includeMessageBatch, boolean migration)	Reloads a conflict retry or ACCEPT rebase, waiting for pending document materialization and allowing an incomplete authoritative document to advance the exact boundary before mutation evaluation.
CommitAttempt	DefaultModelRepository.overlayPendingContext(CommitAttempt context)	Adds this repository's visible pending values and commit dependencies to a prefetched durable context.

Methods in io.fluxzero.sdk.persisting.repository with parameters of type CommitAttempt

Modifier and Type	Method	Description
CompletableFuture<Optional<CommitModelsResult>>	DefaultModelRepository.Commit.commit(String commitId, CommitAttempt evaluation)	Prepares and commits an attempt with ModelConflictPolicy.ACCEPT; returns an empty result when there is no commit to send.
CompletableFuture<Optional<CommitModelsResult>>	DefaultModelRepository.Commit.commit(String commitId, CommitAttempt evaluation, ModelConflictPolicy conflictPolicy)	Prepares and commits an attempt with the supplied conflict policy.
CommitAttempt	DefaultModelRepository.overlayPendingContext(CommitAttempt context)	Adds this repository's visible pending values and commit dependencies to a prefetched durable context.
DefaultModelRepository.Commit.Outcome	DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation)	Prepares the wire commit and change correlation for an attempt using ModelConflictPolicy.ACCEPT, without submitting it.
DefaultModelRepository.Commit.Outcome	DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation, ModelConflictPolicy conflictPolicy)	Prepares an ordinary, non-migration commit with the supplied conflict policy, without submitting it.
DefaultModelRepository.Commit.Outcome	DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation, ModelConflictPolicy conflictPolicy, boolean migration)	Prepares a commit with the supplied conflict and migration policies, without treating its input as an already stored event or submitting it.
DefaultModelRepository.Commit.Outcome	DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation, ModelConflictPolicy conflictPolicy, boolean migration, boolean existingEvent)	Prepares the wire commit and change correlation using the supplied conflict, migration, and existing-event policies, without submitting the commit.
DefaultModelRepository.Commit.Outcome	DefaultModelRepository.Commit.prepareDeadlineReevaluation(String commitId, DefaultModelRepository.Commit.Outcome original, CommitAttempt evaluation)	Rebuilds all deadline metadata and effects without changing the original conflict or event policy.
DefaultModelRepository.Commit.Outcome	DefaultModelRepository.Commit.prepareRebased(String commitId, DefaultModelRepository.Commit.Outcome original, CommitAttempt evaluation)	Prepares an ACCEPT rebase with the original commit shape, delivery guarantee, duplicate flag, and migration policy.
CompletableFuture<Optional<CommitModelsResult>>	DefaultModelRepository.Commit.trackLocalCommit(CommitAttempt attempt, DeserializingMessage message, boolean migration, Supplier<CompletableFuture<Optional<CommitModelsResult>>> operation)	Keeps tracker fencing around the complete commit and retry lifecycle.
CompletableFuture<Optional<CommitModelsResult>>	DefaultModelRepository.Commit.trackLocalCommit(CommitAttempt attempt, DeserializingMessage message, boolean migration, Supplier<CompletableFuture<Optional<CommitModelsResult>>> operation, Runnable afterCommit)	Releases process-local commit ordering after cache/tracker publication and before optional Graph waiting.