tag

package
v1.2.14-prerelease04 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2024 License: MIT Imports: 5 Imported by: 33

Documentation

Index

Constants

View Source 
const LoggingCallAtKey = "logging-call-at"

LoggingCallAtKey is reserved tag

Variables

View Source 
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

View Source 
var (
	WorkflowListWorkflowFilterByID     = workflowListFilterType("WID")
	WorkflowListWorkflowFilterByType   = workflowListFilterType("WType")
	WorkflowListWorkflowFilterByStatus = workflowListFilterType("status")
)

Pre-defined values for TagWorkflowListFilterType

View Source 
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")
	ComponentAsyncWFConsumptionManager  = component("async-wf-consumption-manager")
	ComponentGlobalRatelimiter          = component("global-ratelimiter")
	ComponentMapQ                       = component("mapq")
	ComponentMapQTree                   = component("mapq-tree")
	ComponentMapQTreeNode               = component("mapq-tree-node")
)

Pre-defined values for TagSysComponent

View Source 
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

View Source 
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

View Source 
var (
	// Shard context events
	ValueShardRangeUpdated            = shardupdate("ShardRangeUpdated")
	ValueShardAllocateTimerBeforeRead = shardupdate("ShardAllocateTimerBeforeRead")
	ValueRingMembershipChangedEvent   = shardupdate("RingMembershipChangedEvent")
)

Pre-defined values for SysShardUpdate

View Source 
var (
	OperationFailed   = operationResult("OperationFailed")
	OperationStuck    = operationResult("OperationStuck")
	OperationCritical = operationResult("OperationCritical")
)

Pre-defined values for OperationResult

View Source 
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")
	StoreOperationGetOrphanTasks        = storeOperation("get-orphan-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")
	StoreOperationGetTaskListSize       = storeOperation("get-task-list-size")
	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")
	StoreOperationDeleteUninitializedWorkflowExecution     = storeOperation("delete-uninitialized-wf-execution")
	StoreOperationRecordWorkflowExecutionUninitialized     = storeOperation("record-wf-execution-uninitialized")

	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

View Source 
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")
	AdminClientOperationDeleteWorkflow                        = clientOperation("admin-delete-workflow")
	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")
	AdminClientOperationMaintainCorruptWorkflow               = clientOperation("admin-maintain-corrupt-workflow")
	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")
	AdminClientOperationGetDomainAsyncWorkflowConfiguraton    = clientOperation("admin-get-domain-async-workflow-configuration")
	AdminClientOperationUpdateDomainAsyncWorkflowConfiguraton = clientOperation("admin-update-domain-async-workflow-configuration")
	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")
	FrontendClientOperationDiagnoseWorkflowExecution             = clientOperation("frontend-diagnose-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")
	FrontendClientOperationSignalWithStartWorkflowExecutionAsync = clientOperation("frontend-signal-with-start-wf-execution-async")
	FrontendClientOperationSignalWorkflowExecution               = clientOperation("frontend-signal-wf-execution")
	FrontendClientOperationStartWorkflowExecution                = clientOperation("frontend-start-wf-execution")
	FrontendClientOperationStartWorkflowExecutionAsync           = clientOperation("frontend-start-wf-execution-async")
	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")
	HistoryClientOperationRespondActivityTaskCanceled       = clientOperation("history-respond-activity-task-canceled")
	HistoryClientOperationRespondActivityTaskCompleted      = clientOperation("history-respond-activity-task-completed")
	HistoryClientOperationRespondActivityTaskFailed         = clientOperation("history-respond-activity-task-failed")
	HistoryClientOperationRespondDecisionTaskCompleted      = clientOperation("history-respond-decision-task-completed")
	HistoryClientOperationRespondDecisionTaskFailed         = clientOperation("history-respond-decision-task-failed")
	HistoryClientOperationRatelimitUpdate                   = clientOperation("history-ratelimit-update")

	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("matching-get-task-list-for-domain")
	MatchingClientOperationRespondQueryTaskCompleted = clientOperation("matching-respond-query-task-completed")
)

Pre-defined values for TagSysClientOperation

