tag

package
Version: v0.22.0 Latest Latest
Warning

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

Go to latest
Published: Aug 20, 2021 License: MIT Imports: 3 Imported by: 30

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")
	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")
)

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")
	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")
)

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")
	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")

	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")
	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")
	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")

	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")
	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")

	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")
)

Pre-defined values for TagSysClientOperation

Functions

This section is empty.

Types

type Tag

type Tag struct {
	// contains filtered or unexported fields
}

Tag is the interface for logging system

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 Attempt

func Attempt(attempt int32) Tag

Attempt returns tag for Attempt

func AttemptCount

func AttemptCount(attemptCount int64) 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 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 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 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 FirstEventVersion

func FirstEventVersion(version int64) Tag

FirstEventVersion returns tag for FirstEventVersion

func IncomingVersion

func IncomingVersion(incomingVersion int64) Tag

IncomingVersion returns tag for IncomingVersion

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 ListenerName

func ListenerName(name string) Tag

ListenerName returns tag for ListenerName

func MaxLevel

func MaxLevel(lv int64) Tag

MaxLevel returns tag for MaxLevel

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

func ReplicationInfo(replicationInfo interface{}) Tag

ReplicationInfo returns tag for ReplicationInfo

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

func StoreType(storeType string) Tag

StoreType returns tag for StoreType

func SysStackTrace

func SysStackTrace(stackTrace string) Tag

SysStackTrace returns tag for SysStackTrace

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 WorkflowActivityID

func WorkflowActivityID(id string) Tag

WorkflowActivityID returns tag for WorkflowActivityID

func WorkflowBeginningFirstEventID

func WorkflowBeginningFirstEventID(beginningFirstEventID int64) Tag

WorkflowBeginningFirstEventID returns tag for WorkflowBeginningFirstEventID

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

func WorkflowEndingNextEventID(endingNextEventID int64) Tag

WorkflowEndingNextEventID returns tag for WorkflowEndingNextEventID

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL