Versions in this module Expand all Collapse all v1 v1.11.0 Apr 7, 2025 v1.10.1 Apr 7, 2025 Changes in this version + const ActivityExecutionFailedCounter + const ActivityExecutionLatency + const ActivityPollNoTaskCounter + const ActivityScheduleToStartLatency + const ActivitySucceedEndToEndLatency + const ActivityTaskErrorCounter + const ActivityTypeNameTagName + const CauseTagName + const ClientTagName + const ClientTagValue + const CorruptedSignalsCounter + const FailureReasonTagName + const LocalActivityCanceledCounter + const LocalActivityErrorCounter + const LocalActivityExecutionCanceledCounter + const LocalActivityExecutionFailedCounter + const LocalActivityExecutionLatency + const LocalActivityFailedCounter + const LocalActivitySucceedEndToEndLatency + const LocalActivityTotalCounter + const NamespaceTagName + const NexusOperationTagName + const NexusPollNoTaskCounter + const NexusServiceTagName + const NexusTaskEndToEndLatency + const NexusTaskExecutionFailedCounter + const NexusTaskExecutionLatency + const NexusTaskScheduleToStartLatency + const NoneTagValue + const NumPoller + const OperationTagName + const PollerStartCounter + const PollerTypeActivityTask + const PollerTypeNexusTask + const PollerTypeTagName + const PollerTypeWorkflowStickyTask + const PollerTypeWorkflowTask + const RequestFailureCode + const StickyCacheHit + const StickyCacheMiss + const StickyCacheSize + const StickyCacheTotalForcedEviction + const TaskQueueTagName + const TemporalLongRequest + const TemporalLongRequestFailure + const TemporalLongRequestLatency + const TemporalLongRequestResourceExhausted + const TemporalMetricsPrefix + const TemporalRequest + const TemporalRequestFailure + const TemporalRequestLatency + const TemporalRequestResourceExhausted + const UnregisteredActivityInvocationCounter + const WorkerStartCounter + const WorkerTaskSlotsAvailable + const WorkerTaskSlotsUsed + const WorkerTypeTagName + const WorkflowActiveThreadCount + const WorkflowCanceledCounter + const WorkflowCompletedCounter + const WorkflowContinueAsNewCounter + const WorkflowEndToEndLatency + const WorkflowFailedCounter + const WorkflowTaskExecutionFailureCounter + const WorkflowTaskExecutionLatency + const WorkflowTaskNoCompletionCounter + const WorkflowTaskQueuePollEmptyCounter + const WorkflowTaskQueuePollSucceedCounter + const WorkflowTaskReplayLatency + const WorkflowTaskScheduleToStartLatency + const WorkflowTypeNameTagName + func ActivityTags(workflowType, activityType, taskQueueName string) map[string]string + func LocalActivityTags(workflowType, activityType string) map[string]string + func NewGRPCInterceptor(defaultHandler Handler, suffix string, disableRequestFailCodes bool) grpc.UnaryClientInterceptor + func NexusTags(service, operation, taskQueueName string) map[string]string + func NexusTaskFailureTags(reason string) map[string]string + func PollerTags(pollerType string) map[string]string + func RPCTags(workflowType, activityType, taskQueueName string) map[string]string + func RequestFailureCodeTags(statusCode codes.Code) map[string]string + func RootTags(namespace string) map[string]string + func TaskQueueTags(taskQueue string) map[string]string + func WorkerTags(workerType string) map[string]string + func WorkflowTags(workflowType string) map[string]string + func WorkflowTaskFailedTags(reason string) map[string]string + type CapturedCounter struct + func (c *CapturedCounter) Inc(d int64) + func (c *CapturedCounter) Value() int64 + type CapturedGauge struct + func (c *CapturedGauge) Update(d float64) + func (c *CapturedGauge) Value() float64 + type CapturedMetricMeta struct + Name string + Tags map[string]string + type CapturedTimer struct + func (c *CapturedTimer) Record(d time.Duration) + func (c *CapturedTimer) Value() time.Duration + type CapturingHandler struct + func NewCapturingHandler() *CapturingHandler + func (c *CapturingHandler) Clear() + func (c *CapturingHandler) Counter(name string) Counter + func (c *CapturingHandler) Counters() []*CapturedCounter + func (c *CapturingHandler) Gauge(name string) Gauge + func (c *CapturingHandler) Gauges() []*CapturedGauge + func (c *CapturingHandler) Timer(name string) Timer + func (c *CapturingHandler) Timers() []*CapturedTimer + func (c *CapturingHandler) WithTags(tags map[string]string) Handler + type Counter interface + Inc func(int64) + type CounterFunc func(int64) + func (c CounterFunc) Inc(d int64) + type Gauge interface + Update func(float64) + type GaugeFunc func(float64) + func (g GaugeFunc) Update(d float64) + type Handler interface + Counter func(name string) Counter + Gauge func(name string) Gauge + Timer func(name string) Timer + WithTags func(map[string]string) Handler + var NopHandler Handler = nopHandler{} + func NewReplayAwareHandler(replay *bool, underlying Handler) Handler + type HandlerContextKey struct + type LongPollContextKey struct + type Timer interface + Record func(time.Duration) + type TimerFunc func(time.Duration) + func (t TimerFunc) Record(d time.Duration)
Go to main page