View Source 
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 ActivityTimeoutType added in v1.2.12 

func ActivityTimeoutType(timerType shared.TimeoutType) Tag

ActivityTimeoutType returns tag for ActivityTimeoutType

func ActorEmail added in v1.2.1 

func ActorEmail(actorEmail string) Tag

ActorEmail returns tag for the actor's email address

func ActorID added in v1.0.0 

func ActorID(actorID string) Tag

ActorID returns tag for the actor ID

func Address 

func Address(ad string) Tag

Address return tag for Address

func Addresses 

func Addresses(ads []string) Tag

Addresses returns tag for Addresses

func ArchivalArchiveAttemptedInline added in v0.8.0 

func ArchivalArchiveAttemptedInline(archiveInline bool) Tag

ArchivalArchiveAttemptedInline returns tag for whether archival is attempted inline before signal is sent.

func ArchivalArchiveFailReason added in v0.6.0 

func ArchivalArchiveFailReason(archiveFailReason string) Tag

ArchivalArchiveFailReason returns tag for ArchivalArchiveFailReason

func ArchivalBlobIntegrityCheckFailReason added in v0.5.9 

func ArchivalBlobIntegrityCheckFailReason(blobIntegrityCheckFailReason string) Tag

ArchivalBlobIntegrityCheckFailReason returns tag for ArchivalBlobIntegrityCheckFailReason

func ArchivalBlobKey 

func ArchivalBlobKey(blobKey string) Tag

ArchivalBlobKey returns tag for BlobKey

func ArchivalBlobstoreContextTimeout added in v0.10.1 

func ArchivalBlobstoreContextTimeout(blobstoreContextTimeout time.Duration) Tag

ArchivalBlobstoreContextTimeout returns tag for ArchivalBlobstoreContextTimeout

func ArchivalCallerServiceName added in v0.7.0 

func ArchivalCallerServiceName(callerServiceName string) Tag

ArchivalCallerServiceName returns tag for the service name calling archival client

func ArchivalDeleteHistoryFailReason added in v0.5.9 

func ArchivalDeleteHistoryFailReason(deleteHistoryFailReason string) Tag

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 

func ArchivalNonDeterministicBlobKey(nondeterministicBlobKey string) Tag

ArchivalNonDeterministicBlobKey returns tag for randomly generated NonDeterministicBlobKey

func ArchivalRequestBranchToken 

func ArchivalRequestBranchToken(requestBranchToken []byte) Tag

ArchivalRequestBranchToken returns tag for RequestBranchToken

func ArchivalRequestCloseFailoverVersion 

func ArchivalRequestCloseFailoverVersion(requestCloseFailoverVersion int64) Tag

ArchivalRequestCloseFailoverVersion returns tag for RequestCloseFailoverVersion

func ArchivalRequestCloseStatus added in v0.9.0 

func ArchivalRequestCloseStatus(requestCloseStatus string) Tag

ArchivalRequestCloseStatus returns tag for RequestCloseStatus

func ArchivalRequestCloseTimestamp added in v0.9.0 

func ArchivalRequestCloseTimestamp(requestCloseTimeStamp int64) Tag

ArchivalRequestCloseTimestamp returns tag for RequestCloseTimestamp

func ArchivalRequestDomainID 

func ArchivalRequestDomainID(requestDomainID string) Tag

ArchivalRequestDomainID returns tag for RequestDomainID

func ArchivalRequestDomainName added in v0.5.9 

func ArchivalRequestDomainName(requestDomainName string) Tag

ArchivalRequestDomainName returns tag for RequestDomainName

func ArchivalRequestNextEventID 

func ArchivalRequestNextEventID(requestNextEventID int64) Tag

ArchivalRequestNextEventID returns tag for RequestNextEventID

func ArchivalRequestRunID 

func ArchivalRequestRunID(requestRunID string) Tag

ArchivalRequestRunID returns tag for RequestRunID

func ArchivalRequestWorkflowID 

func ArchivalRequestWorkflowID(requestWorkflowID string) Tag

ArchivalRequestWorkflowID returns tag for RequestWorkflowID

