Class CommitModelsWithDeadlines

java.lang.Object

io.fluxzero.common.api.Request

io.fluxzero.common.api.Command

io.fluxzero.common.api.modeling.CommitModels

io.fluxzero.common.api.modeling.CommitModelsWithDeadlines

All Implemented Interfaces:

JsonType, RetryAwareRequest

public final class CommitModelsWithDeadlines
extends CommitModels

Commits SDK-computed ordinary scheduler effects together with Model state. The distinct wire type requires explicit service support. All existing relationship, alias and document projection facets are retained.

Nested Class Summary

Nested classes/interfaces inherited from class CommitModels

CommitModels.Metric

Constructor Summary

Constructors

Constructor	Description
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)
CommitModelsWithDeadlines(CommitModels commit, List<ModelDeadlineUpdate> updates)

Method Summary

Modifier and Type	Method	Description
long	getBytes()	Returns the complete serialized event-message bytes carried once by this commit.
boolean	hasExpiredReplacement(long cutoff)	Whether a proposed replacement's original scheduler time has been reached at commit acceptance.

Methods inherited from class CommitModels

getReadAliasIds, getReadRelationships, markPossibleDuplicate, routingKey, singleTarget, toMetric

Methods inherited from class Command

getGuarantee

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CommitModelsWithDeadlines

public CommitModelsWithDeadlines(CommitModels commit,
 List<ModelDeadlineUpdate> updates)

CommitModelsWithDeadlines

@ConstructorProperties({"requestId","commitId","readStateIndex","readModelIds","substeps","conflictPolicy","guarantee","possibleDuplicate","migration","readRelationships","readAliasIds","deadlineUpdates"})
public 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)

Method Details

hasExpiredReplacement

public boolean hasExpiredReplacement(long cutoff)

Whether a proposed replacement's original scheduler time has been reached at commit acceptance.

getBytes

public long getBytes()

Description copied from class: CommitModels

Returns the complete serialized event-message bytes carried once by this commit.

Overrides:

getBytes in class CommitModels