Class VersionMarkerUtils

java.lang.Object

io.temporal.internal.history.VersionMarkerUtils

public class VersionMarkerUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CHANGE_VERSION_SEARCH_ATTRIBUTE_SIZE_LIMIT
static final String	MARKER_CHANGE_ID_KEY
static final String	MARKER_NAME
static final String	MARKER_VERSION_KEY
static final SearchAttributeKey<List<String>>	TEMPORAL_CHANGE_VERSION
static final String	VERSION_SA_UPDATED_KEY

Constructor Summary

Constructors

Constructor	Description
VersionMarkerUtils()

Method Summary

Modifier and Type	Method	Description
static String	createChangeId(String changeId, Integer version)
static io.temporal.api.command.v1.RecordMarkerCommandAttributes	createMarkerAttributes(String changeId, Integer version, Boolean upsertVersionSA)
static io.temporal.api.common.v1.SearchAttributes	createVersionMarkerSearchAttributes(String newChangeId, Integer newVersion, Map<String,Integer> existingVersions)
static String	getChangeId(io.temporal.api.history.v1.MarkerRecordedEventAttributes markerAttributes)
static boolean	getUpsertVersionSA(io.temporal.api.history.v1.MarkerRecordedEventAttributes markerAttributes)
static Integer	getVersion(io.temporal.api.history.v1.MarkerRecordedEventAttributes markerAttributes)
static boolean	hasVersionMarkerStructure(io.temporal.api.command.v1.Command command)
static boolean	hasVersionMarkerStructure(io.temporal.api.history.v1.HistoryEvent event)
static String	tryGetChangeIdFromVersionMarkerEvent(io.temporal.api.history.v1.HistoryEvent event)

Methods inherited from class java.lang.Object

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

Field Details

MARKER_NAME

public static final String MARKER_NAME

See Also:

• Constant Field Values

MARKER_CHANGE_ID_KEY

public static final String MARKER_CHANGE_ID_KEY

See Also:

• Constant Field Values

MARKER_VERSION_KEY

public static final String MARKER_VERSION_KEY

See Also:

• Constant Field Values

VERSION_SA_UPDATED_KEY

public static final String VERSION_SA_UPDATED_KEY

See Also:

• Constant Field Values

TEMPORAL_CHANGE_VERSION

public static final SearchAttributeKey<List<String>> TEMPORAL_CHANGE_VERSION

CHANGE_VERSION_SEARCH_ATTRIBUTE_SIZE_LIMIT

public static final int CHANGE_VERSION_SEARCH_ATTRIBUTE_SIZE_LIMIT

See Also:

• Constant Field Values

Constructor Details

VersionMarkerUtils

public VersionMarkerUtils()

Method Details

tryGetChangeIdFromVersionMarkerEvent

@Nullable
public static String tryGetChangeIdFromVersionMarkerEvent(io.temporal.api.history.v1.HistoryEvent event)

Parameters:

event - HistoryEvent to parse

Returns:

changeId of this version marker if the structure of this event looks like a marker event, null otherwise

hasVersionMarkerStructure

public static boolean hasVersionMarkerStructure(io.temporal.api.history.v1.HistoryEvent event)

Parameters:

event - HistoryEvent to inspect

Returns:

true if the event has a correct structure for a version marker

hasVersionMarkerStructure

public static boolean hasVersionMarkerStructure(io.temporal.api.command.v1.Command command)

Parameters:

command - Command to inspect

Returns:

true if the command has a correct structure for a version marker

getChangeId

@Nullable
public static String getChangeId(io.temporal.api.history.v1.MarkerRecordedEventAttributes markerAttributes)

getVersion

@Nullable
public static Integer getVersion(io.temporal.api.history.v1.MarkerRecordedEventAttributes markerAttributes)

getUpsertVersionSA

@Nullable
public static boolean getUpsertVersionSA(io.temporal.api.history.v1.MarkerRecordedEventAttributes markerAttributes)

createMarkerAttributes

public static io.temporal.api.command.v1.RecordMarkerCommandAttributes createMarkerAttributes(String changeId,
 Integer version,
 Boolean upsertVersionSA)

createChangeId

public static String createChangeId(String changeId,
 Integer version)

createVersionMarkerSearchAttributes

public static io.temporal.api.common.v1.SearchAttributes createVersionMarkerSearchAttributes(String newChangeId,
 Integer newVersion,
 Map<String,Integer> existingVersions)