func ArchivalURI added in v0.6.0 

func ArchivalURI(URI string) Tag

ArchivalURI returns tag for Archival URI

func ArchivalVisibilityQuery added in v0.11.0 

func ArchivalVisibilityQuery(query string) Tag

ArchivalVisibilityQuery returns tag for the query for getting archived visibility record

func ArchvialRequestWorkflowType added in v0.9.0 

func ArchvialRequestWorkflowType(requestWorkflowType string) Tag

ArchvialRequestWorkflowType returns tag for RequestWorkflowType

func AsyncWFQueueID added in v1.2.8 

func AsyncWFQueueID(queueID string) Tag

func Attempt 

func Attempt(attempt int32) Tag

Attempt returns tag for Attempt

func AttemptCount 

func AttemptCount(attemptCount int) Tag

AttemptCount returns tag for AttemptCount

func AttemptEnd 

func AttemptEnd(attemptEnd time.Time) Tag

AttemptEnd returns tag for AttemptEnd

func AttemptStart 

func AttemptStart(attemptStart time.Time) Tag

AttemptStart returns tag for AttemptStart

func BlobSizeViolationOperation added in v0.12.0 

func BlobSizeViolationOperation(operation string) Tag

BlobSizeViolationOperation returns tag for BlobSizeViolationOperation

func Bool 

func Bool(b bool) Tag

Bool returns tag for Bool

func ClientError added in v0.18.0 

func ClientError(clientErr error) Tag

ClientError returns tag for ClientError

func ClientFeatureVersion added in v1.2.1 

func ClientFeatureVersion(clientFeatureVersion string) Tag

ClientFeatureVersion returns tag for ClientFeatureVersion

func ClientImpl added in v1.2.1 

func ClientImpl(clientImpl string) Tag

ClientImpl returns tag for ClientImpl

func ClusterName 

func ClusterName(clusterName string) Tag

ClusterName returns tag for ClusterName

func Counter 

func Counter(c int) Tag

Counter returns tag for Counter

func CurrentVersion 

func CurrentVersion(currentVersion int64) Tag

CurrentVersion returns tag for CurrentVersion

func CursorTimestamp 

func CursorTimestamp(timestamp time.Time) Tag

CursorTimestamp returns tag for CursorTimestamp

func DefaultValue 

func DefaultValue(v interface{}) Tag

DefaultValue returns tag for DefaultValue

func DetailInfo 

func DetailInfo(i string) Tag

DetailInfo returns tag for DetailInfo

func Dynamic added in v1.0.0 

func Dynamic(key string, v interface{}) Tag

Dynamic Uses reflection based logging for arbitrary values for not very performant logging

func ESAggregationID added in v0.24.0 

func ESAggregationID(id string) Tag

ESAggregationID returns tag for ESDocID

func ESConfig 

func ESConfig(c interface{}) Tag

ESConfig returns tag for ESConfig

func ESDocID 

func ESDocID(id string) Tag

ESDocID returns tag for ESDocID

func ESField 

func ESField(ESField string) Tag

ESField returns tag for ESField

func ESKey 

func ESKey(ESKey string) Tag

ESKey returns tag for ESKey

func ESRequest 

func ESRequest(ESRequest string) Tag

ESRequest returns tag for ESRequest

func ESResponseError 

func ESResponseError(msg string) Tag

ESResponseError returns tag for ESResponse error

func ESResponseStatus 

func ESResponseStatus(status int) Tag

ESResponseStatus returns tag for ESResponse status

func ESValue added in v0.12.0 

func ESValue(ESValue []byte) Tag

ESValue returns tag for ESValue

func EarliestTime added in v1.2.8 

func EarliestTime(time int64) Tag

func Env added in v0.12.0 

func Env(env string) Tag

Env return tag for runtime environment

func Error 

func Error(err error) Tag

Error returns tag for Error

func FailoverMsg 

func FailoverMsg(failoverMsg string) Tag

FailoverMsg returns tag for FailoverMsg

func FailoverVersion 

func FailoverVersion(version int64) Tag

FailoverVersion returns tag for Version

func FallbackIsolationGroup added in v1.2.1 

