metrics

package
v0.3.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2023 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Common.
	AppVersion       = "app_version"
	AppInfo          = "app_info"
	BlockHeight      = "block_height"
	Count            = "count"
	Detail           = "detail"
	Deterministic    = "deterministic"
	Error            = "error"
	GitCommit        = "git_commit"
	HttpGet5xx       = "http_get_5xx"
	HttpGetHangup    = "http_get_hangup"
	HttpGetRequest   = "http_get_request"
	HttpGetResponse  = "http_get_response"
	HttpGetTimeout   = "http_get_timeout"
	Invalid          = "invalid"
	Latency          = "latency"
	Matched          = "matched"
	MessageType      = "message_type"
	Negative         = "negative"
	No               = "no"
	NonDeterministic = "non_deterministic"
	Positive         = "positive"
	Reason           = "reason"
	Received         = "received"
	Rejected         = "rejected"
	SequenceNumber   = "sequence_number"
	Success          = "success"
	Valid            = "valid"
	ValidateBasic    = "validate_basic"
	Yes              = "yes"
	CheckTx          = "check_tx"
	DeliverTx        = "deliver_tx"
	ProcessProposal  = "process_proposal"

	// Common (Daemons).
	MainTaskLoop = "main_task_loop"

	// ABCI: Prepare / Process
	AcknowledgeBridgesTx = "acknowledge_bridges_tx"
	ConsensusRound       = "consensus_round"
	DisallowMsg          = "disallow_msg"
	Decode               = "decode"
	FundingTx            = "funding_tx"
	GetTxsInOrder        = "get_txs_in_order"
	Handler              = "handler"
	NumOtherTxs          = "num_other_txs"
	OperationsTx         = "operations_tx"
	OriginalNumTxs       = "original_num_txs"
	OtherTxs             = "other_txs"
	RemoveDisallowMsgs   = "remove_disallow_msgs"
	PrepareProposalTxs   = "prepare_proposal_txs"
	PrepareCheckState    = "prepare_check_state"
	PricesTx             = "prices_tx"
	TotalNumBytes        = "total_num_bytes"
	TotalNumTxs          = "total_num_txs"
	Validate             = "validate"

	// Bridge.
	AcknowledgeBridges            = "acknowledge_bridges"
	AcknowledgedEventInfo         = "acknowledged_event_info"
	BridgeTokenDenom              = "bridge_token_denom"
	CompleteBridge                = "complete_bridge"
	GetAcknowledgeBridges         = "get_acknowledge_bridges"
	LastBridgeEventId             = "last_bridge_event_id"
	LastBridgeEventEthBlockHeight = "last_bridge_event_eth_block_height"
	LastCompletedBridgeId         = "last_completed_bridge_id"
	NextAcknowledgedEventId       = "next_acknowledge_event_id"
	NumBridges                    = "num_bridges"
	UnbridgedBalance              = "unbridged_balance"

	// Bridge Daemon.
	BridgeDaemon = "bridge_daemon"
	NewEthLogs   = "new_eth_logs"

	// Bridge Server.
	AddBridgeEvents          = "add_bridge_events"
	BridgeServer             = "bridge_server"
	EthBlockHeight           = "eth_block_height"
	EventIdAlreadyRecognized = "event_id_already_recognized"
	EventIdNotSequential     = "event_id_not_sequential"
	NextId                   = "next_id"
	RecognizedEventInfo      = "recognized_event_info"

	// CLOB.
	AddPerpetualFillAmount                       = "add_perpetual_fill_amount"
	BaseQuantums                                 = "base_quantums"
	BestAskClobPair                              = "best_ask_clob_pair"
	BestBidClobPair                              = "best_bid_clob_pair"
	CancelOrder                                  = "cancel_order"
	CancelOrderSubaccounts                       = "cancel_order_subaccounts"
	CancelShortTermOrder                         = "cancel_short_term_order"
	CancelStatefulOrder                          = "cancel_stateful_order"
	ClobPairId                                   = "clob_pair_id"
	CollateralizationCheck                       = "place_order_collateralization_check"
	CollateralizationCheckSubaccounts            = "collateralization_check_subaccounts"
	Conditional                                  = "conditional"
	ConditionalOrderTriggered                    = "conditional_order_triggered"
	ConditionalOrderUntriggered                  = "conditional_order_untriggered"
	ConvertToUpdates                             = "convert_to_updates"
	Expired                                      = "expired"
	GetFillQuoteQuantums                         = "get_fill_quote_quantums"
	Hydrate                                      = "hydrate"
	IterateOverPendingMatches                    = "iterate_over_pending_matches"
	NumConditionalOrderRemovals                  = "num_conditional_order_removals"
	NumFills                                     = "num_fills"
	NumLongTermOrderRemovals                     = "num_long_term_order_removals"
	NumMatchPerpDeleveragingOperations           = "num_match_perp_deleveraging_operations"
	NumMatchPerpLiquidationsOperations           = "num_match_perp_liquidations_operations"
	NumMatchStatefulOrders                       = "num_match_stateful_orders"
	NumMatchTakerOrders                          = "num_match_taker_orders"
	NumMatchedOrdersInOperationsQueue            = "num_matched_orders_in_operations_queue"
	NumMatchedConditionalOrders                  = "num_match_conditional_orders"
	NumMatchedLiquidationOrders                  = "num_match_liquidation_orders"
	NumMatchedLongTermOrders                     = "num_match_long_term_orders"
	NumMatchedShortTermOrders                    = "num_match_short_term_orders"
	NumOffsettingSubaccountsForDeleveraging      = "num_offsetting_subaccounts_for_deleveraging"
	NumProposedOperations                        = "num_proposed_operations"
	NumShortTermOrderTxBytes                     = "num_short_term_order_tx_bytes"
	NumUniqueSubaccountsDeleveraged              = "num_unique_subaccounts_deleveraged"
	NumUniqueSubaccountsLiquidated               = "num_unique_subaccounts_liquidated"
	NumUniqueSubaccountsOffsettingDeleveraged    = "num_unique_subaccounts_offsetting_deleveraged"
	OffsettingSubaccountPerpetualPosition        = "offsetting_subaccount_perpetual_position"
	OperationsQueueLength                        = "operations_queue_length"
	OrderConflictsWithClobPairStatus             = "order_conflicts_with_clob_pair_status"
	OrderFlag                                    = "order_flag"
	OrderSide                                    = "order_side"
	PlaceOrder                                   = "place_order"
	PlaceOrderSubaccounts                        = "place_order_subaccounts"
	ProcessMatches                               = "process_matches"
	ProcessOperations                            = "process_operations"
	Proposer                                     = "proposer"
	RateLimit                                    = "rate_limit"
	ReduceOnly                                   = "reduce_only"
	RemovalReason                                = "removal_reason"
	SortLiquidationOrders                        = "sort_liquidation_orders"
	SendCancelOrderOffchainUpdates               = "send_cancel_order_offchain_updates"
	SendPlaceOrderOffchainUpdates                = "send_place_order_offchain_updates"
	SendPlacePerpetualLiquidationOffchainUpdates = "send_perpetual_liquidation_offchain_updates"
	SendPrepareCheckStateOffchainUpdates         = "send_prepare_check_state_offchain_updates"
	SendProcessProposerMatchesOffchainUpdates    = "send_process_proposer_matches_offchain_updates"
	SendProposedOperationsOffchainUpdates        = "send_proposed_operations_offchain_updates"
	SendPurgeOffchainUpdates                     = "send_purge_offchain_updates"
	SendUncrossOffchainUpdates                   = "send_uncross_offchain_updates"
	ShortTermOrder                               = "short_term_order"
	StatefulCancellationMsgHandlerSuccess        = "stateful_cancellation_msg_handler_success"
	StatefulOrder                                = "stateful_order"
	StatefulOrderMsgHandlerSuccess               = "stateful_order_msg_handler_success"
	StatefulOrderRemoved                         = "stateful_order_removed"
	SubaccountPendingMatches                     = "subaccount_pending_matches"
	TimeInForce                                  = "time_in_force"
	TotalOrdersClobPair                          = "total_orders_in_clob"
	UnfilledLiquidationOrders                    = "unfilled_liquidation_orders"
	UnknownPlaceOrders                           = "unknown_place_orders"
	UnverifiedStatefulOrderRemoval               = "unverified_stateful_order_removal"
	ValidateMatches                              = "validate_matches"
	ValidateOrder                                = "validate_order"

	// MemCLOB.
	AddedToOrderBook                     = "added_to_orderbook"
	AddToOrderbookCollateralizationCheck = "add_to_orderbook_collateralization_check"
	Memclob                              = "memclob"
	RemovedFromOrderBook                 = "removed_from_orderbook"

	// Daemon
	DaemonServer    = "daemon_server"
	ValidResponse   = "valid_response"
	MissingResponse = "missing_response"

	// Epochs.
	EpochInfoName = "epoch_name"
	EpochNumber   = "epoch_number"
	IsEpochOne    = "is_epoch_one"

	// Perpetuals.
	AddPremiumSamples            = "add_premium_samples"
	AddPremiumVotes              = "add_premium_votes"
	GetMarginRequirements        = "get_margin_requirements"
	GetNetNotional               = "get_net_notional"
	GetNotionalInBaseQuantums    = "get_notional_in_base_quantums"
	GetPerpetualAndMarketPrice   = "get_perpetual_and_market_price"
	GetAllPerpetualPricePremiums = "get_all_perpetual_price_premiums"
	NewPremiumVotes              = "new_premium_votes"
	NumPremiumsFromEpoch         = "num_premiums_from_epoch"
	MissingIndexPriceForFunding  = "missing_index_price_for_funding"
	NumPremiumVotes              = "num_premium_votes"
	PerpetualTicker              = "perpetual_ticker"
	PerpetualId                  = "perpetual_id"
	PremiumRate                  = "premium_rate"
	PremiumSampleValue           = "premium_sample_value"
	PremiumType                  = "premium_type"

	// Rewards.
	GetRewardShare                   = "get_reward_share"
	ProcessRewardsForBlock           = "process_rewards_for_block"
	TotalRewardShareWeight           = "total_reward_share_weight"
	DistributedRewardTokens          = "distributed_reward_tokens"
	TreasuryBalanceAfterDistribution = "treasury_balance_after_distribution"

	// Vest.
	GetVestEntry          = "get_vest_entry"
	VestAmount            = "vest_amount"
	BalanceAfterVestEvent = "balance_after_vest_event"
	VesterAccount         = "vester_account"

	// Block Time.
	BlockTimeMs = "block_time_ms"

	// Prices.
	CurrentMarketPrices                          = "current_market_prices"
	GetValidMarketPriceUpdates                   = "get_valid_market_price_updates"
	IndexPriceDoesNotExist                       = "index_price_does_not_exist"
	IndexPriceIsZero                             = "index_price_is_zero"
	IndexPriceNotAccurate                        = "index_price_not_accurate"
	IndexPriceNotAvailForAccuracyCheck           = "index_price_not_available_for_accuracy_check"
	LastPriceUpdateForMarketBlock                = "last_price_update_for_market_block"
	MissingPriceUpdates                          = "missing_price_updates"
	NumMarketPricesToUpdate                      = "num_market_prices_to_update"
	PriceChangeRate                              = "price_change_rate"
	ProposedPriceChangesPriceUpdateDecision      = "proposed_price_changes_price_update_decision"
	ProposedPriceCrossesOraclePrice              = "proposed_price_crosses_oracle_price"
	ProposedPriceDoesNotMeetMinPriceChange       = "proposed_price_does_not_meet_min_price_change"
	RecentSmoothedPriceDoesNotMeetMinPriceChange = "recent_smoothed_price_doesnt_meet_min_price_change"
	RecentSmoothedPriceCrossesOraclePrice        = "recent_smoothed_price_crosses_old_price"
	StatefulPriceUpdateValidation                = "stateful_price_update_validation"
	UpdateMarketPrices                           = "update_market_prices"
	UpdateSmoothedPrices                         = "update_smoothed_prices"

	// Sending.
	Account                       = "account"
	New                           = "new"
	ProcessTransfer               = "process_transfer"
	Transfer                      = "transfer"
	ProcessDepositToSubaccount    = "process_deposit_to_subaccount"
	ProcessWithdrawFromSubaccount = "process_withdraw_from_subaccount"
	AssetId                       = "asset_id"
	SenderAddress                 = "sender_address"
	SenderSubaccount              = "sender_subaccount"
	RecipientAddress              = "recipient_address"
	RecipientSubaccount           = "recipient_subaccount"

	// Subaccount.
	CanUpdateSubaccounts                  = "can_update_subaccounts"
	GetNetCollateralAndMarginRequirements = "get_net_collateral_and_margin_requirements"
	GetSubaccount                         = "get_subaccount"
	UpdateSubaccounts                     = "update_subaccounts"

	// Liquidation Daemon.
	CheckCollateralizationForSubaccounts = "check_collateralization_for_subaccounts"
	GetAllSubaccounts                    = "get_all_subaccounts"
	GetLiquidatableSubaccountIds         = "get_liquidatable_subaccount_ids"
	GetSubaccountsFromKey                = "get_subaccounts_from_key"
	LiquidatableSubaccountIds            = "liquidatable_subaccount_ids"
	LiquidationDaemon                    = "liquidation_daemon"
	PageLimit                            = "page_limit"
	SendLiquidatableSubaccountIds        = "send_liquidatable_subaccount_ids"
	SubaccountsWithOpenPositions         = "subaccounts_with_open_positions"

	// Liquidation.
	InsuranceFundBalance                  = "insurance_fund_balance"
	InsuranceFundDelta                    = "insurance_fund_delta"
	Liquidations                          = "liquidations"
	MaybeGetLiquidationOrder              = "maybe_get_liquidation_order"
	PlacePerpetualLiquidation             = "place_perpetual_liquidation"
	ProcessLiquidationMatches             = "process_liquidation_matches"
	SubaccountsNotLiquidatable            = "subaccounts_not_liquidatable"
	LiquidationOrderNotionalQuoteQuantums = "liquidation_order_notional_quote_quantums"
	Liquidated                            = "liquidated"
	Filled                                = "filled"
	SubaccountMaxInsuranceLost            = "exceeds_subaccount_max_insurance_lost"
	SubaccountMaxNotionalLiquidated       = "exceeds_subaccount_max_notional_liquidated"
	LiquidationRequiresDeleveraging       = "liquidation_requires_deleveraging"

	// Deleveraging.
	CannotDeleverageSubaccount     = "cannot_deleverage_subaccount"
	DeleverageSubaccount           = "deleverage_subaccount"
	Deleveraging                   = "deleveraging"
	DeltaQuoteQuantums             = "delta_quote_quantums"
	NumSubaccountsIterated         = "num_subaccounts_iterated"
	NotEnoughPositionToFullyOffset = "not_enough_position_to_fully_offset"
	NonOverlappingBankruptcyPrices = "non_overlapping_bankruptcy_prices"

	// Pricefeed Daemon.
	Exchange                                = "exchange"
	ExchangeQueryHandlerApiRequest          = "exchange_query_handler_api_request"
	ExchangeSpecificError                   = "exchange_specific_error"
	GetAllPrices_MarketIdToPrice            = "get_all_prices_market_id_to_price"
	PriceEncoderUpdatePrice                 = "price_encoder_update_price"
	PricefeedDaemon                         = "pricefeed_daemon"
	ConfiguredMarketCount                   = "configured_market_count"
	ConfiguredMarketCountPerExchange        = "configured_market_count_per_exchange"
	ConfiguredExchangeCountPerMarket        = "configured_exchange_count_per_market"
	MarketUpdaterGetAllMarketParams         = "market_updater_get_all_market_params"
	MarketUpdaterApplyMarketUpdates         = "market_updater_apply_market_updates"
	MarketUpdaterUpdateMarkets              = "market_updater_update_markets"
	PriceEncoderPriceConversion             = "price_encoder_price_conversion"
	PriceFetcherQueryExchange               = "price_fetcher_query_exchange"
	PriceFetcherSubtaskLoop                 = "price_fetcher_subtask_loop"
	PriceFetcherSubtaskLoopAndSetCtxTimeout = "price_fetcher_subtask_loop_and_set_ctx_timeout"
	PriceUpdateCount                        = "price_update_count"
	PriceUpdaterSendPrices                  = "price_updater_send_prices"
	PriceUpdaterTaskLoop                    = "price_updater_task_loop"
	PriceUpdaterTransformPrices             = "price_updater_transform_prices"
	PriceUpdaterZeroPrices                  = "price_updater_zero_prices"

	// Pricefeed Server.
	GetValidPrices                = "get_valid_prices"
	ValidPrices                   = "valid_prices"
	NoMarketPrice                 = "no_market_price"
	NoValidMedianPrice            = "no_valid_median_price"
	PricefeedServer               = "pricefeed_server"
	PricefeedServerUpdatePrices   = "pricefeed_server_update_prices"
	PricefeedServerValidatePrices = "pricefeed_server_validate_prices"
	PriceIsInvalid                = "price_is_invalid"

	// Shared Pricefeed Server and Daemon.
	UpdatePrice = "update_price"

	// msgsender
	MessageSendSuccess    = "message_send_success"
	MessageSendError      = "message_send_error"
	SendOffchainData      = "send_offchain_data"
	SendOnchainData       = "send_onchain_data"
	OnchainMessageLength  = "onchain_message_length"
	OffchainMessageLength = "offchain_message_length"

	// Indexer events.
	TotalNumIndexerBlockEvents = "total_num_block_events"
	TotalNumIndexerTxnEvents   = "total_num_txn_events"

	// Mev.
	Mev                            = "mev"
	MevSentDatapoints              = "mev_num_sent_datapoints"
	MidPrice                       = "mid_price"
	MissingMidPrice                = "missing_mid_price"
	ProposerNumFills               = "proposer_num_fills"
	ProposerNumMatchedTakerOrders  = "proposer_num_matched_taker_orders"
	ProposerVolumeQuoteQuantums    = "proposer_volume_quote_quantums"
	ValidatorNumFills              = "validator_num_fills"
	ValidatorNumMatchedTakerOrders = "validator_num_matched_taker_orders"
	ValidatorVolumeQuoteQuantums   = "validator_volume_quote_quantums"
)

