tag

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 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")

	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")
	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")
	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 added in v1.2.0 

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

ZapTag is the wrapper over zap.Field.

func AckLevel added in v1.2.0 

func AckLevel(s any) ZapTag

AckLevel returns tag for ack level

func ActivityID added in v1.2.0 

func ActivityID(id string) ZapTag

ActivityID returns tag for an activity ID

func ActivityInfo added in v1.2.0 

func ActivityInfo(activityInfo any) ZapTag

ActivityInfo returns tag for activity info

func ActivitySize added in v1.2.0 

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 added in v1.2.0 

func Any(key string, value any) ZapTag

func Archetype added in v1.2.0 

func Archetype(archetype string) ZapTag

Archetype returns tag for Archetype

func ArchetypeID added in v1.2.0 

func ArchetypeID(archetype uint32) ZapTag

ArchetypeID returns tag for Archetype

func ArchivalArchiveFailReason added in v0.6.0 

func ArchivalArchiveFailReason(archiveFailReason string) ZapTag

ArchivalArchiveFailReason returns tag for ArchivalArchiveFailReason

func ArchivalCallerServiceName added in v0.7.0 

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 added in v1.2.0 

func ArchivalRequestCloseTimestamp(requestCloseTimeStamp *timestamppb.Timestamp) ZapTag

ArchivalRequestCloseTimestamp returns tag for RequestCloseTimestamp

func ArchivalRequestNamespace added in v1.2.0 

func ArchivalRequestNamespace(requestNamespace string) ZapTag

ArchivalRequestNamespace returns tag for RequestNamespace

func ArchivalRequestNamespaceID added in v1.2.0 

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 added in v1.2.0 

func ArchivalRequestStatus(requestStatus string) ZapTag

ArchivalRequestStatus returns tag for RequestStatus

func ArchivalRequestWorkflowID 

func ArchivalRequestWorkflowID(requestWorkflowID string) ZapTag

ArchivalRequestWorkflowID returns tag for RequestWorkflowID

func ArchivalURI added in v0.6.0 

func ArchivalURI(URI string) ZapTag

ArchivalURI returns tag for Archival URI

func ArchvialRequestWorkflowType added in v1.2.0 

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 added in v1.2.0 

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

func BlobSize added in v1.2.0 

func BlobSize(blobSize int64) ZapTag

BlobSize returns tag for BlobSize

func BlobSizeViolationOperation added in v1.2.0 

func BlobSizeViolationOperation(operation string) ZapTag

BlobSizeViolationOperation returns tag for BlobSizeViolationOperation

func Bool 

func Bool(key string, b bool) ZapTag

func BootstrapHostPorts added in v1.2.0 

func BootstrapHostPorts(s string) ZapTag

BootstrapHostPorts returns tag for bootstrap host ports

func BuildId added in v1.2.0 

func BuildId(buildId string) ZapTag

func BuildIdTaskReachabilityTag added in v1.2.0 

func BuildIdTaskReachabilityTag(buildIdReachability string) ZapTag

BuildIdTaskReachabilityTag returns tag for build id task reachability

func Cause added in v1.2.0 

func Cause(cause string) ZapTag

func CertThumbprint added in v1.2.0 

func CertThumbprint(thumbprint string) ZapTag

CertThumbprint returns tag for CertThumbprint

func ChasmRunID added in v1.2.0 

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 added in v1.2.0 

func DLQMessageID(dlqMessageID int64) ZapTag

func DefaultValue 

func DefaultValue(v any) ZapTag

DefaultValue returns tag for DefaultValue

func DeletedExecutionsCount added in v1.2.0 

func DeletedExecutionsCount(count int) ZapTag

func DeletedExecutionsErrorCount added in v1.2.0 

func DeletedExecutionsErrorCount(count int) ZapTag

func Deployment added in v1.2.0 

func Deployment(d string) ZapTag

func DetailInfo 

func DetailInfo(i string) ZapTag

DetailInfo returns tag for DetailInfo

func Duration added in v1.2.0 

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

func DurationPtr added in v1.2.0 

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

func ESClusterStatus added in v1.2.0 

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 added in v1.2.0 

func ESIndex(index string) ZapTag

func ESKey 

func ESKey(ESKey string) ZapTag

ESKey returns tag for ESKey

func ESMapping added in v1.2.0 

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 added in v1.2.0 

func ESValue(ESValue []byte) ZapTag

ESValue returns tag for ESValue

func Endpoint added in v1.2.0 

func Endpoint(endpoint string) ZapTag

func Env added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

func Float64(key string, value float64) ZapTag

func Host added in v1.2.0 

func Host(h string) ZapTag

Host returns tag for Host

func HostID added in v1.2.0 

func HostID(hid string) ZapTag

HostID return tag for HostID

func IgnoredValue added in v1.2.0 

func IgnoredValue(v any) ZapTag

IgnoredValue returns tag for IgnoredValue

func IncomingVersion 

func IncomingVersion(incomingVersion int64) ZapTag

IncomingVersion returns tag for IncomingVersion

func Int added in v1.2.0 

func Int(key string, value int) ZapTag

func Int32 added in v1.2.0 

func Int32(key string, value int32) ZapTag

func Int64 added in v1.2.0 

func Int64(key string, value int64) ZapTag

func IsRetryable added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

func NewAnyTag(key string, value any) ZapTag

func NewBinaryTag added in v1.2.0 

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

func NewBoolTag added in v1.2.0 

func NewBoolTag(key string, value bool) ZapTag

func NewDurationPtrTag added in v1.2.0 

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

func NewDurationTag added in v1.2.0 

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

func NewErrorTag added in v1.2.0 

func NewErrorTag(key string, value error) ZapTag

func NewFloat64 added in v1.2.0 

func NewFloat64(key string, value float64) ZapTag

func NewInt added in v1.2.0 

func NewInt(key string, value int) ZapTag

func NewInt32 added in v1.2.0 

func NewInt32(key string, value int32) ZapTag

func NewInt64 added in v1.2.0 

func NewInt64(key string, value int64) ZapTag

func NewStringTag added in v1.2.0 

func NewStringTag(key string, value string) ZapTag

func NewStringerTag added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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

func NewTimePtrTag added in v1.2.0 

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

func NewTimeTag added in v1.2.0 

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

func NewUInt32 added in v1.2.0 

func NewUInt32(key string, value uint32) ZapTag

func NewUInt64 added in v1.2.0 

func NewUInt64(key string, value uint64) ZapTag

func NewZapTag added in v1.2.0 

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 NexusOperation added in v1.2.0 

func NexusOperation(operation string) ZapTag

func NexusTaskQueueName added in v1.2.0 

func NexusTaskQueueName(taskQueueName string) ZapTag

NexusTaskQueueName returns tag for NexusTaskQueueName

func Number 

func Number(n int64) ZapTag

Number returns tag for Number

func NumberChanged added in v1.2.0 

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 added in v1.2.0 

func Operation(operation string) ZapTag

Operation returns tag for Operation

func OperationID added in v1.2.0 

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 added in v1.2.0 

func QueryID(queryID string) ZapTag

QueryID returns tag for QueryID

func QueueAlert added in v1.2.0 

func QueueAlert(alert any) ZapTag

QueueAlert returns tag for queue alert

func QueueReaderID added in v1.2.0 

func QueueReaderID(readerID int64) ZapTag

QueueReaderID returns tag for queue readerID

func RPS added in v1.2.0 

func RPS(c int64) ZapTag

RPS returns tag for requests per second

func ReachabilityExitPointTag added in v1.2.0 

func ReachabilityExitPointTag(reachabilityExitPoint string) ZapTag

ReachabilityExitPointTag returns tag for reachabilityExitPoint

func ReadLevel 

func ReadLevel(lv int64) ZapTag

ReadLevel returns tag for ReadLevel

func ReplicationTask added in v1.2.0 

func ReplicationTask(replicationTask any) ZapTag

func RequestCount added in v1.2.0 

func RequestCount(c int) ZapTag

RequestCount returns tag for RequestCount

func RequestID added in v1.2.0 

func RequestID(requestID string) ZapTag

RequestID returns tag for RequestID

func ScheduleAttempt 

func ScheduleAttempt(scheduleAttempt int32) ZapTag

ScheduleAttempt returns tag for ScheduleAttempt

func ScheduleID added in v1.2.0 

func ScheduleID(scheduleID string) ZapTag

ScheduleID returns tag for ScheduleID

func ServerName added in v1.2.0 

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 added in v1.2.0 

func ServiceErrorType(err error) ZapTag

ServiceErrorType returns tag for ServiceErrorType

func ShardContextState added in v1.2.0 

func ShardContextState(state int) ZapTag

ShardContextState returns tag for ShardContextState

func ShardContextStateRequest added in v1.2.0 

func ShardContextStateRequest(r string) ZapTag

ShardContextStateRequest returns tag for ShardContextStateRequest

func ShardID 

func ShardID(shardID int32) ZapTag

ShardID returns tag for ShardID

func ShardQueueAcks added in v1.2.0 

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 added in v1.2.0 

func SourceShardID(shardID int32) ZapTag

func StoreType 

func StoreType(storeType string) ZapTag

StoreType returns tag for StoreType

func String added in v1.2.0 

func String(key string, value string) ZapTag

func Stringer added in v1.2.0 

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

func Stringers added in v1.2.0 

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

func Strings added in v1.2.0 

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

func SysStackTrace 

func SysStackTrace(stackTrace string) ZapTag

SysStackTrace returns tag for SysStackTrace

func TLSCertFile added in v1.2.0 

func TLSCertFile(filePath string) ZapTag

TLSCertFile returns tag for TLS cert file name

func TLSCertFiles added in v1.2.0 

func TLSCertFiles(filePaths []string) ZapTag

TLSCertFiles returns tag for TLS cert file names

func TLSKeyFile added in v1.2.0 

func TLSKeyFile(filePath string) ZapTag

TLSKeyFile returns tag for TLS key file

func TargetCluster added in v1.2.0 

func TargetCluster(targetCluster string) ZapTag

TargetCluster returns tag for TargetCluster

func TargetShardID added in v1.2.0 

func TargetShardID(shardID int32) ZapTag

func Task added in v1.2.0 

func Task(task any) ZapTag

Task returns tag for Task

func TaskCategoryID added in v1.2.0 

func TaskCategoryID(taskCategoryID int) ZapTag

func TaskID 

func TaskID(taskID int64) ZapTag

TaskID returns tag for TaskID

func TaskKey added in v1.2.0 

func TaskKey(key any) ZapTag

TaskKey returns tag for TaskKey

func TaskPriority added in v1.2.0 

func TaskPriority(priority string) ZapTag

TaskPriority returns tag for TaskPriority

func TaskType 

func TaskType(taskType enumsspb.TaskType) ZapTag

func TaskVersion added in v1.2.0 

func TaskVersion(taskVersion int64) ZapTag

TaskVersion returns tag for TaskVersion

func TaskVisibilityTimestamp added in v1.2.0 

func TaskVisibilityTimestamp(timestamp time.Time) ZapTag

TaskVisibilityTimestamp returns tag for task visibilityTimestamp

func Time added in v1.2.0 

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

func TimePtr added in v1.2.0 

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

func Timeout added in v1.2.0 

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 added in v1.2.0 

func TransportType(transportType string) ZapTag

TransportType returns tag for transportType

func UInt32 added in v1.2.0 

func UInt32(key string, value uint32) ZapTag

func UInt64 added in v1.2.0 

func UInt64(key string, value uint64) ZapTag

func URL added in v1.2.0 

func URL(url string) ZapTag

URL returns tag for URL

func UnexpectedErrorAttempts added in v1.2.0 

func UnexpectedErrorAttempts(attempt int32) ZapTag

UnexpectedErrorAttempts returns tag for UnexpectedErrorAttempts

func UserDataVersion added in v1.2.0 

func UserDataVersion(v int64) ZapTag

func Value 

func Value(v any) ZapTag

Value returns tag for Value

func ValueType added in v0.6.0 

func ValueType(v any) ZapTag

ValueType returns tag for ValueType

func VersioningBehavior added in v1.2.0 

func VersioningBehavior(behavior enumspb.VersioningBehavior) ZapTag

func WorkerComponent added in v1.2.0 

func WorkerComponent(v any) ZapTag

func WorkerVersion added in v1.2.0 

func WorkerVersion(version string) ZapTag

WorkerVersion returns tag for worker build ID

func WorkerVersioningAssignmentRuleCount added in v1.2.0 

func WorkerVersioningAssignmentRuleCount(assignmentRuleCount int) ZapTag

