tag

package
v0.8.1 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2019 License: MIT Imports: 3 Imported by: 21

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

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

	// 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")
	ComponentHistoryBuilder           = component("history-builder")
	ComponentHistoryEngine            = component("history-engine")
	ComponentHistoryCache             = component("history-cache")
	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")
	ComponentHistoryReplicator        = component("history-replicator")
	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")
)

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

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 (
	StoreOperationGetTasks                = storeOperation("get-tasks")
	StoreOperationCompleteTask            = storeOperation("complete-task")
	StoreOperationCompleteTasksLessThan   = storeOperation("complete-tasks-less-than")
	StoreOperationCreateWorkflowExecution = storeOperation("create-wf-execution")
	StoreOperationGetWorkflowExecution    = storeOperation("get-wf-execution")
	StoreOperationUpdateWorkflowExecution = storeOperation("update-wf-execution")
	StoreOperationDeleteWorkflowExecution = storeOperation("delete-wf-execution")
	StoreOperationUpdateShard             = storeOperation("update-shard")
	StoreOperationCreateTask              = storeOperation("create-task")
	StoreOperationUpdateTaskList          = storeOperation("update-task-list")
	StoreOperationStopTaskList            = storeOperation("stop-task-list")
)

Pre-defined values for TagSysStoreOperation

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

func ArchivalRequestEventStoreVersion(requestEventStoreVersion int32) Tag

ArchivalRequestEventStoreVersion returns tag for RequestEventStoreVersion

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

func Bool(b bool) Tag

Bool returns tag for Bool

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

func PreviousShardRangeID(id int64) Tag

PreviousShardRangeID returns tag for PreviousShardRangeID

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 ReplicationState 

func ReplicationState(replicationState interface{}) Tag

ReplicationState returns tag for ReplicationState

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

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.