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 CommitAttemptModelBatchScope.overlayCurrent(String namespace, CommitAttempt durable) Overlays pending exact values without changing the durable context's pinned state boundary.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 ObjectModelReducer.replay(MutationPlan plan, DeserializingMessage event, CommitAttempt context, String targetModelId) -
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.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.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.