func FallbackIsolationGroup(group string) Tag

func FirstEventVersion 

func FirstEventVersion(version int64) Tag

FirstEventVersion returns tag for FirstEventVersion

func GlobalRatelimiterCollectionName added in v1.2.12 

func GlobalRatelimiterCollectionName(name string) Tag

func GlobalRatelimiterIdleCount added in v1.2.12 

func GlobalRatelimiterIdleCount(count int) Tag

func GlobalRatelimiterKey added in v1.2.12 

func GlobalRatelimiterKey(globalKey string) Tag

func GlobalRatelimiterKeyMode added in v1.2.12 

func GlobalRatelimiterKeyMode(mode string) Tag

func GlobalRatelimiterPeer added in v1.2.12 

func GlobalRatelimiterPeer(peer string) Tag

func HandlerCall added in v1.0.0 

func HandlerCall(handlerCall string) Tag

HandlerCall returns tag for the API name of a request

func IncomingVersion 

func IncomingVersion(incomingVersion int64) Tag

IncomingVersion returns tag for IncomingVersion

func IsWorkflowOpen added in v1.2.6 

func IsWorkflowOpen(isOpen bool) Tag

IsWorkflowOpen returns a tag to report a workflow is open or not

func IsolationGroup added in v1.2.1 

func IsolationGroup(group string) Tag

func KafkaConsumerName 

func KafkaConsumerName(consumerName string) Tag

KafkaConsumerName returns tag for ConsumerName

func KafkaOffset 

func KafkaOffset(offset int64) Tag

KafkaOffset returns tag for Offset

func KafkaPartition 

func KafkaPartition(partition int32) Tag

KafkaPartition returns tag for Partition

func KafkaPartitionKey 

func KafkaPartitionKey(partitionKey interface{}) Tag

KafkaPartitionKey returns tag for PartitionKey

func KafkaTopicName 

func KafkaTopicName(topicName string) Tag

KafkaTopicName returns tag for TopicName

func Key 

func Key(k string) Tag

Key returns tag for Key

func LastEventVersion 

func LastEventVersion(version int64) Tag

LastEventVersion returns tag for LastEventVersion

func LatestTime added in v1.2.8 

func LatestTime(time int64) Tag

func MaxLevel 

func MaxLevel(lv int64) Tag

MaxLevel returns tag for MaxLevel

func MembershipChangeEvent added in v1.2.13 

func MembershipChangeEvent(event interface{}) Tag

MembershipChangeEvent is a predefined tag for when logging hashring change events, expected to be of type membership.ChangeEvent

func MetricScope 

func MetricScope(metricScope int) Tag

MetricScope returns tag for MetricScope

func MinLevel 

func MinLevel(lv int64) Tag

MinLevel returns tag for MinLevel

func Name 

func Name(k string) Tag

Name returns tag for Name

func NextNumber 

func NextNumber(n int64) Tag

NextNumber returns tag for NextNumber

func Number 

func Number(n int64) Tag

Number returns tag for Number

func NumberDeleted 

func NumberDeleted(n int) Tag

NumberDeleted returns tag for NumberDeleted

func NumberProcessed 

func NumberProcessed(n int) Tag

NumberProcessed returns tag for NumberProcessed

func OperationName added in v0.25.0 

func OperationName(operationName string) Tag

OperationName returns tag for OperationName

func PartitionConfig added in v1.2.1 

func PartitionConfig(p map[string]string) Tag

func PollerGroups added in v1.2.1 

func PollerGroups(pollers []string) Tag

func PollerGroupsConfiguration added in v1.2.1 

func PollerGroupsConfiguration(pollers types.IsolationGroupConfiguration) Tag

func Port 

func Port(p int) Tag

Port returns tag for Port

func PrevActiveCluster 

func PrevActiveCluster(prevActiveCluster string) Tag

PrevActiveCluster returns tag for PrevActiveCluster

func PreviousQueueLevel added in v0.14.0 

func PreviousQueueLevel(level int) Tag

PreviousQueueLevel returns tag for PreviousQueueLevel

func PreviousShardRangeID 

