definition

package
v1.2.14-prerelease07 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 8, 2024 License: MIT Imports: 2 Imported by: 9

Documentation

Index

Constants

View Source
const (
	DomainID        = "DomainID"
	WorkflowID      = "WorkflowID"
	RunID           = "RunID"
	WorkflowType    = "WorkflowType"
	StartTime       = "StartTime"
	ExecutionTime   = "ExecutionTime"
	CloseTime       = "CloseTime"
	CloseStatus     = "CloseStatus"
	HistoryLength   = "HistoryLength"
	Encoding        = "Encoding"
	KafkaKey        = "KafkaKey"
	BinaryChecksums = "BinaryChecksums"
	TaskList        = "TaskList"
	IsCron          = "IsCron"
	NumClusters     = "NumClusters"
	UpdateTime      = "UpdateTime"
	CustomDomain    = "CustomDomain" // to support batch workflow
	Operator        = "Operator"     // to support batch workflow

	CustomStringField    = "CustomStringField"
	CustomKeywordField   = "CustomKeywordField"
	CustomIntField       = "CustomIntField"
	CustomBoolField      = "CustomBoolField"
	CustomDoubleField    = "CustomDoubleField"
	CustomDatetimeField  = "CustomDatetimeField"
	CadenceChangeVersion = "CadenceChangeVersion"
)

valid indexed fields on ES

View Source
const (
	// Memo is valid non-indexed fields on ES
	Memo = "Memo"
	// Attr is prefix of custom search attributes
	Attr = "Attr"
	// HeaderFormat is the format of context headers in search attributes
	HeaderFormat = "Header_%s"
)

Variables

This section is empty.

Functions

func GenerateDeduplicationKey added in v0.11.0

func GenerateDeduplicationKey(
	resource DeduplicationID,
) string

GenerateDeduplicationKey generates deduplication key

func GetDefaultIndexedKeys added in v0.5.9

func GetDefaultIndexedKeys() map[string]interface{}

GetDefaultIndexedKeys return default valid indexed keys

func IsSystemBoolKey added in v1.2.13

func IsSystemBoolKey(key string) bool

IsSystemBoolKey return true is key is system added bool key

func IsSystemIndexedKey added in v0.5.9

func IsSystemIndexedKey(key string) bool

IsSystemIndexedKey return true is key is system added

Types

type DeduplicationID added in v0.11.0

type DeduplicationID interface {
	GetID() string
}

DeduplicationID uses to generate id for deduplication

type EventReappliedID added in v0.11.0

type EventReappliedID struct {
	// contains filtered or unexported fields
}

EventReappliedID is the deduplication resource for reapply event

func NewEventReappliedID added in v0.11.0

func NewEventReappliedID(
	runID string,
	eventID int64,
	version int64,
) EventReappliedID

NewEventReappliedID returns EventReappliedID resource

func (EventReappliedID) GetID added in v0.11.0

func (e EventReappliedID) GetID() string

GetID returns id of EventReappliedID

type WorkflowIdentifier

type WorkflowIdentifier struct {
	DomainID   string
	WorkflowID string
	RunID      string
}

WorkflowIdentifier is the combinations which represent a workflow

func NewWorkflowIdentifier

func NewWorkflowIdentifier(domainID string, workflowID string, runID string) WorkflowIdentifier

NewWorkflowIdentifier create a new WorkflowIdentifier

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL