tag

package
v1.32.1 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LoggingCallAtKey = "logging-call-at"
	WorkflowIDKey    = "wf-id"
	WorkflowRunIDKey = "wf-run-id"
)

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")
	WorkflowActionWorkflowPaused        = workflowAction("add-workflow-paused-event")
	WorkflowActionWorkflowUnpaused      = workflowAction("add-workflow-unpaused-event")

	// workflow cancellation / sign / update-options
	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")
	WorkflowActionWorkflowPropertiesModified     = workflowAction("add-workflow-properties-modified-event")
	WorkflowActionWorkflowOptionsUpdated         = workflowAction("add-workflow-options-updated-event")

	// workflow update
	WorkflowActionUpdateAccepted  = workflowAction("add-workflow-update-accepted-event")
	WorkflowActionUpdateCompleted = workflowAction("add-workflow-update-completed-event")
	WorkflowActionUpdateAdmitted  = workflowAction("add-workflow-update-admitted-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")

	// time skipping
	WorkflowActionWorkflowExecutionTimeSkippingTransitioned = workflowAction("add-workflow-execution-time-skipping-transitioned-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 (
	ComponentFX                        = component("fx")
	ComponentTaskQueue                 = component("taskqueue")
	ComponentHistoryEngine             = component("history-engine")
	ComponentHistoryCache              = component("history-cache")
	ComponentEventsCache               = component("events-cache")
	ComponentTransferQueue             = component("transfer-queue-processor")
	ComponentOutboundQueue             = component("outbound-queue-processor")
	ComponentVisibilityQueue           = component("visibility-queue-processor")
	ComponentArchivalQueue             = component("archival-queue-processor")
	ComponentTimerQueue                = component("timer-queue-processor")
	ComponentMemoryScheduledQueue      = component("memory-scheduled-queue-processor")
	ComponentTimerBuilder              = component("timer-builder")
	ComponentReplicatorQueue           = component("replicator-queue-processor")
	ComponentShardController           = component("shard-controller")
	ComponentShardContext              = component("shard-context")
	ComponentShardEngine               = component("shard-engine")
	ComponentMatchingEngine            = component("matching-engine")
	ComponentPartitionScaler           = component("partition-scaler")
	ComponentReplicator                = component("replicator")
	ComponentReplicationTaskProcessor  = component("replication-task-processor")
	ComponentHSMStateReplicator        = component("hsm-state-replicator")
	ComponentActivityStateReplicator   = component("activity-state-replicator")
	ComponentWorkflowStateReplicator   = component("workflow-state-replicator")
	ComponentBackfillHistoryReplicator = component("backfill-history-replicator")
	ComponentHistoryReplicator         = component("history-replicator")
	ComponentHistoryImporter           = component("history-importer")
	ComponentIndexer                   = component("indexer")
	ComponentIndexerProcessor          = component("indexer-processor")
	ComponentIndexerESProcessor        = component("indexer-es-processor")
	ComponentESVisibilityManager       = component("es-visibility-manager")
	ComponentArchiver                  = component("archiver")
	ComponentBatcher                   = component("batcher")
	ComponentAdminBatcher              = component("admin-batcher")
	ComponentWorker                    = component("worker")
	ComponentWorkerManager             = component("worker-manager")
	ComponentPerNSWorkerManager        = component("perns-worker-manager")
	ComponentServiceResolver           = component("service-resolver")
	ComponentMetadataInitializer       = component("metadata-initializer")
	ComponentAddSearchAttributes       = component("add-search-attributes")
	ComponentRPCHandler                = component("rpc-handler")
	ComponentLongPollHandler           = component("long-poll-handler")
	ComponentVisibilityHandler         = component("visibility-handler")
	ComponentNamespaceReplication      = component("namespace-replication")
	ComponentPersistence               = component("persistence")
	ComponentWorkflowUpdate            = component("workflow-update")
	ComponentTaskScheduler             = component("task-scheduler")
	VersionChecker                     = component("version-checker")
)

Pre-defined values for TagSysComponent

View Source 
var (
	ScopeHost      = scope("host")
	ScopeNamespace = scope("namespace")
)