WorkerVersioningAssignmentRuleCount returns tag for AssignmentRuleCount

func WorkerVersioningMaxUpstreamBuildIDs added in v1.2.0 

func WorkerVersioningMaxUpstreamBuildIDs(maxUpstreamBuildIDs int) ZapTag

WorkerVersioningMaxUpstreamBuildIDs returns tag for RedirectRuleCount

func WorkerVersioningRedirectRuleCount added in v1.2.0 

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

func WorkflowBinaryChecksum(cs string) ZapTag

WorkflowBinaryChecksum returns tag for WorkflowBinaryChecksum

func WorkflowBranchID 

func WorkflowBranchID(branchID string) ZapTag

WorkflowBranchID returns tag for WorkflowBranchID

func WorkflowBranchToken added in v1.2.0 

func WorkflowBranchToken(branchToken []byte) ZapTag

WorkflowBranchToken returns tag for WorkflowBranchToken

func WorkflowCommandType added in v1.2.0 

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 added in v1.2.0 

func WorkflowMutableStateSize(mutableStateSize int) ZapTag

WorkflowMutableStateSize returns tag for MutableStateSize

func WorkflowNamespace added in v1.2.0 

func WorkflowNamespace(namespace string) ZapTag

WorkflowNamespace returns tag for WorkflowNamespace

func WorkflowNamespaceID added in v1.2.0 

func WorkflowNamespaceID(namespaceID string) ZapTag

WorkflowNamespaceID returns tag for WorkflowNamespaceID TODO: Rename to NamespaceID

func WorkflowNamespaceIDs added in v1.2.0 

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

WorkflowNamespaceIDs returns tag for WorkflowNamespaceIDs

func WorkflowNewRunID added in v1.2.0 

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 WorkflowResetBaseRunID added in v0.5.8 

func WorkflowResetBaseRunID(runID string) ZapTag

WorkflowResetBaseRunID returns tag for WorkflowResetBaseRunID

func WorkflowResetNewRunID added in v0.5.8 

func WorkflowResetNewRunID(runID string) ZapTag

WorkflowResetNewRunID returns tag for WorkflowResetNewRunID

func WorkflowResetNextEventID 

func WorkflowResetNextEventID(resetNextEventID int64) ZapTag

WorkflowResetNextEventID returns tag for WorkflowResetNextEventID

func WorkflowRuleID added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

func WorkflowStartedEventID(startedEventID int64) ZapTag

WorkflowStartedEventID returns tag for WorkflowStartedEventID

func WorkflowStartedTimestamp added in v1.2.0 

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 added in v1.2.0 

func WorkflowTaskFailedCause(workflowTaskFailCause enumspb.WorkflowTaskFailedCause) ZapTag

WorkflowTaskFailedCause returns tag for WorkflowTaskFailedCause

func WorkflowTaskQueueName added in v1.2.0 

func WorkflowTaskQueueName(taskQueueName string) ZapTag

WorkflowTaskQueueName returns tag for WorkflowTaskQueueName

func WorkflowTaskQueueType added in v1.2.0 

func WorkflowTaskQueueType(taskQueueType enumspb.TaskQueueType) ZapTag

WorkflowTaskQueueType returns tag for WorkflowTaskQueueType

func WorkflowTaskRequestId added in v1.2.0 

func WorkflowTaskRequestId(s string) ZapTag

WorkflowTaskRequestId returns a tag for workflow task RequestId

func WorkflowTaskTimeout added in v1.2.0 

func WorkflowTaskTimeout(s time.Duration) ZapTag

WorkflowTaskTimeout returns tag for WorkflowTaskTimeoutSeconds

func WorkflowTaskTimeoutSeconds added in v1.2.0 

func WorkflowTaskTimeoutSeconds(s int64) ZapTag

WorkflowTaskTimeoutSeconds returns tag for WorkflowTaskTimeoutSeconds

func WorkflowTaskType added in v1.2.0 

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 added in v1.2.0 

func Zap(field zap.Field) ZapTag

func (ZapTag) Field added in v1.2.0 

func (t ZapTag) Field() zap.Field

func (ZapTag) Key added in v1.2.0 

func (t ZapTag) Key() string

func (ZapTag) Value added in v1.2.0 

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.