definition

Documentation

Index

• Constants
• func GenerateDeduplicationKey(resource DeduplicationID) string
• func GetDefaultIndexedKeys() map[string]interface{}
• func IsSystemBoolKey(key string) bool
• 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 IsSystemBoolKey

func IsSystemBoolKey(key string) bool

IsSystemBoolKey return true is key is system added bool key

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