Keep the metric fields alphabetized within each category.

View Source 
const (
	// Price labels.
	ExchangeId = "exchange_id"
	MarketId   = "market_id"
	StatusCode = "status_code"

	Callback = "callback"

	Daemon = "daemon"
)

Variables

This section is empty.

Functions

func GetLabelForBoolValue 

func GetLabelForBoolValue(labelName string, labelValue bool) gometrics.Label

GetLabelForBoolValue returns a telemetry label for a given label and bool value.

func GetLabelForIntValue 

func GetLabelForIntValue(labelName string, labelValue int) gometrics.Label

GetLabelForIntValue returns a telemetry label for a given label and int value.

func GetLabelForStringValue 

func GetLabelForStringValue(labelName string, labelValue string) gometrics.Label

GetLabelForStringValue returns a telemetry label for a given label and string value.

func GetMetricValueFromBigInt 

func GetMetricValueFromBigInt(i *big.Int) float32

GetMetricValueFromBigInt returns a telemetry value (float32) from an integer value. Any rounding information is ignored, so this function should only be used for metrics.

func IncrCountMetricWithLabels 

func IncrCountMetricWithLabels(module string, metric string, labels ...gometrics.Label)

IncrCountMetricWithLabels increases a count metric from a module with the provided labels by a count of 1.

func ModuleMeasureSinceWithLabels 

func ModuleMeasureSinceWithLabels(
	module string,
	keys []string,
	start time.Time,
	labels []gometrics.Label,
)

ModuleMeasureSinceWithLabels provides a short hand method for emitting a time measure metric for a module with a given set of keys and labels. NOTE: global labels are not included in this metric.

func NewBinaryStringLabel 

func NewBinaryStringLabel(metricName string, condition bool) gometrics.Label

NewBinaryStringLabel returns a metrics label with a value of "yes" or "no" depending on the condition.

Types

This section is empty.

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.