definition

package
v0.24.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 24, 2022 License: MIT Imports: 2 Imported by: 9

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"

	CustomStringField    = "CustomStringField"
	CustomKeywordField   = "CustomKeywordField"
	CustomIntField       = "CustomIntField"
	CustomBoolField      = "CustomBoolField"
	CustomDoubleField    = "CustomDoubleField"
	CustomDatetimeField  = "CustomDatetimeField"
	CadenceChangeVersion = "CadenceChangeVersion"
)

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

func (EventReappliedID) GetID added in v0.11.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL