tag

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2020 License: MIT Imports: 7 Imported by: 20

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

	// workflow task
	WorkflowActionWorkflowTaskScheduled = workflowAction("add-workflowtask-scheduled-event")
	WorkflowActionWorkflowTaskStarted   = workflowAction("add-workflowtask-started-event")
	WorkflowActionWorkflowTaskCompleted = workflowAction("add-workflowtask-completed-event")
	WorkflowActionWorkflowTaskTimedOut  = workflowAction("add-workflowtask-timedout-event")
	WorkflowActionWorkflowTaskFailed    = workflowAction("add-workflowtask-failed-event")

	// in memory workflow task
	WorkflowActionInMemoryWorkflowTaskScheduled = workflowAction("add-in-memory-workflowtask-scheduled")
	WorkflowActionInMemoryWorkflowTaskStarted   = workflowAction("add-in-memory-workflowtask-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 (
	ComponentTaskQueue                = component("taskqueue")
	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")
	ComponentMetadataInitializer      = component("metadata-initializer")
)

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")
	ErrorTypeMultipleCompletionCommands   = errorType("MultipleCompletionCommands")
	ErrorTypeDuplicateTransferTask        = errorType("DuplicateTransferTask")
	ErrorTypeWorkflowTaskFailed           = errorType("WorkflowTaskFailed")
	ErrorTypeInvalidMutableStateAction    = errorType("InvalidMutableStateAction")
	ErrorTypeInvalidMemWorkflowTaskAction = errorType("InvalidMemWorkflowTaskAction")
)

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")
	StoreOperationUpdateTaskQueue         = storeOperation("update-task-queue")
	StoreOperationStopTaskQueue           = storeOperation("stop-task-queue")
)

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 AckLevel added in v0.27.0 

func AckLevel(s interface{}) Tag

AckLevel returns tag for ack level

func ActivityInfo added in v0.27.0 

func ActivityInfo(activityInfo interface{}) Tag

ActivityInfo returns tag for activity info

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

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 ArchivalRequestCloseTimestamp added in v0.27.0 

func ArchivalRequestCloseTimestamp(requestCloseTimeStamp *time.Time) Tag

ArchivalRequestCloseTimestamp returns tag for RequestCloseTimestamp

func ArchivalRequestNamespace added in v0.27.0 

func ArchivalRequestNamespace(requestNamespace string) Tag

ArchivalRequestNamespace returns tag for RequestNamespace

func ArchivalRequestNamespaceID added in v0.27.0 

func ArchivalRequestNamespaceID(requestNamespaceID string) Tag

ArchivalRequestNamespaceID returns tag for RequestNamespaceID

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 ArchivalRequestStatus added in v0.27.0 

func ArchivalRequestStatus(requestStatus string) Tag

ArchivalRequestStatus returns tag for RequestStatus

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

func ArchivalVisibilityQuery(query string) Tag

ArchivalVisibilityQuery returns tag for the query for getting archived visibility record

func ArchvialRequestWorkflowType added in v0.27.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.27.0 

func BlobSizeViolationOperation(operation string) Tag

BlobSizeViolationOperation returns tag for BlobSizeViolationOperation

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 ESValue added in v0.27.0 

func ESValue(ESValue []byte) Tag

ESValue returns tag for ESValue

func Env added in v0.27.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 HostID added in v0.27.0 

func HostID(hid string) Tag

HostID return tag for HostID

func IgnoredValue added in v0.27.0 

func IgnoredValue(v interface{}) Tag

IgnoredValue returns tag for IgnoredValue

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 MaxQueryLevel added in v0.30.0 

func MaxQueryLevel(s time.Time) Tag

QueryLevel returns tag for query level

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 MinQueryLevel added in v0.30.0 

func MinQueryLevel(s time.Time) Tag

QueryLevel returns tag for query level

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 QueryID added in v0.27.0 

func QueryID(queryID string) Tag

QueryID returns tag for QueryID

func QueryLevel added in v0.27.0 

func QueryLevel(s time.Time) Tag

QueryLevel returns tag for query level

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 int32) 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 ShardItem added in v0.27.0 

func ShardItem(shardItem interface{}) Tag

ShardItem returns tag for ShardItem

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 Task added in v0.27.0 

func Task(task interface{}) Tag

Task returns tag for Task

func TaskID 

func TaskID(taskID int64) Tag

TaskID returns tag for TaskID

func TaskQueueInfo added in v0.27.0 

func TaskQueueInfo(s interface{}) Tag

TaskQueueInfo returns tag for task queue info

func TaskType 

func TaskType(taskType enumsspb.TaskType) Tag

TaskType returns tag for TaskType for queue processor

func TaskVersion added in v0.27.0 

func TaskVersion(taskVersion int64) Tag

TaskVersion returns tag for TaskVersion

func TaskVisibilityTimestamp added in v0.27.0 

func TaskVisibilityTimestamp(timestamp int64) Tag

TaskVisibilityTimestamp returns tag for task visibilityTimestamp

func Tasks added in v0.27.0 

func Tasks(s interface{}) Tag

AckLevel returns tag for upper ack level

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 TimestampInt added in v0.27.0 

func TimestampInt(timestamp int64) Tag

TimestampInt returns tag for Timestamp

func TimestampProto added in v0.27.0 

func TimestampProto(timestamp *types.Timestamp) Tag

Timestamp returns tag for Timestamp

func TimestampPtr added in v0.28.0 

func TimestampPtr(t *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 TransportType added in v0.27.0 

func TransportType(transportType string) Tag

TransportType returns tag for transportType

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 WorkflowCommandType added in v0.27.0 

func WorkflowCommandType(commandType enumspb.CommandType) Tag

WorkflowCommandType returns tag for WorkflowCommandType

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 WorkflowNamespace added in v0.27.0 

func WorkflowNamespace(namespace string) Tag

WorkflowNamespace returns tag for WorkflowNamespace

func WorkflowNamespaceID added in v0.27.0 

func WorkflowNamespaceID(namespaceID string) Tag

WorkflowNamespaceID returns tag for WorkflowNamespaceID

func WorkflowNamespaceIDs added in v0.27.0 

func WorkflowNamespaceIDs(namespaceIDs interface{}) Tag

WorkflowNamespaceIDs returns tag for WorkflowNamespaceIDs

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 int64) 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 WorkflowStartedTimestamp added in v0.30.0 

func WorkflowStartedTimestamp(t *time.Time) Tag

WorkflowStartedID returns tag for WorkflowStartedTimestamp

func WorkflowState 

func WorkflowState(s enumsspb.WorkflowExecutionState) Tag

WorkflowState returns tag for WorkflowState

func WorkflowTaskFailedCause added in v0.27.0 

func WorkflowTaskFailedCause(workflowTaskFailCause enumspb.WorkflowTaskFailedCause) Tag

WorkflowTaskFailedCause returns tag for WorkflowTaskFailedCause

func WorkflowTaskQueueName added in v0.27.0 

func WorkflowTaskQueueName(taskQueueName string) Tag

WorkflowTaskQueueName returns tag for WorkflowTaskQueueName

func WorkflowTaskQueueType added in v0.27.0 

func WorkflowTaskQueueType(taskQueueType enumspb.TaskQueueType) Tag

WorkflowTaskQueueType returns tag for WorkflowTaskQueueType

func WorkflowTaskRequestId added in v0.27.0 

func WorkflowTaskRequestId(s string) Tag

WorkflowTaskRequestId returns tag for workflow task RequestId

func WorkflowTaskTimeout added in v0.30.0 

func WorkflowTaskTimeout(s *time.Duration) Tag

WorkflowTaskTimeoutSeconds returns tag for WorkflowTaskTimeoutSeconds

func WorkflowTaskTimeoutSeconds added in v0.27.0 

func WorkflowTaskTimeoutSeconds(s int64) Tag

WorkflowTaskTimeoutSeconds returns tag for WorkflowTaskTimeoutSeconds

func WorkflowTimeoutType 

func WorkflowTimeoutType(timeoutType enumspb.TimeoutType) 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.