metrics

Documentation

Index

• Constants
• func NewWorkflowServiceWrapper(service m.TChanWorkflowService, scope tally.Scope) m.TChanWorkflowService
• func WrapScope(isReplay *bool, scope tally.Scope, clock Clock) tally.Scope
• type Clock

Constants

const (
	WorkflowStartCounter             = "workflow-start"
	WorkflowCompletedCounter         = "workflow-completed"
	WorkflowCanceledCounter          = "workflow-canceled"
	WorkflowFailedCounter            = "workflow-failed"
	WorkflowContinueAsNewCounter     = "workflow-continue-as-new"
	WorkflowEndToEndLatency          = "workflow-endtoend-latency" // measure workflow execution from start to close
	WorkflowGetHistoryCounter        = "workflow-get-history-total"
	WorkflowGetHistoryFailedCounter  = "workflow-get-history-failed"
	WorkflowGetHistorySucceedCounter = "workflow-get-history-succeed"
	WorkflowGetHistoryLatency        = "workflow-get-history-latency"
	DecisionTimeoutCounter           = "decision-timeout"

	DecisionPollCounter            = "decision-poll-total"
	DecisionPollFailedCounter      = "decision-poll-failed"
	DecisionPollNoTaskCounter      = "decision-poll-no-task"
	DecisionPollSucceedCounter     = "decision-poll-succeed"
	DecisionPollLatency            = "decision-poll-latency" // measure succeed poll request latency
	DecisionExecutionFailedCounter = "decision-execution-failed"
	DecisionExecutionLatency       = "decision-execution-latency"
	DecisionResponseFailedCounter  = "decision-response-failed"
	DecisionResponseLatency        = "decision-response-latency"
	DecisionEndToEndLatency        = "decision-endtoend-latency" // measure from poll request start to response completed
	DecisionTaskPanicCounter       = "decision-task-panic"
	DecisionTaskCompletedCounter   = "decision-task-completed"

	ActivityPollCounter            = "activity-poll-total"
	ActivityPollFailedCounter      = "activity-poll-failed"
	ActivityPollNoTaskCounter      = "activity-poll-no-task"
	ActivityPollSucceedCounter     = "activity-poll-succeed"
	ActivityPollLatency            = "activity-poll-latency"
	ActivityExecutionFailedCounter = "activity-execution-failed"
	ActivityExecutionLatency       = "activity-execution-latency"
	ActivityResponseLatency        = "activity-response-latency"
	ActivityResponseFailedCounter  = "activity-response-failed"
	ActivityEndToEndLatency        = "activity-endtoend-latency"
	ActivityTaskPanicCounter       = "activity-task-panic"
	ActivityTaskCompletedCounter   = "activity-task-completed"
	ActivityTaskFailedCounter      = "activity-task-failed"
	ActivityTaskCanceledCounter    = "activity-task-canceled"

	UnhandledSignalsCounter = "unhandled-signals"

	WorkerStartCounter = "worker-start"
	PollerStartCounter = "poller-start"

	CadenceRequest        = "cadence-request"
	CadenceError          = "cadence-error"
	CadenceLatency        = "cadence-latency"
	CadenceInvalidRequest = "cadence-invalid-request"
)

Workflow Creation metrics

Functions

func NewWorkflowServiceWrapper

func NewWorkflowServiceWrapper(service m.TChanWorkflowService, scope tally.Scope) m.TChanWorkflowService

NewWorkflowServiceWrapper creates a new wrapper to WorkflowService that will emit metrics for each service call.

func WrapScope

func WrapScope(isReplay *bool, scope tally.Scope, clock Clock) tally.Scope

WrapScope wraps a scope and skip recording metrics when isReplay is true. This is designed to be used by only by workflowEnvironmentImpl so we suppress metrics while replaying history events. Parameter isReplay is a pointer to workflowEnvironmentImpl.isReplay which will be updated when replaying history events.

Types

type Clock

type Clock interface {
	Now() time.Time
}

Clock defines interface used as time source