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(namespaceID string, workflowID string, runID string) WorkflowIdentifier

Constants

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

const Attr = "Attr"

Attr is prefix of custom search attributes

const (
	Memo = "Memo"
)

valid non-indexed fields on ES

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 {
	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