func PreviousShardRangeID(id int64) Tag

PreviousShardRangeID returns tag for PreviousShardRangeID

func QueryID added in v0.11.0 

func QueryID(queryID string) Tag

QueryID returns tag for QueryID

func QueueLevel added in v0.14.0 

func QueueLevel(level int) Tag

QueueLevel returns tag for QueueLevel

func QueueSplitPolicyType added in v0.14.0 

func QueueSplitPolicyType(policyType int) Tag

QueueSplitPolicyType returns tag for QueueSplitPolicyType

func ReadLevel 

func ReadLevel(lv int64) Tag

ReadLevel returns tag for ReadLevel

func RemoteCluster added in v0.25.0 

func RemoteCluster(remoteCluster string) Tag

func ReplicationInfo 

func ReplicationInfo(replicationInfo interface{}) Tag

ReplicationInfo returns tag for ReplicationInfo

func RequestBody added in v1.2.1 

func RequestBody(requestBody string) Tag

RequestBody returns the tag for the API request body

func RequestCaller added in v1.0.0 

func RequestCaller(callerName string) Tag

RequestCaller returns tag for caller (the name of the service making this request)

func RequestType added in v1.2.8 

func RequestType(requestType string) Tag

RequestType return tag for the type of request (internal, external)

func ResponseMaxSize added in v0.25.0 

func ResponseMaxSize(size int) Tag

ResponseMaxSize returns tag for ResponseMaxSize

func ResponseSize added in v0.25.0 

func ResponseSize(size int) Tag

ResponseSize returns tag for ResponseSize

func ResponseTotalSize added in v0.25.0 

func ResponseTotalSize(size int) Tag

ResponseTotalSize returns tag for ResponseTotalSize

func ScheduleAttempt 

func ScheduleAttempt(scheduleAttempt int64) Tag

ScheduleAttempt returns tag for ScheduleAttempt

func Service 

func Service(sv string) Tag

Service returns tag for Service

func ShardCrossClusterAcks added in v0.24.0 

func ShardCrossClusterAcks(shardCrossClusterAcks interface{}) Tag

ShardCrossClusterAcks returns tag for ShardCrossClusterAcks

func ShardID 

func ShardID(shardID int) Tag

ShardID returns tag for ShardID

func ShardRangeID 

func ShardRangeID(id int64) Tag

ShardRangeID returns tag for ShardRangeID

func ShardReplicationAck 

func ShardReplicationAck(shardReplicationAck int64) Tag

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 ShardTime 

func ShardTime(shardTime interface{}) Tag

ShardTime returns tag for ShardTime

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 

func SourceCluster(sourceCluster string) Tag

SourceCluster returns tag for SourceCluster

func StoreError added in v0.17.0 

func StoreError(storeErr error) Tag

StoreError returns tag for StoreError

func StoreShard added in v1.2.1 

func StoreShard(storeShard string) Tag

StoreShard returns tag for StoreShard

func StoreType 

func StoreType(storeType string) Tag

StoreType returns tag for StoreType

func Subscriber added in v0.24.0 

func Subscriber(subscriber string) Tag

Subscriber returns tag for Subscriber

func SysStackTrace 

func SysStackTrace(stackTrace string) Tag

SysStackTrace returns tag for SysStackTrace

func TargetWorkflowDomainID added in v0.25.0 

func TargetWorkflowDomainID(domainID string) Tag

TargetWorkflowDomainID returns tag for target WorkflowDomainID

func TargetWorkflowID added in v0.25.0 

func TargetWorkflowID(workflowID string) Tag

TargetWorkflowID returns tag for target WorkflowID

func TargetWorkflowRunID added in v0.25.0 

func TargetWorkflowRunID(runID string) Tag

TargetWorkflowRunID returns tag for target WorkflowRunID

func TaskID 

func TaskID(taskID int64) Tag

TaskID returns tag for TaskID

func TaskType 

func TaskType(taskType int) Tag

TaskType returns tag for TaskType for queue processor

func TaskVisibilityTimestamp added in v0.12.0 

func TaskVisibilityTimestamp(timestamp int64) Tag

