worker_versioning

Documentation

Index

• Constants
• func AssignedBuildIdSearchAttribute(buildId string) string
• func BuildIdIfUsingVersioning(stamp *commonpb.WorkerVersionStamp) string
• func FindBuildId(versioningData *persistencespb.VersioningData, buildId string) (setIndex, indexInSet int)
• func IsUnversionedOrAssignedBuildIdSearchAttribute(buildId string) bool
• func MakeBuildIdDirective(buildId string) *taskqueuespb.TaskVersionDirective
• func MakeDirectiveForWorkflowTask(inheritedBuildId string, assignedBuildId string, ...) *taskqueuespb.TaskVersionDirective
• func MakeUseAssignmentRulesDirective() *taskqueuespb.TaskVersionDirective
• func StampFromCapabilities(cap *commonpb.WorkerVersionCapabilities) *commonpb.WorkerVersionStamp
• 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 AssignedBuildIdSearchAttribute

func AssignedBuildIdSearchAttribute(buildId string) string

AssignedBuildIdSearchAttribute returns the search attribute value for the currently assigned build id

func BuildIdIfUsingVersioning

func BuildIdIfUsingVersioning(stamp *commonpb.WorkerVersionStamp) string

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

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 IsUnversionedOrAssignedBuildIdSearchAttribute

func IsUnversionedOrAssignedBuildIdSearchAttribute(buildId string) bool

IsUnversionedOrAssignedBuildIdSearchAttribute returns the value is "unversioned" or "assigned:<bld>"

func MakeBuildIdDirective

func MakeBuildIdDirective(buildId string) *taskqueuespb.TaskVersionDirective

func MakeDirectiveForWorkflowTask

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

MakeDirectiveForWorkflowTask returns a versioning directive based on the following parameters: - inheritedBuildId: build ID inherited from a past/previous wf execution (for Child WF or CaN) - assignedBuildId: the build id to which the WF is currently assigned (i.e. mutable state's AssginedBuildId) - stamp: the latest versioning stamp of the execution (only needed for old versioning) - lastWorkflowTaskStartedEventID: to determine if this is the first WFT

func MakeUseAssignmentRulesDirective

func MakeUseAssignmentRulesDirective() *taskqueuespb.TaskVersionDirective

func StampFromCapabilities

func StampFromCapabilities(cap *commonpb.WorkerVersionCapabilities) *commonpb.WorkerVersionStamp

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

UnversionedBuildIdSearchAttribute returns the search attribute value for an unversioned 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 a versioned build id

func WorkflowsExistForBuildId

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