Uses of Class
io.fluxzero.sdk.modeling.CommitAttempt
Packages that use CommitAttempt
-
Uses of CommitAttempt in io.fluxzero.sdk.modeling
Methods in io.fluxzero.sdk.modeling that return CommitAttemptModifier and TypeMethodDescriptionstatic CommitAttemptCommitAttempt.create(long readStateIndex, MutationPlan.Resolution resolution, Map<String, ? extends Entity<?>> loadedModels) Creates a loaded begin-state for one resolved target set.static CommitAttemptCommitAttempt.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 CommitAttemptCommitAttempt.currentReadContext(ModelRepository repository) Returns this repository's active mutation read context, never an event-replay or escaped async context.static CommitAttemptModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable) Overlays pending exact values without changing the durable context's pinned state boundary.static CommitAttemptModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable, Object repositoryOwner) Overlays only pending values produced by this repository family at the durable boundary.CommitAttempt.withAliasResolutions(Map<String, String> aliases) Retains the lookup names that resolved injected read-only targets, including unresolved aliases.CommitAttempt.withAncestorReads(ModelAncestorResolver.AncestorReads reads) Retains identity-only proof used to resolve indirect injected Models at this context's pinned boundary.CommitAttempt.withDeferredBoundary(LongSupplier verification) Internal single-document loading provenance; copies share the same one-time verification.Methods in io.fluxzero.sdk.modeling with parameters of type CommitAttemptModifier and TypeMethodDescriptionstatic CommitAttemptModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable) Overlays pending exact values without changing the durable context's pinned state boundary.static CommitAttemptModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable, Object repositoryOwner) Overlays only pending values produced by this repository family at the durable boundary.static ObjectModelReducer.replay(MutationPlan plan, DeserializingMessage event, CommitAttempt context, String targetModelId) static ObjectModelReducer.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 CommitAttemptModifier and TypeMethodDescriptionstatic ObjectModelReducer.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 ObjectModelReducer.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 CommitAttemptModifier and TypeMethodDescriptionDefaultModelRepository.loadContext(MutationPlan.Resolution resolution) Loads all direct commit targets at one state boundary.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.DefaultModelRepository.loadContext(MutationPlan.Resolution resolution, Long maxStateIndex, Map<String, Object> stagedValues, boolean includeMessageBatch, boolean migration) default CommitAttemptModelRepository.loadContext(MutationPlan.Resolution resolution) Loads all model parameters for one selected message handler at one repository boundary.DefaultModelRepository.loadCurrentContext(MutationPlan.Resolution resolution, Map<String, Object> stagedValues, boolean includeMessageBatch) Loads one transaction's initial context at a freshly observed storage boundary.DefaultModelRepository.loadDeferredDocumentContext(MutationPlan.Resolution resolution) Internal fast preparation for a direct DOCUMENT target; pending mutations retain eager preparation.DefaultModelRepository.loadRebaseContext(MutationPlan.Resolution resolution, Long maxStateIndex, Map<String, Object> stagedValues, boolean includeMessageBatch, boolean migration) Reloads an ACCEPT rebase while allowing an incomplete authoritative document to advance the exact boundary.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 CommitAttemptModifier and TypeMethodDescriptionCompletableFuture<Optional<io.fluxzero.common.api.modeling.CommitModelsResult>> DefaultModelRepository.Commit.commit(String commitId, CommitAttempt evaluation) CompletableFuture<Optional<io.fluxzero.common.api.modeling.CommitModelsResult>> DefaultModelRepository.Commit.commit(String commitId, CommitAttempt evaluation, io.fluxzero.common.api.modeling.ModelConflictPolicy conflictPolicy) DefaultModelRepository.overlayPendingContext(CommitAttempt context) Adds this repository's visible pending values and commit dependencies to a prefetched durable context.DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation) DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation, io.fluxzero.common.api.modeling.ModelConflictPolicy conflictPolicy) DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation, io.fluxzero.common.api.modeling.ModelConflictPolicy conflictPolicy, boolean migration) DefaultModelRepository.Commit.prepare(String commitId, CommitAttempt evaluation, io.fluxzero.common.api.modeling.ModelConflictPolicy conflictPolicy, boolean migration, boolean existingEvent) DefaultModelRepository.Commit.prepareRebased(String commitId, DefaultModelRepository.Commit.Outcome original, CommitAttempt evaluation) CompletableFuture<Optional<io.fluxzero.common.api.modeling.CommitModelsResult>> DefaultModelRepository.Commit.trackLocalCommit(CommitAttempt attempt, DeserializingMessage message, boolean migration, Supplier<CompletableFuture<Optional<io.fluxzero.common.api.modeling.CommitModelsResult>>> operation) Keeps tracker fencing around the complete commit and retry lifecycle.CompletableFuture<Optional<io.fluxzero.common.api.modeling.CommitModelsResult>> DefaultModelRepository.Commit.trackLocalCommit(CommitAttempt attempt, DeserializingMessage message, boolean migration, Supplier<CompletableFuture<Optional<io.fluxzero.common.api.modeling.CommitModelsResult>>> operation, Runnable afterCommit) Releases process-local commit ordering after cache/tracker publication and before optional Graph waiting.