worker_versioning

Documentation

Index

• Constants
• func FindBuildId(versioningData *persistencespb.VersioningData, buildId string) (setIndex, indexInSet int)
• 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 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)