metrics

Documentation

Index

• Variables

Variables

var (
	TagContractMethodName = insmetrics.MustTagKey("vm_execution_contract_method_name")
	TagContractPrototype  = insmetrics.MustTagKey("vm_execution_contract_prototype")
)

var (
	ExecutionBrokerOnPulseTiming = stats.Float64(
		"vm_execution_broker_onpulse_timing",
		"time spent on pulse in execution broker",
		stats.UnitMilliseconds,
	)
	ExecutionBrokerOnPulseNotConfirmed = stats.Int64(
		"vm_execution_broker_onpulse_notconfirmed",
		"not confirmed execution brokers",
		stats.UnitDimensionless,
	)
)

var (
	ExecutionBrokerTruncatedRequests = stats.Int64(
		"vm_execution_broker_onpulse_truncated",
		"execution broker truncated requests onpulse",
		stats.UnitDimensionless,
	)
	ExecutionBrokerTranscriptRegistered = stats.Int64(
		"vm_execution_broker_transcript_new",
		"execution broker new transcript registered",
		stats.UnitDimensionless,
	)
	ExecutionBrokerTranscriptDuplicate = stats.Int64(
		"vm_execution_broker_transcript_duplicate",
		"execution broker duplicate transcript registered",
		stats.UnitDimensionless,
	)
	ExecutionBrokerTranscriptExecuting = stats.Int64(
		"vm_execution_broker_transcript_executing",
		"execution broker already executing transcript",
		stats.UnitDimensionless,
	)
	ExecutionBrokerTranscriptAlreadyRegistered = stats.Int64(
		"vm_execution_broker_transcript_already_registered",
		"execution broker already registered transcript",
		stats.UnitDimensionless,
	)
)

var (
	ExecutionBrokerExecutionStarted = stats.Int64(
		"vm_execution_broker_execution_started",
		"execution broker started execution",
		stats.UnitDimensionless,
	)
	ExecutionBrokerExecutionFinished = stats.Int64(
		"vm_execution_broker_execution_finished",
		"execution broker started execution",
		stats.UnitDimensionless,
	)
)

var (
	TagHandlePayloadType = insmetrics.MustTagKey("vm_handle_payload_type")

	TagFinishedWithError = insmetrics.MustTagKey("vm_handle_finished_with_error")
)

var (
	HandleStarted = stats.Int64(
		"vm_handle_started",
		"started message handling",
		stats.UnitDimensionless,
	)
	HandleFinished = stats.Int64(
		"vm_handle_finished",
		"finished message handling",
		stats.UnitDimensionless,
	)
	HandleFuture = stats.Int64(
		"vm_handle_future",
		"handling messages from future pulse",
		stats.UnitDimensionless,
	)
	HandlePast = stats.Int64(
		"vm_handle_past",
		"handling messages from previous pulse",
		stats.UnitDimensionless,
	)
	HandlePastFlowCancelled = stats.Int64(
		"vm_handle_past_flow_cancelled",
		"handling messages from previous pulse that flow cancelled",
		stats.UnitDimensionless,
	)
	HandleTiming = stats.Float64(
		"vm_handle_latency",
		"time spent on handling messages",
		stats.UnitMilliseconds,
	)

	HandlingParsingError = stats.Int64(
		"vm_handle_parsing_error",
		"handling messages that could not be parsed",
		stats.UnitDimensionless,
	)
)

common handling stats

var (
	CallMethodLogicalError = stats.Int64(
		"vm_call_method_logical_error",
		"call method with logical error",
		stats.UnitDimensionless,
	)
	CallMethodAdditionalCall = stats.Int64(
		"vm_call_method_additional_call",
		"call method with additional call",
		stats.UnitDimensionless,
	)
	CallMethodLoopDetected = stats.Int64(
		"vm_call_method_loop_detected",
		"call method with loop detected",
		stats.UnitDimensionless,
	)
)

CallMethod specific stats

var (
	IncomingRequestsNew = stats.Int64(
		"vm_incoming_request_new",
		"New IncomingRequests created",
		stats.UnitDimensionless,
	)
	IncomingRequestsDuplicate = stats.Int64(
		"vm_incoming_request_duplicate",
		"Duplicated IncomingRequests registered",
		stats.UnitDimensionless,
	)
	IncomingRequestsClosed = stats.Int64(
		"vm_incoming_request_closed",
		"Duplicated IncomingRequests with results",
		stats.UnitDimensionless,
	)
)

IncomingRequests related stats

var (
	OutgoingRequestsNew = stats.Int64(
		"vm_outgoing_request_new",
		"New OutgoingRequests created",
		stats.UnitDimensionless,
	)
	OutgoingRequestsDuplicate = stats.Int64(
		"vm_outgoing_request_duplicate",
		"Duplicated OutgoingRequests registered",
		stats.UnitDimensionless,
	)
	OutgoingRequestsClosed = stats.Int64(
		"vm_outgoing_request_closed",
		"Duplicated OutgoingRequests with results",
		stats.UnitDimensionless,
	)
)

OutgoingRequests related stats

var (
	RequestFetcherFetchCall = stats.Int64(
		"vm_request_fetcher_fetch_call",
		"RequestFetcher fetch calls",
		stats.UnitDimensionless,
	)
	RequestFetcherFetchUnique = stats.Int64(
		"vm_request_fetcher_fetch_unique",
		"RequestFetcher fetch unique responses",
		stats.UnitDimensionless,
	)
	RequestFetcherFetchKnown = stats.Int64(
		"vm_request_fetcher_fetch_known",
		"RequestFetcher fetch known responses",
		stats.UnitDimensionless,
	)
)

var (
	ResultsMatcherAddStillExecution = stats.Int64(
		"vm_results_matcher_still_execution",
		"AddStillExecution calls",
		stats.UnitDimensionless,
	)
	ResultsMatcherAddUnwantedResponse = stats.Int64(
		"vm_results_matcher_unwanted_response",
		"AddUnwantedResponse calls",
		stats.UnitDimensionless,
	)

	ResultsMatcherSentResults = stats.Int64(
		"vm_results_matcher_sent_results",
		"sent results to executor",
		stats.UnitDimensionless,
	)
	ResultsMatcherDroppedResults = stats.Int64(
		"vm_results_matcher_dropped_results",
		"dropped results in pulse",
		stats.UnitDimensionless,
	)
)

var (
	ContractExecutionTime = stats.Float64(
		"vm_contracts_timing",
		"time spent executing contract",
		stats.UnitMilliseconds,
	)
)

var (
	ExecutorResultsRequestsFromPrevExecutor = stats.Int64(
		"vm_executor_results_prev_executor",
		"ExecutorResults with AddRequestsFromPrevExecutor calls",
		stats.UnitDimensionless,
	)
)

ExecutorResults specific stats

var (
	HandleUnknownMessageType = stats.Int64(
		"vm_handle_unknown_message",
		"handling unknown message type",
		stats.UnitDimensionless,
	)
)

unknown message type error

var (
	LogicRunnerOnPulseTiming = stats.Float64(
		"vm_logicrunner_onpulse_timing",
		"time spent on pulse change of LogicRunner",
		stats.UnitMilliseconds,
	)
)

var (
	OutgoingSenderActorGoroutines = stats.Int64(
		"vm_outgoing_sender_goroutines",
		"OutgoingSender goroutines",
		stats.UnitDimensionless,
	)
)

var (
	PendingFinishedAlreadyExecuting = stats.Int64(
		"vm_pending_finished_already_executing",
		"PendingFinished with AlreadyExecuting error",
		stats.UnitDimensionless,
	)
)

PendingFinished specific stats

var (
	PulseManagerOnPulseTiming = stats.Float64(
		"vm_pulse_manager_onpulse_timing",
		"time spent on pulse set in pulsemanager",
		stats.UnitMilliseconds,
	)
)

var (
	StillExecutingAlreadyExecuting = stats.Int64(
		"vm_still_executing_already_executing",
		"StillExecuting with AlreadyExecuting error",
		stats.UnitDimensionless,
	)
)

StillExecuting specific stats

var (
	TagExecutionQueueName = insmetrics.MustTagKey("vm_execution_broker_queue_name")
)