TaskVisibilityTimestamp returns tag for task visibilityTimestamp

func TimerTaskStatus 

func TimerTaskStatus(timerTaskStatus int32) Tag

TimerTaskStatus returns tag for TimerTaskStatus

func Timestamp 

func Timestamp(timestamp time.Time) Tag

Timestamp returns tag for Timestamp

func TokenLastEventID 

func TokenLastEventID(id int64) Tag

TokenLastEventID returns tag for TokenLastEventID

func TokenLastEventVersion 

func TokenLastEventVersion(version int64) Tag

TokenLastEventVersion returns tag for TokenLastEventVersion

func Value 

func Value(v interface{}) Tag

Value returns tag for Value

func ValueType added in v0.6.0 

func ValueType(v interface{}) Tag

ValueType returns tag for ValueType

func VisibilityQuery added in v0.24.0 

func VisibilityQuery(query string) Tag

VisibilityQuery returns tag for the query for getting visibility records

func WorkflowActivityID 

func WorkflowActivityID(id string) Tag

WorkflowActivityID returns tag for WorkflowActivityID

func WorkflowBeginningRunID 

func WorkflowBeginningRunID(beginningRunID string) Tag

WorkflowBeginningRunID returns tag for WorkflowBeginningRunID

func WorkflowBinaryChecksum added in v0.5.8 

func WorkflowBinaryChecksum(cs string) Tag

WorkflowBinaryChecksum returns tag for WorkflowBinaryChecksum

func WorkflowBranchID 

func WorkflowBranchID(branchID string) Tag

WorkflowBranchID returns tag for WorkflowBranchID

func WorkflowCloseStatus added in v1.2.6 

func WorkflowCloseStatus(status int) Tag

WorkflowCloseStatus returns a tag to report a workflow's close status

func WorkflowCronSchedule added in v1.0.0 

func WorkflowCronSchedule(schedule string) Tag

WorkflowCronSchedule returns a tag to report a workflow's cron schedule

func WorkflowDecisionFailCause 

func WorkflowDecisionFailCause(decisionFailCause int64) Tag

WorkflowDecisionFailCause returns tag for WorkflowDecisionFailCause

func WorkflowDecisionTimeoutSeconds 

func WorkflowDecisionTimeoutSeconds(s int32) Tag

WorkflowDecisionTimeoutSeconds returns tag for WorkflowDecisionTimeoutSeconds

func WorkflowDecisionType 

func WorkflowDecisionType(decisionType int64) Tag

WorkflowDecisionType returns tag for WorkflowDecisionType

func WorkflowDomainID 

func WorkflowDomainID(domainID string) Tag

WorkflowDomainID returns tag for WorkflowDomainID

func WorkflowDomainIDs 

func WorkflowDomainIDs(domainIDs interface{}) Tag

WorkflowDomainIDs returns tag for WorkflowDomainIDs

func WorkflowDomainName 

func WorkflowDomainName(domainName string) Tag

WorkflowDomainName returns tag for WorkflowDomainName

func WorkflowEndingRunID 

func WorkflowEndingRunID(endingRunID string) Tag

WorkflowEndingRunID returns tag for WorkflowEndingRunID

func WorkflowError 

func WorkflowError(error error) Tag

WorkflowError returns tag for WorkflowError

func WorkflowEventCount 

func WorkflowEventCount(eventCount int) Tag

WorkflowEventCount returns tag for EventCount

func WorkflowEventID 

func WorkflowEventID(eventID int64) Tag

WorkflowEventID returns tag for WorkflowEventID

func WorkflowEventType added in v0.25.0 

func WorkflowEventType(eventType string) Tag

func WorkflowFirstEventID 

func WorkflowFirstEventID(firstEventID int64) Tag

WorkflowFirstEventID returns tag for WorkflowFirstEventID

func WorkflowHandlerName 

func WorkflowHandlerName(handlerName string) Tag

WorkflowHandlerName returns tag for WorkflowHandlerName

func WorkflowHistorySize 

func WorkflowHistorySize(historySize int) Tag

WorkflowHistorySize returns tag for HistorySize

