worker_versioning

Documentation

Index

• Constants
• func FindBuildId(versioningData *persistencespb.VersioningData, buildId string) (setIndex, indexInSet int)
• func MakeDirectiveForActivityTask(stamp *commonpb.WorkerVersionStamp, useCompatibleVersion bool) *taskqueuespb.TaskVersionDirective
• func MakeDirectiveForWorkflowTask(stamp *commonpb.WorkerVersionStamp, lastWorkflowTaskStartedEventID int64) *taskqueuespb.TaskVersionDirective
• func StampIfUsingVersioning(stamp *commonpb.WorkerVersionStamp) *commonpb.WorkerVersionStamp
• func UnversionedBuildIdSearchAttribute(buildId string) string
• func VersionStampToBuildIdSearchAttribute(stamp *commonpb.WorkerVersionStamp) string
• func VersionedBuildIdSearchAttribute(buildId string) string
• func WorkflowsExistForBuildId(ctx context.Context, visibilityManager manager.VisibilityManager, ...) (bool, error)

Constants

const (
	BuildIdSearchAttributeDelimiter = ":"
	// UnversionedSearchAttribute is the sentinel value used to mark all unversioned workflows
	UnversionedSearchAttribute = buildIdSearchAttributePrefixUnversioned
)

Functions

func FindBuildId

func FindBuildId(versioningData *persistencespb.VersioningData, buildId string) (setIndex, indexInSet int)

FindBuildId finds a build id in the version data's sets, returning (set index, index within that set). Returns -1, -1 if not found.

func MakeDirectiveForActivityTask

func MakeDirectiveForActivityTask(
	stamp *commonpb.WorkerVersionStamp,
	useCompatibleVersion bool,
) *taskqueuespb.TaskVersionDirective

func MakeDirectiveForWorkflowTask

func MakeDirectiveForWorkflowTask(
	stamp *commonpb.WorkerVersionStamp,
	lastWorkflowTaskStartedEventID int64,
) *taskqueuespb.TaskVersionDirective

func StampIfUsingVersioning

func StampIfUsingVersioning(stamp *commonpb.WorkerVersionStamp) *commonpb.WorkerVersionStamp

StampIfUsingVersioning returns the given WorkerVersionStamp if it is using versioning, otherwise returns nil.

func UnversionedBuildIdSearchAttribute

func UnversionedBuildIdSearchAttribute(buildId string) string

VersionedBuildIdSearchAttribute returns the search attribute value for an versioned build id

func VersionStampToBuildIdSearchAttribute

func VersionStampToBuildIdSearchAttribute(stamp *commonpb.WorkerVersionStamp) string

VersionStampToBuildIdSearchAttribute returns the search attribute value for a version stamp

func VersionedBuildIdSearchAttribute

func VersionedBuildIdSearchAttribute(buildId string) string

VersionedBuildIdSearchAttribute returns the search attribute value for an unversioned build id

func WorkflowsExistForBuildId

func WorkflowsExistForBuildId(ctx context.Context, visibilityManager manager.VisibilityManager, ns *namespace.Namespace, taskQueue, buildId string) (bool, error)