definition

Documentation

Index

• Constants
• func GenerateDeduplicationKey(resource DeduplicationID) string
• func GetDefaultIndexedKeys() map[string]interface{}
• func IsSystemIndexedKey(key string) bool
• type DeduplicationID
• type EventReappliedID
  • func NewEventReappliedID(runID string, eventID int64, version int64) EventReappliedID
  • func (e EventReappliedID) GetID() string
• type WorkflowIdentifier
  • func NewWorkflowIdentifier(domainID string, workflowID string, runID string) WorkflowIdentifier

Constants

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

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"
)

Functions

func GenerateDeduplicationKey

func GenerateDeduplicationKey(
	resource DeduplicationID,
) string

GenerateDeduplicationKey generates deduplication key

func GetDefaultIndexedKeys

func GetDefaultIndexedKeys() map[string]interface{}

GetDefaultIndexedKeys return default valid indexed keys

func IsSystemIndexedKey

func IsSystemIndexedKey(key string) bool

IsSystemIndexedKey return true is key is system added

Types

type DeduplicationID

type DeduplicationID interface {
	GetID() string
}

DeduplicationID uses to generate id for deduplication

type EventReappliedID

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

EventReappliedID is the deduplication resource for reapply event

func NewEventReappliedID

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

NewEventReappliedID returns EventReappliedID resource

func (EventReappliedID) GetID

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