Documentation
¶
Index ¶
- Constants
- Variables
- type Tag
- func ActorEmail(actorEmail string) Tag
- func ActorID(actorID string) Tag
- func Address(ad string) Tag
- func Addresses(ads []string) Tag
- func ArchivalArchiveAttemptedInline(archiveInline bool) Tag
- func ArchivalArchiveFailReason(archiveFailReason string) Tag
- func ArchivalBlobIntegrityCheckFailReason(blobIntegrityCheckFailReason string) Tag
- func ArchivalBlobKey(blobKey string) Tag
- func ArchivalBlobstoreContextTimeout(blobstoreContextTimeout time.Duration) Tag
- func ArchivalCallerServiceName(callerServiceName string) Tag
- func ArchivalDeleteHistoryFailReason(deleteHistoryFailReason string) Tag
- func ArchivalDeterministicConstructionCheckFailReason(deterministicConstructionCheckFailReason string) Tag
- func ArchivalNonDeterministicBlobKey(nondeterministicBlobKey string) Tag
- func ArchivalRequestBranchToken(requestBranchToken []byte) Tag
- func ArchivalRequestCloseFailoverVersion(requestCloseFailoverVersion int64) Tag
- func ArchivalRequestCloseStatus(requestCloseStatus string) Tag
- func ArchivalRequestCloseTimestamp(requestCloseTimeStamp int64) Tag
- func ArchivalRequestDomainID(requestDomainID string) Tag
- func ArchivalRequestDomainName(requestDomainName string) Tag
- func ArchivalRequestNextEventID(requestNextEventID int64) Tag
- func ArchivalRequestRunID(requestRunID string) Tag
- func ArchivalRequestWorkflowID(requestWorkflowID string) Tag
- func ArchivalURI(URI string) Tag
- func ArchivalVisibilityQuery(query string) Tag
- func ArchvialRequestWorkflowType(requestWorkflowType string) Tag
- func Attempt(attempt int32) Tag
- func AttemptCount(attemptCount int) Tag
- func AttemptEnd(attemptEnd time.Time) Tag
- func AttemptStart(attemptStart time.Time) Tag
- func BlobSizeViolationOperation(operation string) Tag
- func Bool(b bool) Tag
- func ClientError(clientErr error) Tag
- func ClientFeatureVersion(clientFeatureVersion string) Tag
- func ClientImpl(clientImpl string) Tag
- func ClusterName(clusterName string) Tag
- func Counter(c int) Tag
- func CurrentVersion(currentVersion int64) Tag
- func CursorTimestamp(timestamp time.Time) Tag
- func DefaultValue(v interface{}) Tag
- func DetailInfo(i string) Tag
- func Dynamic(key string, v interface{}) Tag
- func ESAggregationID(id string) Tag
- func ESConfig(c interface{}) Tag
- func ESDocID(id string) Tag
- func ESField(ESField string) Tag
- func ESKey(ESKey string) Tag
- func ESRequest(ESRequest string) Tag
- func ESResponseError(msg string) Tag
- func ESResponseStatus(status int) Tag
- func ESValue(ESValue []byte) Tag
- func Env(env string) Tag
- func Error(err error) Tag
- func FailoverMsg(failoverMsg string) Tag
- func FailoverVersion(version int64) Tag
- func FallbackIsolationGroup(group string) Tag
- func FirstEventVersion(version int64) Tag
- func HandlerCall(handlerCall string) Tag
- func IncomingVersion(incomingVersion int64) Tag
- func IsolationGroup(group string) Tag
- func KafkaConsumerName(consumerName string) Tag
- func KafkaOffset(offset int64) Tag
- func KafkaPartition(partition int32) Tag
- func KafkaPartitionKey(partitionKey interface{}) Tag
- func KafkaTopicName(topicName string) Tag
- func Key(k string) Tag
- func LastEventVersion(version int64) Tag
- func MaxLevel(lv int64) Tag
- func MetricScope(metricScope int) Tag
- func MinLevel(lv int64) Tag
- func Name(k string) Tag
- func NextNumber(n int64) Tag
- func Number(n int64) Tag
- func NumberDeleted(n int) Tag
- func NumberProcessed(n int) Tag
- func OperationName(operationName string) Tag
- func PartitionConfig(p map[string]string) Tag
- func PollerGroups(pollers []string) Tag
- func PollerGroupsConfiguration(pollers types.IsolationGroupConfiguration) Tag
- func Port(p int) Tag
- func PrevActiveCluster(prevActiveCluster string) Tag
- func PreviousQueueLevel(level int) Tag
- func PreviousShardRangeID(id int64) Tag
- func QueryID(queryID string) Tag
- func QueueLevel(level int) Tag
- func QueueSplitPolicyType(policyType int) Tag
- func ReadLevel(lv int64) Tag
- func RemoteCluster(remoteCluster string) Tag
- func ReplicationInfo(replicationInfo interface{}) Tag
- func RequestBody(requestBody string) Tag
- func RequestCaller(callerName string) Tag
- func ResponseMaxSize(size int) Tag
- func ResponseSize(size int) Tag
- func ResponseTotalSize(size int) Tag
- func ScheduleAttempt(scheduleAttempt int64) Tag
- func Service(sv string) Tag
- func ShardCrossClusterAcks(shardCrossClusterAcks interface{}) Tag
- func ShardID(shardID int) Tag
- func ShardRangeID(id int64) Tag
- func ShardReplicationAck(shardReplicationAck int64) Tag
- func ShardReplicationToken(token interface{}) Tag
- func ShardTime(shardTime interface{}) Tag
- func ShardTimerAcks(shardTimerAcks interface{}) Tag
- func ShardTransferAcks(shardTransferAcks interface{}) Tag
- func SourceCluster(sourceCluster string) Tag
- func StoreError(storeErr error) Tag
- func StoreShard(storeShard string) Tag
- func StoreType(storeType string) Tag
- func Subscriber(subscriber string) Tag
- func SysStackTrace(stackTrace string) Tag
- func TargetWorkflowDomainID(domainID string) Tag
- func TargetWorkflowID(workflowID string) Tag
- func TargetWorkflowRunID(runID string) Tag
- func TaskID(taskID int64) Tag
- func TaskType(taskType int) Tag
- func TaskVisibilityTimestamp(timestamp int64) Tag
- func TimerTaskStatus(timerTaskStatus int32) Tag
- func Timestamp(timestamp time.Time) Tag
- func TokenLastEventID(id int64) Tag
- func TokenLastEventVersion(version int64) Tag
- func Value(v interface{}) Tag
- func ValueType(v interface{}) Tag
- func VisibilityQuery(query string) Tag
- func WorkflowActivityID(id string) Tag
- func WorkflowBeginningRunID(beginningRunID string) Tag
- func WorkflowBinaryChecksum(cs string) Tag
- func WorkflowBranchID(branchID string) Tag
- func WorkflowCronSchedule(schedule string) Tag
- func WorkflowDecisionFailCause(decisionFailCause int64) Tag
- func WorkflowDecisionTimeoutSeconds(s int32) Tag
- func WorkflowDecisionType(decisionType int64) Tag
- func WorkflowDomainID(domainID string) Tag
- func WorkflowDomainIDs(domainIDs interface{}) Tag
- func WorkflowDomainName(domainName string) Tag
- func WorkflowEndingRunID(endingRunID string) Tag
- func WorkflowError(error error) Tag
- func WorkflowEventCount(eventCount int) Tag
- func WorkflowEventID(eventID int64) Tag
- func WorkflowEventType(eventType string) Tag
- func WorkflowFirstEventID(firstEventID int64) Tag
- func WorkflowHandlerName(handlerName string) Tag
- func WorkflowHistorySize(historySize int) Tag
- func WorkflowHistorySizeBytes(historySizeBytes int) Tag
- func WorkflowID(workflowID string) Tag
- func WorkflowInitiatedID(id int64) Tag
- func WorkflowNextEventID(nextEventID int64) Tag
- func WorkflowPollContextTimeout(pollContextTimeout time.Duration) Tag
- func WorkflowQueryType(qt string) Tag
- func WorkflowResetBaseRunID(runID string) Tag
- func WorkflowResetNewRunID(runID string) Tag
- func WorkflowResetNextEventID(resetNextEventID int64) Tag
- func WorkflowRunID(runID string) Tag
- func WorkflowScheduleID(scheduleID int64) Tag
- func WorkflowSignalCount(signalCount int32) Tag
- func WorkflowSize(workflowSize int64) Tag
- func WorkflowStartedID(id int64) Tag
- func WorkflowState(s int) Tag
- func WorkflowTaskListKind(taskListKind int32) Tag
- func WorkflowTaskListName(taskListName string) Tag
- func WorkflowTaskListType(taskListType int) Tag
- func WorkflowTimeoutType(timeoutType int64) Tag
- func WorkflowTimerID(id string) Tag
- func WorkflowTreeID(treeID string) Tag
- func WorkflowType(wfType string) Tag
Constants ¶
const LoggingCallAtKey = "logging-call-at"
LoggingCallAtKey is reserved tag
Variables ¶
var ( // workflow start / finish WorkflowActionWorkflowStarted = workflowAction("add-workflow-started-event") WorkflowActionWorkflowCanceled = workflowAction("add-workflow-canceled-event") WorkflowActionWorkflowCompleted = workflowAction("add-workflow-completed--event") WorkflowActionWorkflowFailed = workflowAction("add-workflow-failed-event") WorkflowActionWorkflowTimeout = workflowAction("add-workflow-timeout-event") WorkflowActionWorkflowTerminated = workflowAction("add-workflow-terminated-event") WorkflowActionWorkflowContinueAsNew = workflowAction("add-workflow-continue-as-new-event") // workflow cancellation / sign WorkflowActionWorkflowCancelRequested = workflowAction("add-workflow-cancel-requested-event") WorkflowActionWorkflowSignaled = workflowAction("add-workflow-signaled-event") WorkflowActionWorkflowRecordMarker = workflowAction("add-workflow-marker-record-event") WorkflowActionUpsertWorkflowSearchAttributes = workflowAction("add-workflow-upsert-search-attributes-event") // decision WorkflowActionDecisionTaskScheduled = workflowAction("add-decisiontask-scheduled-event") WorkflowActionDecisionTaskStarted = workflowAction("add-decisiontask-started-event") WorkflowActionDecisionTaskCompleted = workflowAction("add-decisiontask-completed-event") WorkflowActionDecisionTaskTimedOut = workflowAction("add-decisiontask-timedout-event") WorkflowActionDecisionTaskFailed = workflowAction("add-decisiontask-failed-event") // in memory decision WorkflowActionInMemoryDecisionTaskScheduled = workflowAction("add-in-memory-decisiontask-scheduled") WorkflowActionInMemoryDecisionTaskStarted = workflowAction("add-in-memory-decisiontask-started") // activity WorkflowActionActivityTaskScheduled = workflowAction("add-activitytask-scheduled-event") WorkflowActionActivityTaskStarted = workflowAction("add-activitytask-started-event") WorkflowActionActivityTaskCompleted = workflowAction("add-activitytask-completed-event") WorkflowActionActivityTaskFailed = workflowAction("add-activitytask-failed-event") WorkflowActionActivityTaskTimedOut = workflowAction("add-activitytask-timed-event") WorkflowActionActivityTaskCanceled = workflowAction("add-activitytask-canceled-event") WorkflowActionActivityTaskCancelRequested = workflowAction("add-activitytask-cancel-requested-event") WorkflowActionActivityTaskCancelFailed = workflowAction("add-activitytask-cancel-failed-event") WorkflowActionActivityTaskRetry = workflowAction("add-activitytask-retry-event") // timer WorkflowActionTimerStarted = workflowAction("add-timer-started-event") WorkflowActionTimerFired = workflowAction("add-timer-fired-event") WorkflowActionTimerCanceled = workflowAction("add-timer-canceled-event") WorkflowActionTimerCancelFailed = workflowAction("add-timer-cancel-failed-event") // child workflow start / finish WorkflowActionChildWorkflowInitiated = workflowAction("add-childworkflow-initiated-event") WorkflowActionChildWorkflowStarted = workflowAction("add-childworkflow-started-event") WorkflowActionChildWorkflowInitiationFailed = workflowAction("add-childworkflow-initiation-failed-event") WorkflowActionChildWorkflowCanceled = workflowAction("add-childworkflow-canceled-event") WorkflowActionChildWorkflowCompleted = workflowAction("add-childworkflow-completed-event") WorkflowActionChildWorkflowFailed = workflowAction("add-childworkflow-failed-event") WorkflowActionChildWorkflowTerminated = workflowAction("add-childworkflow-terminated-event") WorkflowActionChildWorkflowTimedOut = workflowAction("add-childworkflow-timedout-event") // external workflow cancellation WorkflowActionExternalWorkflowCancelInitiated = workflowAction("add-externalworkflow-cancel-initiated-event") WorkflowActionExternalWorkflowCancelRequested = workflowAction("add-externalworkflow-cancel-requested-event") WorkflowActionExternalWorkflowCancelFailed = workflowAction("add-externalworkflow-cancel-failed-event") // external workflow signal WorkflowActionExternalWorkflowSignalInitiated = workflowAction("add-externalworkflow-signal-initiated-event") WorkflowActionExternalWorkflowSignalRequested = workflowAction("add-externalworkflow-signal-requested-event") WorkflowActionExternalWorkflowSignalFailed = workflowAction("add-externalworkflow-signal-failed-event") WorkflowActionUnknown = workflowAction("add-unknown-event") )
Pre-defined values for TagWorkflowAction
var ( WorkflowListWorkflowFilterByID = workflowListFilterType("WID") WorkflowListWorkflowFilterByType = workflowListFilterType("WType") WorkflowListWorkflowFilterByStatus = workflowListFilterType("status") )
Pre-defined values for TagWorkflowListFilterType
var ( ComponentTaskList = component("tasklist") ComponentHistoryEngine = component("history-engine") ComponentHistoryCache = component("history-cache") ComponentDecisionHandler = component("decision-handler") ComponentEventsCache = component("events-cache") ComponentTransferQueue = component("transfer-queue-processor") ComponentTimerQueue = component("timer-queue-processor") ComponentTimerBuilder = component("timer-builder") ComponentReplicatorQueue = component("replicator-queue-processor") ComponentShardController = component("shard-controller") ComponentShard = component("shard") ComponentShardItem = component("shard-item") ComponentShardEngine = component("shard-engine") ComponentMatchingEngine = component("matching-engine") ComponentReplicator = component("replicator") ComponentReplicationTaskProcessor = component("replication-task-processor") ComponentReplicationAckManager = component("replication-ack-manager") ComponentReplicationCacheManager = component("replication-cache-manager") ComponentHistoryReplicator = component("history-replicator") ComponentHistoryResender = component("history-resender") ComponentIndexer = component("indexer") ComponentIndexerProcessor = component("indexer-processor") ComponentIndexerESProcessor = component("indexer-es-processor") ComponentESVisibilityManager = component("es-visibility-manager") ComponentArchiver = component("archiver") ComponentBatcher = component("batcher") ComponentWorker = component("worker") ComponentServiceResolver = component("service-resolver") ComponentFailoverCoordinator = component("failover-coordinator") ComponentFailoverMarkerNotifier = component("failover-marker-notifier") ComponentCrossClusterQueueProcessor = component("cross-cluster-queue-processor") ComponentCrossClusterTaskProcessor = component("cross-cluster-task-processor") ComponentCrossClusterTaskFetcher = component("cross-cluster-task-fetcher") ComponentShardScanner = component("shardscanner-scanner") ComponentShardFixer = component("shardscanner-fixer") ComponentPinotVisibilityManager = component("pinot-visibility-manager") )
Pre-defined values for TagSysComponent
var ( LifeCycleStarting = lifecycle("Starting") LifeCycleStarted = lifecycle("Started") LifeCycleStopping = lifecycle("Stopping") LifeCycleStopped = lifecycle("Stopped") LifeCycleStopTimedout = lifecycle("StopTimedout") LifeCycleStartFailed = lifecycle("StartFailed") LifeCycleStopFailed = lifecycle("StopFailed") LifeCycleProcessingFailed = lifecycle("ProcessingFailed") )
Pre-defined values for TagSysLifecycle
var ( ErrorTypeInvalidHistoryAction = errorType("InvalidHistoryAction") ErrorTypeInvalidQueryTask = errorType("InvalidQueryTask") ErrorTypeQueryTaskFailed = errorType("QueryTaskFailed") ErrorTypePersistentStoreError = errorType("PersistentStoreError") ErrorTypeHistorySerializationError = errorType("HistorySerializationError") ErrorTypeHistoryDeserializationError = errorType("HistoryDeserializationError") ErrorTypeDuplicateTask = errorType("DuplicateTask") ErrorTypeMultipleCompletionDecisions = errorType("MultipleCompletionDecisions") ErrorTypeDuplicateTransferTask = errorType("DuplicateTransferTask") ErrorTypeDecisionFailed = errorType("DecisionFailed") ErrorTypeInvalidMutableStateAction = errorType("InvalidMutableStateAction") ErrorTypeInvalidMemDecisionTaskAction = errorType("InvalidMemDecisionTaskAction") )
Pre-defined values for SysErrorType
var ( // Shard context events ValueShardRangeUpdated = shardupdate("ShardRangeUpdated") ValueShardAllocateTimerBeforeRead = shardupdate("ShardAllocateTimerBeforeRead") ValueRingMembershipChangedEvent = shardupdate("RingMembershipChangedEvent") )
Pre-defined values for SysShardUpdate
var ( OperationFailed = operationResult("OperationFailed") OperationStuck = operationResult("OperationStuck") OperationCritical = operationResult("OperationCritical") )
Pre-defined values for OperationResult
var ( StoreOperationCreateShard = storeOperation("create-shard") StoreOperationGetShard = storeOperation("get-shard") StoreOperationUpdateShard = storeOperation("update-shard") StoreOperationCreateWorkflowExecution = storeOperation("create-wf-execution") StoreOperationGetWorkflowExecution = storeOperation("get-wf-execution") StoreOperationUpdateWorkflowExecution = storeOperation("update-wf-execution") StoreOperationConflictResolveWorkflowExecution = storeOperation("conflict-resolve-wf-execution") StoreOperationResetWorkflowExecution = storeOperation("reset-wf-execution") StoreOperationDeleteWorkflowExecution = storeOperation("delete-wf-execution") StoreOperationDeleteCurrentWorkflowExecution = storeOperation("delete-current-wf-execution") StoreOperationGetCurrentExecution = storeOperation("get-current-execution") StoreOperationListCurrentExecution = storeOperation("list-current-execution") StoreOperationIsWorkflowExecutionExists = storeOperation("is-wf-execution-exists") StoreOperationListConcreteExecution = storeOperation("list-concrete-execution") StoreOperationGetTransferTasks = storeOperation("get-transfer-tasks") StoreOperationGetCrossClusterTasks = storeOperation("get-cross-cluster-tasks") StoreOperationGetReplicationTasks = storeOperation("get-replication-tasks") StoreOperationCompleteTransferTask = storeOperation("complete-transfer-task") StoreOperationRangeCompleteTransferTask = storeOperation("range-complete-transfer-task") StoreOperationCompleteCrossClusterTask = storeOperation("complete-cross-cluster-task") StoreOperationRangeCompleteCrossClusterTask = storeOperation("range-complete-cross-cluster-task") StoreOperationCompleteReplicationTask = storeOperation("complete-replication-task") StoreOperationRangeCompleteReplicationTask = storeOperation("range-complete-replication-task") StoreOperationPutReplicationTaskToDLQ = storeOperation("put-replication-task-to-dlq") StoreOperationGetReplicationTasksFromDLQ = storeOperation("get-replication-tasks-from-dlq") StoreOperationGetReplicationDLQSize = storeOperation("get-replication-dlq-size") StoreOperationDeleteReplicationTaskFromDLQ = storeOperation("delete-replication-task-from-dlq") StoreOperationRangeDeleteReplicationTaskFromDLQ = storeOperation("range-delete-replication-task-from-dlq") StoreOperationCreateFailoverMarkerTasks = storeOperation("createFailoverMarkerTasks") StoreOperationGetTimerIndexTasks = storeOperation("get-timer-index-tasks") StoreOperationCompleteTimerTask = storeOperation("complete-timer-task") StoreOperationRangeCompleteTimerTask = storeOperation("range-complete-timer-task") StoreOperationCreateTasks = storeOperation("create-tasks") StoreOperationGetTasks = storeOperation("get-tasks") StoreOperationCompleteTask = storeOperation("complete-task") StoreOperationCompleteTasksLessThan = storeOperation("complete-tasks-less-than") StoreOperationLeaseTaskList = storeOperation("lease-task-list") StoreOperationUpdateTaskList = storeOperation("update-task-list") StoreOperationListTaskList = storeOperation("list-task-list") StoreOperationDeleteTaskList = storeOperation("delete-task-list") StoreOperationStopTaskList = storeOperation("stop-task-list") StoreOperationCreateDomain = storeOperation("create-domain") StoreOperationGetDomain = storeOperation("get-domain") StoreOperationUpdateDomain = storeOperation("update-domain") StoreOperationDeleteDomain = storeOperation("delete-domain") StoreOperationDeleteDomainByName = storeOperation("delete-domain-by-name") StoreOperationListDomains = storeOperation("list-domains") StoreOperationGetMetadata = storeOperation("get-metadata") StoreOperationRecordWorkflowExecutionStarted = storeOperation("record-wf-execution-started") StoreOperationRecordWorkflowExecutionClosed = storeOperation("record-wf-execution-closed") StoreOperationUpsertWorkflowExecution = storeOperation("upsert-wf-execution") StoreOperationListOpenWorkflowExecutions = storeOperation("list-open-wf-executions") StoreOperationListClosedWorkflowExecutions = storeOperation("list-closed-wf-executions") StoreOperationListOpenWorkflowExecutionsByType = storeOperation("list-open-wf-executions-by-type") StoreOperationListClosedWorkflowExecutionsByType = storeOperation("list-closed-wf-executions-by-type") StoreOperationListOpenWorkflowExecutionsByWorkflowID = storeOperation("list-open-wf-executions-by-wfID") StoreOperationListClosedWorkflowExecutionsByWorkflowID = storeOperation("list-closed-wf-executions-by-wfID") StoreOperationListClosedWorkflowExecutionsByStatus = storeOperation("list-closed-wf-executions-by-status") StoreOperationGetClosedWorkflowExecution = storeOperation("get-closed-wf-execution") StoreOperationVisibilityDeleteWorkflowExecution = storeOperation("vis-delete-wf-execution") StoreOperationListWorkflowExecutions = storeOperation("list-wf-executions") StoreOperationScanWorkflowExecutions = storeOperation("scan-wf-executions") StoreOperationCountWorkflowExecutions = storeOperation("count-wf-executions") StoreOperationAppendHistoryNodes = storeOperation("append-history-nodes") StoreOperationReadHistoryBranch = storeOperation("read-history-branch") StoreOperationReadHistoryBranchByBatch = storeOperation("read-history-branch-by-batch") StoreOperationReadRawHistoryBranch = storeOperation("read-raw-history-branch") StoreOperationForkHistoryBranch = storeOperation("fork-history-branch") StoreOperationDeleteHistoryBranch = storeOperation("delete-history-branch") StoreOperationGetHistoryTree = storeOperation("get-history-tree") StoreOperationGetAllHistoryTreeBranches = storeOperation("get-all-history-tree-branches") StoreOperationEnqueueMessage = storeOperation("enqueue-message") StoreOperationReadMessages = storeOperation("read-messages") StoreOperationUpdateAckLevel = storeOperation("update-ack-level") StoreOperationGetAckLevels = storeOperation("get-ack-levels") StoreOperationDeleteMessagesBefore = storeOperation("delete-messages-before") StoreOperationEnqueueMessageToDLQ = storeOperation("enqueue-message-to-dlq") StoreOperationReadMessagesFromDLQ = storeOperation("read-messages-from-dlq") StoreOperationRangeDeleteMessagesFromDLQ = storeOperation("range-delete-messages-from-dlq") StoreOperationUpdateDLQAckLevel = storeOperation("update-dlq-ack-level") StoreOperationGetDLQAckLevels = storeOperation("get-dlq-ack-levels") StoreOperationGetDLQSize = storeOperation("get-dlq-size") StoreOperationDeleteMessageFromDLQ = storeOperation("delete-message-from-dlq") StoreOperationFetchDynamicConfig = storeOperation("fetch-dynamic-config") StoreOperationUpdateDynamicConfig = storeOperation("update-dynamic-config") )
Pre-defined values for TagSysStoreOperation
var ( AdminClientOperationAddSearchAttribute = clientOperation("admin-add-search-attribute") AdminClientOperationDescribeHistoryHost = clientOperation("admin-describe-history-host") AdminClientOperationDescribeShardDistribution = clientOperation("admin-shard-list") AdminClientOperationRemoveTask = clientOperation("admin-remove-task") AdminClientOperationCloseShard = clientOperation("admin-close-shard") AdminClientOperationResetQueue = clientOperation("admin-reset-queue") AdminClientOperationDescribeQueue = clientOperation("admin-describe-queue") AdminClientOperationDescribeWorkflowExecution = clientOperation("admin-describe-wf-execution") AdminClientOperationGetWorkflowExecutionRawHistoryV2 = clientOperation("admin-get-wf-execution-raw-history-v2") AdminClientOperationDescribeCluster = clientOperation("admin-describe-cluster") AdminClientOperationGetReplicationMessages = clientOperation("admin-get-replication-messsages") AdminClientOperationGetDomainReplicationMessages = clientOperation("admin-get-domain-replication-messsages") AdminClientOperationGetDLQReplicationMessages = clientOperation("admin-get-dlq-replication-messsages") AdminClientOperationReapplyEvents = clientOperation("admin-reapply-events") AdminClientOperationCountDLQMessages = clientOperation("admin-count-dlq-messsages") AdminClientOperationReadDLQMessages = clientOperation("admin-read-dlq-messsages") AdminClientOperationPurgeDLQMessages = clientOperation("admin-purge-dlq-messsages") AdminClientOperationMergeDLQMessages = clientOperation("admin-merge-dlq-messsages") AdminClientOperationRefreshWorkflowTasks = clientOperation("admin-refresh-wf-tasks") AdminClientOperationResendReplicationTasks = clientOperation("admin-resend-replication-tasks") AdminClientOperationGetCrossClusterTasks = clientOperation("admin-get-cross-cluster-tasks") AdminClientOperationRespondCrossClusterTasksCompleted = clientOperation("admin-respond-cross-cluster-tasks-completed") AdminClientOperationGetDynamicConfig = clientOperation("admin-get-dynamic-config") AdminClientOperationUpdateDynamicConfig = clientOperation("admin-update-dynamic-config") AdminClientOperationRestoreDynamicConfig = clientOperation("admin-restore-dynamic-config") AdminClientOperationListDynamicConfig = clientOperation("admin-list-dynamic-config") AdminClientOperationUpdateGlobalIsolationGroups = clientOperation("admin-update-global-isolation-groups") AdminClientOperationGetGlobalIsolationGroups = clientOperation("admin-get-global-isolation-groups") AdminClientOperationUpdateDomainIsolationGroups = clientOperation("admin-update-domain-isolation-groups") AdminClientOperationGetDomainIsolationGroups = clientOperation("admin-get-domain-isolation-groups") AdminDeleteWorkflow = clientOperation("admin-delete-workflow") MaintainCorruptWorkflow = clientOperation("maintain-corrupt-workflow") FrontendClientOperationDeprecateDomain = clientOperation("frontend-deprecate-domain") FrontendClientOperationDescribeDomain = clientOperation("frontend-describe-domain") FrontendClientOperationDescribeTaskList = clientOperation("frontend-describe-task-list") FrontendClientOperationDescribeWorkflowExecution = clientOperation("frontend-describe-wf-execution") FrontendClientOperationGetWorkflowExecutionHistory = clientOperation("frontend-get-wf-execution-history") FrontendClientOperationListArchivedWorkflowExecutions = clientOperation("frontend-list-archived-wf-executions") FrontendClientOperationListClosedWorkflowExecutions = clientOperation("frontend-list-closed-wf-executions") FrontendClientOperationListDomains = clientOperation("frontend-list-domains") FrontendClientOperationListOpenWorkflowExecutions = clientOperation("frontend-list-open-wf-executions") FrontendClientOperationListWorkflowExecutions = clientOperation("frontend-list-wf-executions") FrontendClientOperationScanWorkflowExecutions = clientOperation("frontend-scan-wf-executions") FrontendClientOperationCountWorkflowExecutions = clientOperation("frontend-count-wf-executions") FrontendClientOperationGetSearchAttributes = clientOperation("frontend-get-search-attributes") FrontendClientOperationPollForActivityTask = clientOperation("frontend-poll-for-activity-task") FrontendClientOperationPollForDecisionTask = clientOperation("frontend-poll-for-decision-task") FrontendClientOperationQueryWorkflow = clientOperation("frontend-query-workflow") FrontendClientOperationRecordActivityTaskHeartbeat = clientOperation("frontend-record-activity-heartbeat") FrontendClientOperationRecordActivityTaskHeartbeatByID = clientOperation("frontend-record-activity-heartbeat-by-id") FrontendClientOperationRegisterDomain = clientOperation("frontend-register-domain") FrontendClientOperationRequestCancelWorkflowExecution = clientOperation("frontend-request-cancel-wf-execution") FrontendClientOperationResetStickyTaskList = clientOperation("frontend-reset-sticky-task-list") FrontendClientOperationResetWorkflowExecution = clientOperation("frontend-reset-wf-execution") FrontendClientOperationRefreshWorkflowTasks = clientOperation("frontend-refresh-wf-tasks") FrontendClientOperationRespondActivityTaskCanceled = clientOperation("frontend-respond-activity-task-canceled") FrontendClientOperationRespondActivityTaskCanceledByID = clientOperation("frontend-respond-activity-task-canceled-by-id") FrontendClientOperationRespondActivityTaskCompleted = clientOperation("frontend-respond-activity-task-completed") FrontendClientOperationRespondActivityTaskCompletedByID = clientOperation("frontend-respond-activity-task-completed-by-id") FrontendClientOperationRespondActivityTaskFailed = clientOperation("frontend-respond-activity-task-failed") FrontendClientOperationRespondActivityTaskFailedByID = clientOperation("frontend-respond-activity-task-failed-by-id") FrontendClientOperationRespondDecisionTaskCompleted = clientOperation("frontend-respond-decision-task-completed") FrontendClientOperationRespondDecisionTaskFailed = clientOperation("frontend-respond-decision-task-failed") FrontendClientOperationRespondQueryTaskCompleted = clientOperation("frontend-respond-query-task-completed") FrontendClientOperationRestartWorkflowExecution = clientOperation("frontend-restart-wf-execution") FrontendClientOperationSignalWithStartWorkflowExecution = clientOperation("frontend-signal-with-start-wf-execution") FrontendClientOperationSignalWorkflowExecution = clientOperation("frontend-signal-wf-execution") FrontendClientOperationStartWorkflowExecution = clientOperation("frontend-start-wf-execution") FrontendClientOperationTerminateWorkflowExecution = clientOperation("frontend-terminate-wf-execution") FrontendClientOperationUpdateDomain = clientOperation("frontend-update-domain") FrontendClientOperationGetClusterInfo = clientOperation("frontend-get-cluster-info") FrontendClientOperationListTaskListPartitions = clientOperation("frontend-list-task-list-partitions") FrontendClientOperationGetTaskListsByDomain = clientOperation("frontend-get-task-list-for-domain") HistoryClientOperationStartWorkflowExecution = clientOperation("history-start-wf-execution") HistoryClientOperationDescribeHistoryHost = clientOperation("history-describe-history-host") HistoryClientOperationCloseShard = clientOperation("history-close-shard") HistoryClientOperationResetQueue = clientOperation("history-reset-queue") HistoryClientOperationDescribeQueue = clientOperation("history-describe-queue") HistoryClientOperationRemoveTask = clientOperation("history-remove-task") HistoryClientOperationDescribeMutableState = clientOperation("history-describe-mutable-state") HistoryClientOperationGetMutableState = clientOperation("history-get-mutable-state") HistoryClientOperationPollMutableState = clientOperation("history-poll-mutable-state") HistoryClientOperationResetStickyTaskList = clientOperation("history-reset-task-list") HistoryClientOperationDescribeWorkflowExecution = clientOperation("history-describe-wf-execution") HistoryClientOperationRecordDecisionTaskStarted = clientOperation("history-record-decision-task-started") HistoryClientOperationRecordActivityTaskStarted = clientOperation("history-record-activity-task-started") HistoryClientOperationRecordDecisionTaskCompleted = clientOperation("history-record-decision-task-completed") HistoryClientOperationRecordDecisionTaskFailed = clientOperation("history-record-decision-task-failed") HistoryClientOperationRecordActivityTaskCompleted = clientOperation("history-record-activity-task-completed") HistoryClientOperationRecordActivityTaskFailed = clientOperation("history-record-activity-task-failed") HistoryClientOperationRecordActivityTaskCanceled = clientOperation("history-record-activity-task-canceled") HistoryClientOperationRecordActivityTaskHeartbeat = clientOperation("history-record-activity-task-heartbeat") HistoryClientOperationRequestCancelWorkflowExecution = clientOperation("history-request-cancel-wf-execution") HistoryClientOperationSignalWorkflowExecution = clientOperation("history-signal-wf-execution") HistoryClientOperationSignalWithStartWorkflowExecution = clientOperation("history-signal-with-start-wf-execution") HistoryClientOperationRemoveSignalMutableState = clientOperation("history-remove-signal-mutable-state") HistoryClientOperationTerminateWorkflowExecution = clientOperation("history-terminate-wf-execution") HistoryClientOperationResetWorkflowExecution = clientOperation("history-reset-wf-execution") HistoryClientOperationScheduleDecisionTask = clientOperation("history-schedule-decision-task") HistoryClientOperationRecordChildExecutionCompleted = clientOperation("history-record-child-execution-completed") HistoryClientOperationReplicateEventsV2 = clientOperation("history-replicate-events-v2") HistoryClientOperationSyncShardStatus = clientOperation("history-sync-shard-status") HistoryClientOperationSyncActivity = clientOperation("history-sync-activity") HistoryClientOperationGetReplicationMessages = clientOperation("history-get-replication-messages") HistoryClientOperationGetDLQReplicationMessages = clientOperation("history-get-dlq-replication-messages") HistoryClientOperationQueryWorkflow = clientOperation("history-query-wf") HistoryClientOperationReapplyEvents = clientOperation("history-reapply-events") HistoryClientOperationCountDLQMessages = clientOperation("history-count-dlq-messages") HistoryClientOperationReadDLQMessages = clientOperation("history-read-dlq-messages") HistoryClientOperationPurgeDLQMessages = clientOperation("history-purge-dlq-messages") HistoryClientOperationMergeDLQMessages = clientOperation("history-merge-dlq-messages") HistoryClientOperationRefreshWorkflowTasks = clientOperation("history-refresh-wf-tasks") HistoryClientOperationNotifyFailoverMarkers = clientOperation("history-notify-failover-markers") HistoryClientOperationGetCrossClusterTasks = clientOperation("history-get-cross-cluster-tasks") HistoryClientOperationRespondCrossClusterTasksCompleted = clientOperation("history-respond-cross-cluster-tasks-completed") HistoryClientOperationGetFailoverInfo = clientOperation("history-get-failover-info") MatchingClientOperationAddActivityTask = clientOperation("matching-add-activity-task") MatchingClientOperationAddDecisionTask = clientOperation("matching-add-decision-task") MatchingClientOperationPollForActivityTask = clientOperation("matching-poll-for-activity-task") MatchingClientOperationPollForDecisionTask = clientOperation("matching-poll-for-decision-task") MatchingClientOperationQueryWorkflow = clientOperation("matching-query-wf") MatchingClientOperationQueryTaskCompleted = clientOperation("matching-query-task-completed") MatchingClientOperationCancelOutstandingPoll = clientOperation("matching-cancel-outstanding-poll") MatchingClientOperationDescribeTaskList = clientOperation("matching-describe-task-list") MatchingClientOperationListTaskListPartitions = clientOperation("matching-list-task-list-partitions") MatchingClientOperationGetTaskListsByDomain = clientOperation("get-task-list-for-domain") )
Pre-defined values for TagSysClientOperation
var ( IDTypeDomainName = idType("domainName") IDTypeIdentity = idType("identity") IDTypeWorkflowID = idType("workflowID") IDTypeSignalName = idType("signalName") IDTypeWorkflowType = idType("workflowType") IDTypeRequestID = idType("requestID") IDTypeTaskListName = idType("taskListName") IDTypeActivityID = idType("activityID") IDTypeActivityType = idType("activityType") IDTypeMarkerName = idType("markerName") IDTypeTimerID = idType("timerID") )
Pre-defined values for TagIDType
Functions ¶
This section is empty.
Types ¶
type Tag ¶
type Tag struct {
// contains filtered or unexported fields
}
Tag is the interface for logging system
func ActorEmail ¶ added in v1.2.1
ActorEmail returns tag for the actor's email address
func ArchivalArchiveAttemptedInline ¶ added in v0.8.0
ArchivalArchiveAttemptedInline returns tag for whether archival is attempted inline before signal is sent.
func ArchivalArchiveFailReason ¶ added in v0.6.0
ArchivalArchiveFailReason returns tag for ArchivalArchiveFailReason
func ArchivalBlobIntegrityCheckFailReason ¶ added in v0.5.9
ArchivalBlobIntegrityCheckFailReason returns tag for ArchivalBlobIntegrityCheckFailReason
func ArchivalBlobKey ¶
ArchivalBlobKey returns tag for BlobKey
func ArchivalBlobstoreContextTimeout ¶ added in v0.10.1
ArchivalBlobstoreContextTimeout returns tag for ArchivalBlobstoreContextTimeout
func ArchivalCallerServiceName ¶ added in v0.7.0
ArchivalCallerServiceName returns tag for the service name calling archival client
func ArchivalDeleteHistoryFailReason ¶ added in v0.5.9
ArchivalDeleteHistoryFailReason returns tag for ArchivalDeleteHistoryFailReason
func ArchivalDeterministicConstructionCheckFailReason ¶ added in v0.5.9
func ArchivalDeterministicConstructionCheckFailReason(deterministicConstructionCheckFailReason string) Tag
ArchivalDeterministicConstructionCheckFailReason returns tag for ArchivalDeterministicConstructionCheckFailReason
func ArchivalNonDeterministicBlobKey ¶ added in v0.5.9
ArchivalNonDeterministicBlobKey returns tag for randomly generated NonDeterministicBlobKey
func ArchivalRequestBranchToken ¶
ArchivalRequestBranchToken returns tag for RequestBranchToken
func ArchivalRequestCloseFailoverVersion ¶
ArchivalRequestCloseFailoverVersion returns tag for RequestCloseFailoverVersion
func ArchivalRequestCloseStatus ¶ added in v0.9.0
ArchivalRequestCloseStatus returns tag for RequestCloseStatus
func ArchivalRequestCloseTimestamp ¶ added in v0.9.0
ArchivalRequestCloseTimestamp returns tag for RequestCloseTimestamp
func ArchivalRequestDomainID ¶
ArchivalRequestDomainID returns tag for RequestDomainID
func ArchivalRequestDomainName ¶ added in v0.5.9
ArchivalRequestDomainName returns tag for RequestDomainName
func ArchivalRequestNextEventID ¶
ArchivalRequestNextEventID returns tag for RequestNextEventID
func ArchivalRequestRunID ¶
ArchivalRequestRunID returns tag for RequestRunID
func ArchivalRequestWorkflowID ¶
ArchivalRequestWorkflowID returns tag for RequestWorkflowID
func ArchivalURI ¶ added in v0.6.0
ArchivalURI returns tag for Archival URI
func ArchivalVisibilityQuery ¶ added in v0.11.0
ArchivalVisibilityQuery returns tag for the query for getting archived visibility record
func ArchvialRequestWorkflowType ¶ added in v0.9.0
ArchvialRequestWorkflowType returns tag for RequestWorkflowType
func AttemptCount ¶
AttemptCount returns tag for AttemptCount
func AttemptStart ¶
AttemptStart returns tag for AttemptStart
func BlobSizeViolationOperation ¶ added in v0.12.0
BlobSizeViolationOperation returns tag for BlobSizeViolationOperation
func ClientError ¶ added in v0.18.0
ClientError returns tag for ClientError
func ClientFeatureVersion ¶ added in v1.2.1
ClientFeatureVersion returns tag for ClientFeatureVersion
func ClientImpl ¶ added in v1.2.1
ClientImpl returns tag for ClientImpl
func CurrentVersion ¶
CurrentVersion returns tag for CurrentVersion
func CursorTimestamp ¶
CursorTimestamp returns tag for CursorTimestamp
func Dynamic ¶ added in v1.0.0
Dynamic Uses reflection based logging for arbitrary values for not very performant logging
func ESAggregationID ¶ added in v0.24.0
ESAggregationID returns tag for ESDocID
func ESResponseError ¶
ESResponseError returns tag for ESResponse error
func ESResponseStatus ¶
ESResponseStatus returns tag for ESResponse status
func FailoverVersion ¶
FailoverVersion returns tag for Version
func FallbackIsolationGroup ¶ added in v1.2.1
func FirstEventVersion ¶
FirstEventVersion returns tag for FirstEventVersion
func HandlerCall ¶ added in v1.0.0
HandlerCall returns tag for the API name of a request
func IncomingVersion ¶
IncomingVersion returns tag for IncomingVersion
func IsolationGroup ¶ added in v1.2.1
func KafkaConsumerName ¶
KafkaConsumerName returns tag for ConsumerName
func KafkaPartition ¶
KafkaPartition returns tag for Partition
func KafkaPartitionKey ¶
func KafkaPartitionKey(partitionKey interface{}) Tag
KafkaPartitionKey returns tag for PartitionKey
func KafkaTopicName ¶
KafkaTopicName returns tag for TopicName
func LastEventVersion ¶
LastEventVersion returns tag for LastEventVersion
func NumberProcessed ¶
NumberProcessed returns tag for NumberProcessed
func OperationName ¶ added in v0.25.0
OperationName returns tag for OperationName
func PartitionConfig ¶ added in v1.2.1
func PollerGroups ¶ added in v1.2.1
func PollerGroupsConfiguration ¶ added in v1.2.1
func PollerGroupsConfiguration(pollers types.IsolationGroupConfiguration) Tag
func PrevActiveCluster ¶
PrevActiveCluster returns tag for PrevActiveCluster
func PreviousQueueLevel ¶ added in v0.14.0
PreviousQueueLevel returns tag for PreviousQueueLevel
func PreviousShardRangeID ¶
PreviousShardRangeID returns tag for PreviousShardRangeID
func QueueLevel ¶ added in v0.14.0
QueueLevel returns tag for QueueLevel
func QueueSplitPolicyType ¶ added in v0.14.0
QueueSplitPolicyType returns tag for QueueSplitPolicyType
func RemoteCluster ¶ added in v0.25.0
func ReplicationInfo ¶
func ReplicationInfo(replicationInfo interface{}) Tag
ReplicationInfo returns tag for ReplicationInfo
func RequestBody ¶ added in v1.2.1
RequestBody returns the tag for the API request body
func RequestCaller ¶ added in v1.0.0
RequestCaller returns tag for caller (the name of the service making this request)
func ResponseMaxSize ¶ added in v0.25.0
ResponseMaxSize returns tag for ResponseMaxSize
func ResponseSize ¶ added in v0.25.0
ResponseSize returns tag for ResponseSize
func ResponseTotalSize ¶ added in v0.25.0
ResponseTotalSize returns tag for ResponseTotalSize
func ScheduleAttempt ¶
ScheduleAttempt returns tag for ScheduleAttempt
func ShardCrossClusterAcks ¶ added in v0.24.0
func ShardCrossClusterAcks(shardCrossClusterAcks interface{}) Tag
ShardCrossClusterAcks returns tag for ShardCrossClusterAcks
func ShardReplicationAck ¶
ShardReplicationAck returns tag for ShardReplicationAck
func ShardReplicationToken ¶ added in v0.25.0
func ShardReplicationToken(token interface{}) Tag
ShardReplicationToken returns information about a particular replication request
func ShardTimerAcks ¶
func ShardTimerAcks(shardTimerAcks interface{}) Tag
ShardTimerAcks returns tag for ShardTimerAcks
func ShardTransferAcks ¶
func ShardTransferAcks(shardTransferAcks interface{}) Tag
ShardTransferAcks returns tag for ShardTransferAcks
func SourceCluster ¶
SourceCluster returns tag for SourceCluster
func StoreError ¶ added in v0.17.0
StoreError returns tag for StoreError
func StoreShard ¶ added in v1.2.1
StoreShard returns tag for StoreShard
func Subscriber ¶ added in v0.24.0
Subscriber returns tag for Subscriber
func SysStackTrace ¶
SysStackTrace returns tag for SysStackTrace
func TargetWorkflowDomainID ¶ added in v0.25.0
TargetWorkflowDomainID returns tag for target WorkflowDomainID
func TargetWorkflowID ¶ added in v0.25.0
TargetWorkflowID returns tag for target WorkflowID
func TargetWorkflowRunID ¶ added in v0.25.0
TargetWorkflowRunID returns tag for target WorkflowRunID
func TaskVisibilityTimestamp ¶ added in v0.12.0
TaskVisibilityTimestamp returns tag for task visibilityTimestamp
func TimerTaskStatus ¶
TimerTaskStatus returns tag for TimerTaskStatus
func TokenLastEventID ¶
TokenLastEventID returns tag for TokenLastEventID
func TokenLastEventVersion ¶
TokenLastEventVersion returns tag for TokenLastEventVersion
func ValueType ¶ added in v0.6.0
func ValueType(v interface{}) Tag
ValueType returns tag for ValueType
func VisibilityQuery ¶ added in v0.24.0
VisibilityQuery returns tag for the query for getting visibility records
func WorkflowActivityID ¶
WorkflowActivityID returns tag for WorkflowActivityID
func WorkflowBeginningRunID ¶
WorkflowBeginningRunID returns tag for WorkflowBeginningRunID
func WorkflowBinaryChecksum ¶ added in v0.5.8
WorkflowBinaryChecksum returns tag for WorkflowBinaryChecksum
func WorkflowBranchID ¶
WorkflowBranchID returns tag for WorkflowBranchID
func WorkflowCronSchedule ¶ added in v1.0.0
WorkflowCronSchedule returns a tag to report a workflow's cron schedule
func WorkflowDecisionFailCause ¶
WorkflowDecisionFailCause returns tag for WorkflowDecisionFailCause
func WorkflowDecisionTimeoutSeconds ¶
WorkflowDecisionTimeoutSeconds returns tag for WorkflowDecisionTimeoutSeconds
func WorkflowDecisionType ¶
WorkflowDecisionType returns tag for WorkflowDecisionType
func WorkflowDomainID ¶
WorkflowDomainID returns tag for WorkflowDomainID
func WorkflowDomainIDs ¶
func WorkflowDomainIDs(domainIDs interface{}) Tag
WorkflowDomainIDs returns tag for WorkflowDomainIDs
func WorkflowDomainName ¶
WorkflowDomainName returns tag for WorkflowDomainName
func WorkflowEndingRunID ¶
WorkflowEndingRunID returns tag for WorkflowEndingRunID
func WorkflowError ¶
WorkflowError returns tag for WorkflowError
func WorkflowEventCount ¶
WorkflowEventCount returns tag for EventCount
func WorkflowEventID ¶
WorkflowEventID returns tag for WorkflowEventID
func WorkflowEventType ¶ added in v0.25.0
func WorkflowFirstEventID ¶
WorkflowFirstEventID returns tag for WorkflowFirstEventID
func WorkflowHandlerName ¶
WorkflowHandlerName returns tag for WorkflowHandlerName
func WorkflowHistorySize ¶
WorkflowHistorySize returns tag for HistorySize
func WorkflowHistorySizeBytes ¶
WorkflowHistorySizeBytes returns tag for HistorySizeBytes
func WorkflowInitiatedID ¶
WorkflowInitiatedID returns tag for WorkflowInitiatedID
func WorkflowNextEventID ¶
WorkflowNextEventID returns tag for WorkflowNextEventID
func WorkflowPollContextTimeout ¶
WorkflowPollContextTimeout returns tag for WorkflowPollContextTimeout
func WorkflowQueryType ¶
WorkflowQueryType returns tag for WorkflowQueryType
func WorkflowResetBaseRunID ¶ added in v0.5.8
WorkflowResetBaseRunID returns tag for WorkflowResetBaseRunID
func WorkflowResetNewRunID ¶ added in v0.5.8
WorkflowResetNewRunID returns tag for WorkflowResetNewRunID
func WorkflowResetNextEventID ¶
WorkflowResetNextEventID returns tag for WorkflowResetNextEventID
func WorkflowRunID ¶
WorkflowRunID returns tag for WorkflowRunID
func WorkflowScheduleID ¶
WorkflowScheduleID returns tag for WorkflowScheduleID
func WorkflowSignalCount ¶
WorkflowSignalCount returns tag for SignalCount
func WorkflowSize ¶
WorkflowSize returns tag for WorkflowSize
func WorkflowStartedID ¶
WorkflowStartedID returns tag for WorkflowStartedID
func WorkflowTaskListKind ¶ added in v0.18.0
WorkflowTaskListKind returns tag for WorkflowTaskListKind
func WorkflowTaskListName ¶
WorkflowTaskListName returns tag for WorkflowTaskListName
func WorkflowTaskListType ¶
WorkflowTaskListType returns tag for WorkflowTaskListType
func WorkflowTimeoutType ¶
WorkflowTimeoutType returns tag for WorkflowTimeoutType
func WorkflowTimerID ¶
WorkflowTimerID returns tag for WorkflowTimerID
func WorkflowTreeID ¶
WorkflowTreeID returns tag for WorkflowTreeID