Affected by 
Documentation
¶
Index ¶
Constants ¶
View Source
const (
NamespaceID = "NamespaceId"
WorkflowID = "WorkflowId"
RunID = "RunId"
WorkflowType = "WorkflowType"
StartTime = "StartTime"
ExecutionTime = "ExecutionTime"
CloseTime = "CloseTime"
ExecutionStatus = "ExecutionStatus"
HistoryLength = "HistoryLength"
KafkaKey = "KafkaKey"
Encoding = "Encoding"
BinaryChecksums = "BinaryChecksums"
TaskQueue = "TaskQueue"
VisibilityTaskKey = "VisibilityTaskKey"
CustomStringField = "CustomStringField"
CustomKeywordField = "CustomKeywordField"
CustomIntField = "CustomIntField"
CustomDoubleField = "CustomDoubleField"
CustomBoolField = "CustomBoolField"
CustomDatetimeField = "CustomDatetimeField"
TemporalChangeVersion = "TemporalChangeVersion"
CustomNamespace = "CustomNamespace"
Operator = "Operator"
)
valid indexed fields on ES
View Source
const Attr = "Attr"
Attr is prefix of custom search attributes
View Source
const (
Memo = "Memo"
)
valid non-indexed fields on ES
Variables ¶
This section is empty.
Functions ¶
func GenerateDeduplicationKey ¶ added in v0.27.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 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.27.0
type DeduplicationID interface {
GetID() string
}
DeduplicationID uses to generate id for deduplication
type EventReappliedID ¶ added in v0.27.0
type EventReappliedID struct {
// contains filtered or unexported fields
}
EventReappliedID is the deduplication resource for reapply event
func NewEventReappliedID ¶ added in v0.27.0
func NewEventReappliedID(
runID string,
eventID int64,
version int64,
) EventReappliedID
NewEventReappliedID returns EventReappliedID resource
type WorkflowIdentifier ¶
type WorkflowIdentifier struct {
NamespaceID string
WorkflowID string
RunID string
}
WorkflowIdentifier is the combinations which represent a workflow
func NewWorkflowIdentifier ¶
func NewWorkflowIdentifier(namespaceID string, workflowID string, runID string) WorkflowIdentifier
NewWorkflowIdentifier create a new WorkflowIdentifier
Source Files
Click to show internal directories.
Click to hide internal directories.