Pre-defined values for scope tag

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")
	StoreOperationConflictResolveWorkflowExecution = storeOperation("conflict-resolve-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

View Source 
var FailedAssertion = NewBoolTag("failed-assertion", true)

FailedAssertion is a tag for marking a message as a failed assertion.

Functions

This section is empty.

Types

type Tag 

type Tag interface {
	Key() string
	Value() any
}

Implement Tag interface to supply custom tags to Logger interface implementation.

type ZapTag 

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

ZapTag is the wrapper over zap.Field.

func AckLevel 

func AckLevel(s any) ZapTag

AckLevel returns tag for ack level

func ActivityID 

func ActivityID(id string) ZapTag

ActivityID returns tag for an activity ID

func ActivityInfo 

func ActivityInfo(activityInfo any) ZapTag

ActivityInfo returns tag for activity info

func ActivitySize 

func ActivitySize(activitySize int64) ZapTag

ActivitySize returns a tag for a standalone activity size

func Address 

func Address(ad string) ZapTag

Address return tag for Address

func Addresses 

func Addresses(ads []string) ZapTag

Addresses returns tag for Addresses

func Any 

func Any(key string, value any) ZapTag

func Archetype 

func Archetype(archetype string) ZapTag

Archetype returns tag for Archetype

func ArchetypeID 

func ArchetypeID(archetype uint32) ZapTag

ArchetypeID returns tag for Archetype

func ArchivalArchiveFailReason 

func ArchivalArchiveFailReason(archiveFailReason string) ZapTag

ArchivalArchiveFailReason returns tag for ArchivalArchiveFailReason

func ArchivalCallerServiceName 

func ArchivalCallerServiceName(callerServiceName string) ZapTag

ArchivalCallerServiceName returns tag for the service name calling archival client

func ArchivalRequestBranchToken 

func ArchivalRequestBranchToken(requestBranchToken []byte) ZapTag

ArchivalRequestBranchToken returns tag for RequestBranchToken

func ArchivalRequestCloseFailoverVersion 

func ArchivalRequestCloseFailoverVersion(requestCloseFailoverVersion int64) ZapTag

ArchivalRequestCloseFailoverVersion returns tag for RequestCloseFailoverVersion

func ArchivalRequestCloseTimestamp 

func ArchivalRequestCloseTimestamp(requestCloseTimeStamp *timestamppb.Timestamp) ZapTag

ArchivalRequestCloseTimestamp returns tag for RequestCloseTimestamp

func ArchivalRequestNamespace 

func ArchivalRequestNamespace(requestNamespace string) ZapTag

ArchivalRequestNamespace returns tag for RequestNamespace

func ArchivalRequestNamespaceID 

func ArchivalRequestNamespaceID(requestNamespaceID string) ZapTag

ArchivalRequestNamespaceID returns tag for RequestNamespaceID

func ArchivalRequestNextEventID 

func ArchivalRequestNextEventID(requestNextEventID int64) ZapTag

ArchivalRequestNextEventID returns tag for RequestNextEventID

func ArchivalRequestRunID 

func ArchivalRequestRunID(requestRunID string) ZapTag

ArchivalRequestRunID returns tag for RequestRunID

func ArchivalRequestStatus 

func ArchivalRequestStatus(requestStatus string) ZapTag

ArchivalRequestStatus returns tag for RequestStatus

func ArchivalRequestWorkflowID 

func ArchivalRequestWorkflowID(requestWorkflowID string) ZapTag

ArchivalRequestWorkflowID returns tag for RequestWorkflowID

func ArchivalURI 

func ArchivalURI(URI string) ZapTag

ArchivalURI returns tag for Archival URI

func ArchvialRequestWorkflowType 

func ArchvialRequestWorkflowType(requestWorkflowType string) ZapTag

ArchvialRequestWorkflowType returns tag for RequestWorkflowType

func Attempt 

func Attempt(attempt int32) ZapTag

Attempt returns tag for Attempt

func AttemptCount 

func AttemptCount(attemptCount int64) ZapTag

AttemptCount returns tag for AttemptCount

func AttemptEnd 

func AttemptEnd(attemptEnd time.Time) ZapTag

AttemptEnd returns tag for AttemptEnd

func AttemptStart 

func AttemptStart(attemptStart time.Time) ZapTag

AttemptStart returns tag for AttemptStart

func Binary 

func Binary(key string, value []byte) ZapTag

func BlobSize 

func BlobSize(blobSize int64) ZapTag

BlobSize returns tag for BlobSize

func BlobSizeViolationOperation 

func BlobSizeViolationOperation(operation string) ZapTag

BlobSizeViolationOperation returns tag for BlobSizeViolationOperation

func Bool 

func Bool(key string, b bool) ZapTag

func BootstrapHostPorts 

func BootstrapHostPorts(s string) ZapTag

BootstrapHostPorts returns tag for bootstrap host ports

func BuildId 

func BuildId(buildId string) ZapTag

func BuildIdTaskReachabilityTag 

func BuildIdTaskReachabilityTag(buildIdReachability string) ZapTag

BuildIdTaskReachabilityTag returns tag for build id task reachability

func Cause 

func Cause(cause string) ZapTag

func CertThumbprint 

func CertThumbprint(thumbprint string) ZapTag

CertThumbprint returns tag for CertThumbprint

func ChasmRunID 

func ChasmRunID(id string) ZapTag

ChasmRunID returns tag for an entity run ID

func ClusterName 

func ClusterName(clusterName string) ZapTag

ClusterName returns tag for ClusterName

func Counter 

func Counter(c int) ZapTag

Counter returns tag for Counter

func CurrentVersion 

func CurrentVersion(currentVersion int64) ZapTag

CurrentVersion returns tag for CurrentVersion

func CursorTimestamp 

func CursorTimestamp(timestamp time.Time) ZapTag

CursorTimestamp returns tag for CursorTimestamp

func DLQMessageID 

func DLQMessageID(dlqMessageID int64) ZapTag

func DefaultValue 

func DefaultValue(v any) ZapTag

DefaultValue returns tag for DefaultValue

func DeletedExecutionsCount 

func DeletedExecutionsCount(count int) ZapTag

func DeletedExecutionsErrorCount 

func DeletedExecutionsErrorCount(count int) ZapTag

func Deployment 

func Deployment(d string) ZapTag

func DetailInfo 

func DetailInfo(i string) ZapTag

DetailInfo returns tag for DetailInfo

func Duration 

func Duration(key string, value time.Duration) ZapTag

func DurationPtr 

func DurationPtr(key string, value *durationpb.Duration) ZapTag

func ESClusterStatus 

func ESClusterStatus(status string) ZapTag

func ESConfig 

func ESConfig(c any) ZapTag

ESConfig returns tag for ESConfig

func ESDocID 

func ESDocID(id string) ZapTag

ESDocID returns tag for ESDocID

func ESField 

func ESField(ESField string) ZapTag

ESField returns tag for ESField

func ESIndex 

func ESIndex(index string) ZapTag

func ESKey 

func ESKey(ESKey string) ZapTag

ESKey returns tag for ESKey

func ESMapping 

func ESMapping(mapping map[string]enumspb.IndexedValueType) ZapTag

func ESRequest 

func ESRequest(ESRequest string) ZapTag

ESRequest returns tag for ESRequest

func ESResponseError 

func ESResponseError(msg string) ZapTag

ESResponseError returns tag for ESResponse error

func ESResponseStatus 

func ESResponseStatus(status int) ZapTag

ESResponseStatus returns tag for ESResponse status

func ESValue 

func ESValue(ESValue []byte) ZapTag

ESValue returns tag for ESValue

func Endpoint 

func Endpoint(endpoint string) ZapTag

func Env 

func Env(env string) ZapTag

Env return tag for runtime environment

func Error 

func Error(err error) ZapTag

Error returns tag for Error

func ErrorType 

func ErrorType(err error) ZapTag

ErrorType returns tag for ErrorType

func FailoverMsg 

func FailoverMsg(failoverMsg string) ZapTag

FailoverMsg returns tag for FailoverMsg

func FailoverVersion 

func FailoverVersion(version int64) ZapTag

FailoverVersion returns tag for Version

func FirstEventVersion 

func FirstEventVersion(version int64) ZapTag

FirstEventVersion returns tag for FirstEventVersion

func Float64 

func Float64(key string, value float64) ZapTag

func Host 

func Host(h string) ZapTag

Host returns tag for Host

func HostID 

func HostID(hid string) ZapTag

HostID return tag for HostID

func IgnoredValue 

func IgnoredValue(v any) ZapTag

IgnoredValue returns tag for IgnoredValue

func IncomingVersion 

func IncomingVersion(incomingVersion int64) ZapTag

IncomingVersion returns tag for IncomingVersion

func Int 

func Int(key string, value int) ZapTag

func Int32 

func Int32(key string, value int32) ZapTag

func Int64 

func Int64(key string, value int64) ZapTag

func IsRetryable 

func IsRetryable(isRetryable bool) ZapTag

IsRetryable returns tag for IsRetryable

func Key 

func Key(k string) ZapTag

Key returns tag for Key

func LastEventVersion 

func LastEventVersion(version int64) ZapTag

LastEventVersion returns tag for LastEventVersion

func ListenerName 

func ListenerName(name string) ZapTag

ListenerName returns tag for ListenerName

func MaxLevel 

func MaxLevel(lv int64) ZapTag

MaxLevel returns tag for MaxLevel

func MaxQueryLevel 

func MaxQueryLevel(s time.Time) ZapTag

MaxQueryLevel returns tag for query level

func MetricScope 

func MetricScope(metricScope int) ZapTag

MetricScope returns tag for MetricScope

func MinLevel 

func MinLevel(lv int64) ZapTag

MinLevel returns tag for MinLevel

func MinQueryLevel 

func MinQueryLevel(s time.Time) ZapTag

MinQueryLevel returns tag for query level

func Name 

func Name(k string) ZapTag

Name returns tag for Name

func NewAnyTag 

func NewAnyTag(key string, value any) ZapTag

func NewBinaryTag 

func NewBinaryTag(key string, value []byte) ZapTag

func NewBoolTag 

func NewBoolTag(key string, value bool) ZapTag

func NewDurationPtrTag 

func NewDurationPtrTag(key string, value *durationpb.Duration) ZapTag

func NewDurationTag 

func NewDurationTag(key string, value time.Duration) ZapTag

func NewErrorTag 

func NewErrorTag(key string, value error) ZapTag

func NewFloat64 

func NewFloat64(key string, value float64) ZapTag

func NewInt 

func NewInt(key string, value int) ZapTag

func NewInt32 

func NewInt32(key string, value int32) ZapTag

func NewInt64 

func NewInt64(key string, value int64) ZapTag

func NewStringTag 

func NewStringTag(key string, value string) ZapTag

func NewStringerTag 

func NewStringerTag(key string, value fmt.Stringer) ZapTag

NewStringerTag returns a tag that will lazily generate the string representation of the provided fmt.Stringer value. Note that it does **not** cache the result, so you should use `NewStringTag` instead if the tag is applied to the logger itself using `log.With`.

These are still useful if the String() implementation is complicated, especially if you have lots of Debug-level logs that are ignored in production.

func NewStringersTag 

func NewStringersTag(key string, value []fmt.Stringer) ZapTag

NewStringersTag returns a tag that will lazily generate the string representation of the provided fmt.Stringer values. Note that it does **not** cache the results, so you should use `NewStringsTag` instead if the tag is applied to the logger itself using `log.With`.

These are still useful if the String() implementation is complicated, especially if you have lots of Debug-level logs that are ignored in production.

func NewStringsTag 

func NewStringsTag(key string, value []string) ZapTag

func NewTimePtrTag 

func NewTimePtrTag(key string, value *timestamppb.Timestamp) ZapTag

func NewTimeTag 

func NewTimeTag(key string, value time.Time) ZapTag

func NewUInt32 

func NewUInt32(key string, value uint32) ZapTag

func NewUInt64 

func NewUInt64(key string, value uint64) ZapTag

func NewZapTag 

func NewZapTag(field zap.Field) ZapTag

NewZapTag creates new ZapTag from zap.Field.

func NextNumber 

func NextNumber(n int64) ZapTag

NextNumber returns tag for NextNumber

func NexusEndpointTargetNamespaceID 

func NexusEndpointTargetNamespaceID(namespaceID string) ZapTag

NexusEndpointTargetNamespaceID returns a tag for the namespace ID targeted by a Nexus endpoint's worker target.

func NexusOperation 

func NexusOperation(operation string) ZapTag

func NexusTaskQueueName 

func NexusTaskQueueName(taskQueueName string) ZapTag

NexusTaskQueueName returns tag for NexusTaskQueueName

func Number 

func Number(n int64) ZapTag

Number returns tag for Number

func NumberChanged 

func NumberChanged(n int) ZapTag

NumberChanged returns tag for NumberChanged

func NumberDeleted 

func NumberDeleted(n int) ZapTag

NumberDeleted returns tag for NumberDeleted

func NumberProcessed 

func NumberProcessed(n int) ZapTag

NumberProcessed returns tag for NumberProcessed

func Operation 

func Operation(operation string) ZapTag

Operation returns tag for Operation

func OperationID 

func OperationID(id string) ZapTag

OperationID returns tag for a nexus operation ID

func Port 

func Port(p int) ZapTag

Port returns tag for Port

func PrevActiveCluster 

func PrevActiveCluster(prevActiveCluster string) ZapTag

PrevActiveCluster returns tag for PrevActiveCluster

func PreviousShardRangeID 

func PreviousShardRangeID(id int64) ZapTag

PreviousShardRangeID returns tag for PreviousShardRangeID

func QueryID 

func QueryID(queryID string) ZapTag

QueryID returns tag for QueryID

func QueueAlert 

func QueueAlert(alert any) ZapTag

QueueAlert returns tag for queue alert

func QueueReaderID 

func QueueReaderID(readerID int64) ZapTag

QueueReaderID returns tag for queue readerID

func RPS 

func RPS(c int64) ZapTag

RPS returns tag for requests per second

func ReachabilityExitPointTag 

func ReachabilityExitPointTag(reachabilityExitPoint string) ZapTag

ReachabilityExitPointTag returns tag for reachabilityExitPoint

func ReadLevel 

func ReadLevel(lv int64) ZapTag

ReadLevel returns tag for ReadLevel

func ReplicationTask 

func ReplicationTask(replicationTask any) ZapTag

func RequestCount 

func RequestCount(c int) ZapTag

RequestCount returns tag for RequestCount

func RequestID 

func RequestID(requestID string) ZapTag

RequestID returns tag for RequestID

func ScheduleAttempt 

func ScheduleAttempt(scheduleAttempt int32) ZapTag

ScheduleAttempt returns tag for ScheduleAttempt

func ScheduleID 

func ScheduleID(scheduleID string) ZapTag

ScheduleID returns tag for ScheduleID

func ServerName 

func ServerName(serverName string) ZapTag

ServerName returns tag for ServerName

func Service 

func Service(sv primitives.ServiceName) ZapTag

Service returns tag for Service

func ServiceErrorType 

func ServiceErrorType(err error) ZapTag

ServiceErrorType returns tag for ServiceErrorType

func ShardContextState 

func ShardContextState(state int) ZapTag

ShardContextState returns tag for ShardContextState

func ShardContextStateRequest 

func ShardContextStateRequest(r string) ZapTag

ShardContextStateRequest returns tag for ShardContextStateRequest

func ShardID 

func ShardID(shardID int32) ZapTag

ShardID returns tag for ShardID

func ShardQueueAcks 

func ShardQueueAcks(categoryName string, ackLevel any) ZapTag

ShardQueueAcks returns tag for shard queue ack levels

func ShardRangeID 

func ShardRangeID(id int64) ZapTag

ShardRangeID returns tag for ShardRangeID

func ShardTime 

func ShardTime(shardTime any) ZapTag

ShardTime returns tag for ShardTime

func SourceCluster 

func SourceCluster(sourceCluster string) ZapTag

SourceCluster returns tag for SourceCluster

func SourceShardID 

func SourceShardID(shardID int32) ZapTag

func StoreType 

func StoreType(storeType string) ZapTag

StoreType returns tag for StoreType

func String 

func String(key string, value string) ZapTag

func Stringer 

func Stringer(key string, value fmt.Stringer) ZapTag

func Stringers 

func Stringers(key string, value []fmt.Stringer) ZapTag

func Strings 

func Strings(key string, value []string) ZapTag

func SysStackTrace 

func SysStackTrace(stackTrace string) ZapTag

SysStackTrace returns tag for SysStackTrace

func TLSCertFile 

func TLSCertFile(filePath string) ZapTag

TLSCertFile returns tag for TLS cert file name

func TLSCertFiles 

func TLSCertFiles(filePaths []string) ZapTag

TLSCertFiles returns tag for TLS cert file names

func TLSKeyFile 

func TLSKeyFile(filePath string) ZapTag

TLSKeyFile returns tag for TLS key file

func TargetCluster 

func TargetCluster(targetCluster string) ZapTag

TargetCluster returns tag for TargetCluster

func TargetShardID 

func TargetShardID(shardID int32) ZapTag

func Task 

func Task(task any) ZapTag

Task returns tag for Task

func TaskCategoryID 

func TaskCategoryID(taskCategoryID int) ZapTag

func TaskID 

func TaskID(taskID int64) ZapTag

TaskID returns tag for TaskID

func TaskKey 

func TaskKey(key any) ZapTag

TaskKey returns tag for TaskKey

func TaskPriority 

func TaskPriority(priority string) ZapTag

TaskPriority returns tag for TaskPriority

func TaskType 

func TaskType(taskType enumsspb.TaskType) ZapTag

func TaskVersion 

func TaskVersion(taskVersion int64) ZapTag

TaskVersion returns tag for TaskVersion

func TaskVisibilityTimestamp 

func TaskVisibilityTimestamp(timestamp time.Time) ZapTag

TaskVisibilityTimestamp returns tag for task visibilityTimestamp

func Time 

func Time(key string, value time.Time) ZapTag

func TimePtr 

func TimePtr(key string, value *timestamppb.Timestamp) ZapTag

func Timeout 

func Timeout(timeoutValue string) ZapTag

Timeout returns tag for timeout

func TimerTaskStatus 

func TimerTaskStatus(timerTaskStatus int32) ZapTag

TimerTaskStatus returns tag for TimerTaskStatus

func Timestamp 

func Timestamp(timestamp time.Time) ZapTag

Timestamp returns tag for Timestamp

func TokenLastEventID 

func TokenLastEventID(id int64) ZapTag

TokenLastEventID returns tag for TokenLastEventID

func TokenLastEventVersion 

func TokenLastEventVersion(version int64) ZapTag

TokenLastEventVersion returns tag for TokenLastEventVersion

func TransportType 

func TransportType(transportType string) ZapTag

TransportType returns tag for transportType

func UInt32 

func UInt32(key string, value uint32) ZapTag

func UInt64 

func UInt64(key string, value uint64) ZapTag

func URL 

func URL(url string) ZapTag

URL returns tag for URL

func UnexpectedErrorAttempts 

func UnexpectedErrorAttempts(attempt int32) ZapTag

UnexpectedErrorAttempts returns tag for UnexpectedErrorAttempts

func UserDataVersion 

func UserDataVersion(v int64) ZapTag

func Value 

func Value(v any) ZapTag

Value returns tag for Value

func ValueType 

func ValueType(v any) ZapTag

ValueType returns tag for ValueType

func VersioningBehavior 

func VersioningBehavior(behavior enumspb.VersioningBehavior) ZapTag

func WorkerComponent 

func WorkerComponent(v any) ZapTag

func WorkerVersion 

func WorkerVersion(version string) ZapTag

WorkerVersion returns tag for worker build ID

func WorkerVersioningAssignmentRuleCount 

func WorkerVersioningAssignmentRuleCount(assignmentRuleCount int) ZapTag

WorkerVersioningAssignmentRuleCount returns tag for AssignmentRuleCount

func WorkerVersioningMaxUpstreamBuildIDs 

func WorkerVersioningMaxUpstreamBuildIDs(maxUpstreamBuildIDs int) ZapTag

WorkerVersioningMaxUpstreamBuildIDs returns tag for RedirectRuleCount

func WorkerVersioningRedirectRuleCount 

func WorkerVersioningRedirectRuleCount(redirectRuleCount int) ZapTag

WorkerVersioningRedirectRuleCount returns tag for RedirectRuleCount

func WorkflowBeginningFirstEventID 

func WorkflowBeginningFirstEventID(beginningFirstEventID int64) ZapTag

WorkflowBeginningFirstEventID returns tag for WorkflowBeginningFirstEventID

func WorkflowBeginningRunID 

func WorkflowBeginningRunID(beginningRunID string) ZapTag

WorkflowBeginningRunID returns tag for WorkflowBeginningRunID

func WorkflowBinaryChecksum 

func WorkflowBinaryChecksum(cs string) ZapTag

WorkflowBinaryChecksum returns tag for WorkflowBinaryChecksum

func WorkflowBranchID 

func WorkflowBranchID(branchID string) ZapTag

WorkflowBranchID returns tag for WorkflowBranchID

func WorkflowBranchToken 

func WorkflowBranchToken(branchToken []byte) ZapTag

WorkflowBranchToken returns tag for WorkflowBranchToken

func WorkflowCommandType 

func WorkflowCommandType(commandType enumspb.CommandType) ZapTag

WorkflowCommandType returns tag for WorkflowCommandType

func WorkflowEndingNextEventID 

func WorkflowEndingNextEventID(endingNextEventID int64) ZapTag

WorkflowEndingNextEventID returns tag for WorkflowEndingNextEventID

func WorkflowEndingRunID 

func WorkflowEndingRunID(endingRunID string) ZapTag

WorkflowEndingRunID returns tag for WorkflowEndingRunID

func WorkflowEventCount 

func WorkflowEventCount(eventCount int) ZapTag

WorkflowEventCount returns tag for EventCount

func WorkflowEventID 

func WorkflowEventID(eventID int64) ZapTag

WorkflowEventID returns tag for WorkflowEventID

func WorkflowFirstEventID 

func WorkflowFirstEventID(firstEventID int64) ZapTag

WorkflowFirstEventID returns tag for WorkflowFirstEventID

func WorkflowHandlerName 

func WorkflowHandlerName(handlerName string) ZapTag

WorkflowHandlerName returns tag for WorkflowHandlerName

func WorkflowHistorySize 

func WorkflowHistorySize(historySize int) ZapTag

WorkflowHistorySize returns tag for HistorySize

func WorkflowHistorySizeBytes 

func WorkflowHistorySizeBytes(historySizeBytes int) ZapTag

WorkflowHistorySizeBytes returns tag for HistorySizeBytes

func WorkflowID 

func WorkflowID(workflowID string) ZapTag

WorkflowID returns tag for WorkflowID TODO: Rename to BusinessID.

func WorkflowInitiatedID 

func WorkflowInitiatedID(id int64) ZapTag

WorkflowInitiatedID returns tag for WorkflowInitiatedID

func WorkflowMutableStateSize 

func WorkflowMutableStateSize(mutableStateSize int) ZapTag

WorkflowMutableStateSize returns tag for MutableStateSize

func WorkflowNamespace 

func WorkflowNamespace(namespace string) ZapTag

WorkflowNamespace returns tag for WorkflowNamespace

func WorkflowNamespaceID 

func WorkflowNamespaceID(namespaceID string) ZapTag

WorkflowNamespaceID returns tag for WorkflowNamespaceID TODO: Rename to NamespaceID

func WorkflowNamespaceIDs 

func WorkflowNamespaceIDs(namespaceIDs map[string]struct{}) ZapTag

WorkflowNamespaceIDs returns tag for WorkflowNamespaceIDs

func WorkflowNewRunID 

func WorkflowNewRunID(newRunID string) ZapTag

WorkflowNewRunID returns tag for WorkflowNewRunID

func WorkflowNextEventID 

func WorkflowNextEventID(nextEventID int64) ZapTag

WorkflowNextEventID returns tag for WorkflowNextEventID

func WorkflowPollContextTimeout 

func WorkflowPollContextTimeout(pollContextTimeout time.Duration) ZapTag

WorkflowPollContextTimeout returns tag for WorkflowPollContextTimeout

func WorkflowQueryType 

func WorkflowQueryType(qt string) ZapTag

WorkflowQueryType returns tag for WorkflowQueryType

func WorkflowRequestBranchToken 

func WorkflowRequestBranchToken(branchToken []byte) ZapTag

WorkflowRequestBranchToken returns tag for a branch token supplied by the caller

func WorkflowResetBaseRunID 

func WorkflowResetBaseRunID(runID string) ZapTag

WorkflowResetBaseRunID returns tag for WorkflowResetBaseRunID

func WorkflowResetNewRunID 

func WorkflowResetNewRunID(runID string) ZapTag

WorkflowResetNewRunID returns tag for WorkflowResetNewRunID

func WorkflowResetNextEventID 

func WorkflowResetNextEventID(resetNextEventID int64) ZapTag

WorkflowResetNextEventID returns tag for WorkflowResetNextEventID

func WorkflowRuleID 

func WorkflowRuleID(ruleID string) ZapTag

WorkflowRuleID returns tag for WorkflowRuleID

func WorkflowRunID 

func WorkflowRunID(runID string) ZapTag

WorkflowRunID returns tag for WorkflowRunID TODO: Rename to RunID

func WorkflowScheduledEventID 

func WorkflowScheduledEventID(scheduledEventID int64) ZapTag

WorkflowScheduledEventID returns tag for WorkflowScheduledEventID

func WorkflowSignalCount 

func WorkflowSignalCount(signalCount int64) ZapTag

WorkflowSignalCount returns tag for SignalCount

func WorkflowSize 

func WorkflowSize(workflowSize int64) ZapTag

WorkflowSize returns tag for WorkflowSize

func WorkflowStartedEventID 

func WorkflowStartedEventID(startedEventID int64) ZapTag

WorkflowStartedEventID returns tag for WorkflowStartedEventID

func WorkflowStartedTimestamp 

func WorkflowStartedTimestamp(t time.Time) ZapTag

WorkflowStartedTimestamp returns tag for WorkflowStartedTimestamp

func WorkflowState 

func WorkflowState(s enumsspb.WorkflowExecutionState) ZapTag

WorkflowState returns tag for WorkflowState

func WorkflowTaskFailedCause 

func WorkflowTaskFailedCause(workflowTaskFailCause enumspb.WorkflowTaskFailedCause) ZapTag

WorkflowTaskFailedCause returns tag for WorkflowTaskFailedCause

func WorkflowTaskQueueName 

func WorkflowTaskQueueName(taskQueueName string) ZapTag

WorkflowTaskQueueName returns tag for WorkflowTaskQueueName

func WorkflowTaskQueueType 

func WorkflowTaskQueueType(taskQueueType enumspb.TaskQueueType) ZapTag

WorkflowTaskQueueType returns tag for WorkflowTaskQueueType

func WorkflowTaskRequestId 

func WorkflowTaskRequestId(s string) ZapTag

WorkflowTaskRequestId returns a tag for workflow task RequestId

func WorkflowTaskTimeout 

func WorkflowTaskTimeout(s time.Duration) ZapTag

WorkflowTaskTimeout returns tag for WorkflowTaskTimeoutSeconds

func WorkflowTaskTimeoutSeconds 

func WorkflowTaskTimeoutSeconds(s int64) ZapTag

WorkflowTaskTimeoutSeconds returns tag for WorkflowTaskTimeoutSeconds

func WorkflowTaskType 

func WorkflowTaskType(wtType string) ZapTag

func WorkflowTimeoutType 

func WorkflowTimeoutType(timeoutType enumspb.TimeoutType) ZapTag

WorkflowTimeoutType returns tag for WorkflowTimeoutType

func WorkflowTimerID 

func WorkflowTimerID(id string) ZapTag

WorkflowTimerID returns tag for WorkflowTimerID

func WorkflowTreeID 

func WorkflowTreeID(treeID string) ZapTag

WorkflowTreeID returns tag for WorkflowTreeID

func WorkflowType 

func WorkflowType(wfType string) ZapTag

WorkflowType returns tag for WorkflowType

func Zap 

func Zap(field zap.Field) ZapTag

func (ZapTag) Field 

func (t ZapTag) Field() zap.Field

func (ZapTag) Key 

func (t ZapTag) Key() string

func (ZapTag) Value 

func (t ZapTag) Value() any

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.