func WorkflowHistorySizeBytes 

func WorkflowHistorySizeBytes(historySizeBytes int) Tag

WorkflowHistorySizeBytes returns tag for HistorySizeBytes

func WorkflowID 

func WorkflowID(workflowID string) Tag

WorkflowID returns tag for WorkflowID

func WorkflowIDCacheSize added in v1.2.7 

func WorkflowIDCacheSize(size int) Tag

func WorkflowInitiatedID 

func WorkflowInitiatedID(id int64) Tag

WorkflowInitiatedID returns tag for WorkflowInitiatedID

func WorkflowNextEventID 

func WorkflowNextEventID(nextEventID int64) Tag

WorkflowNextEventID returns tag for WorkflowNextEventID

func WorkflowPollContextTimeout 

func WorkflowPollContextTimeout(pollContextTimeout time.Duration) Tag

WorkflowPollContextTimeout returns tag for WorkflowPollContextTimeout

func WorkflowQueryType 

func WorkflowQueryType(qt string) Tag

WorkflowQueryType returns tag for WorkflowQueryType

func WorkflowRequestID added in v1.2.10 

func WorkflowRequestID(requestID string) Tag

WorkflowRequestID returns tag for WorkflowRequestID

func WorkflowResetBaseRunID added in v0.5.8 

func WorkflowResetBaseRunID(runID string) Tag

WorkflowResetBaseRunID returns tag for WorkflowResetBaseRunID

func WorkflowResetNewRunID added in v0.5.8 

func WorkflowResetNewRunID(runID string) Tag

WorkflowResetNewRunID returns tag for WorkflowResetNewRunID

func WorkflowResetNextEventID 

func WorkflowResetNextEventID(resetNextEventID int64) Tag

WorkflowResetNextEventID returns tag for WorkflowResetNextEventID

func WorkflowRunID 

func WorkflowRunID(runID string) Tag

WorkflowRunID returns tag for WorkflowRunID

func WorkflowScheduleID 

func WorkflowScheduleID(scheduleID int64) Tag

WorkflowScheduleID returns tag for WorkflowScheduleID

func WorkflowSignalCount 

func WorkflowSignalCount(signalCount int32) Tag

WorkflowSignalCount returns tag for SignalCount

func WorkflowSignalName added in v1.2.8 

func WorkflowSignalName(signalName string) Tag

WorkflowSignalName returns tag for WorkflowSignalName

func WorkflowSize 

func WorkflowSize(workflowSize int64) Tag

WorkflowSize returns tag for WorkflowSize

func WorkflowStartedID 

func WorkflowStartedID(id int64) Tag

WorkflowStartedID returns tag for WorkflowStartedID

func WorkflowState 

func WorkflowState(s int) Tag

WorkflowState returns tag for WorkflowState

func WorkflowTaskListKind added in v0.18.0 

func WorkflowTaskListKind(taskListKind int32) Tag

WorkflowTaskListKind returns tag for WorkflowTaskListKind

func WorkflowTaskListName 

func WorkflowTaskListName(taskListName string) Tag

WorkflowTaskListName returns tag for WorkflowTaskListName

func WorkflowTaskListType 

func WorkflowTaskListType(taskListType int) Tag

WorkflowTaskListType returns tag for WorkflowTaskListType

func WorkflowTerminationReason added in v1.2.12 

func WorkflowTerminationReason(reason string) Tag

WorkflowTerminationReason returns a tag to report a workflow's termination reason

func WorkflowTimeoutType 

func WorkflowTimeoutType(timeoutType int64) Tag

WorkflowTimeoutType returns tag for WorkflowTimeoutType

func WorkflowTimerID 

func WorkflowTimerID(id string) Tag

WorkflowTimerID returns tag for WorkflowTimerID

func WorkflowTreeID 

func WorkflowTreeID(treeID string) Tag

WorkflowTreeID returns tag for WorkflowTreeID

func WorkflowType 

func WorkflowType(wfType string) Tag

WorkflowType returns tag for WorkflowType

func (*Tag) Field 

func (t *Tag) Field() zap.Field

Field returns a zap field

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.