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
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
Source Files
Click to show internal directories.
Click to hide internal directories.