metrics

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2026 License: MIT Imports: 18 Imported by: 0

Documentation

Overview

Package metrics implements the Prometheusmetrics for the XMTPD service.

Index

Constants

This section is empty.

Variables

View Source 
var QueryDuration = prometheus.NewHistogramVec(
	prometheus.HistogramOpts{
		Namespace: "db",
		Name:      "query_duration_seconds",
		Help:      "Duration of SQL queries by named statement.",
		Buckets:   []float64{0.001, 0.005, 0.01, 0.025, 0.05, 0.1, 0.25, 0.5, 1, 2.5, 5, 10},
	},
	[]string{"query", "op"},
)
View Source 
var QueryErrors = prometheus.NewCounterVec(
	prometheus.CounterOpts{
		Namespace: "db",
		Name:      "query_errors_total",
		Help:      "Total SQL query errors by named statement.",
	},
	[]string{"query", "op"},
)

Functions

func EmitApiStagedEnvelopeProcessingDelay added in v1.1.0 

func EmitApiStagedEnvelopeProcessingDelay(duration time.Duration)

func EmitApiWaitForGatewayPublish added in v1.1.0 

func EmitApiWaitForGatewayPublish(
	duration time.Duration,
)

func EmitBlockchainBroadcastTransaction added in v1.0.0 

func EmitBlockchainBroadcastTransaction(
	payloadType string,
	status string,
	duration time.Duration,
)

func EmitBlockchainGasPrice added in v1.1.0 

func EmitBlockchainGasPrice(chainID int64, gasPrice uint64)

func EmitBlockchainGasPriceDefaultFallbackTotal added in v1.1.0 

func EmitBlockchainGasPriceDefaultFallbackTotal(chainID int64)

func EmitBlockchainGasPriceLastUpdateTimestamp added in v1.1.0 

func EmitBlockchainGasPriceLastUpdateTimestamp(chainID int64, timestamp int64)

func EmitBlockchainGasPriceUpdatesTotal added in v1.1.0 

func EmitBlockchainGasPriceUpdatesTotal(chainID int64)

func EmitBlockchainPublish added in v0.4.0 

func EmitBlockchainPublish(payloadType string, duration time.Duration)

func EmitBlockchainWaitForTransaction added in v0.4.0 

func EmitBlockchainWaitForTransaction(status string, duration float64)

func EmitGRPCServerHandled added in v1.1.0 

func EmitGRPCServerHandled(grpcType string, service, method string, code connect.Code)

EmitGRPCServerHandled increments the handled counter for a completed RPC.

func EmitGRPCServerHandlingTime added in v1.1.0 

func EmitGRPCServerHandlingTime(grpcType string, service, method string, duration time.Duration)

EmitGRPCServerHandlingTime records the handling duration for an RPC.

func EmitGRPCServerMsgReceived added in v1.1.0 

func EmitGRPCServerMsgReceived(grpcType string, service, method string)

EmitGRPCServerMsgReceived increments the received message counter.

func EmitGRPCServerMsgSent added in v1.1.0 

func EmitGRPCServerMsgSent(grpcType string, service, method string)

EmitGRPCServerMsgSent increments the sent message counter.

func EmitGRPCServerStarted added in v1.1.0 

func EmitGRPCServerStarted(grpcType string, service, method string)

EmitGRPCServerStarted increments the started counter for an RPC.

func EmitGatewayBanlistRetries added in v1.0.0 

func EmitGatewayBanlistRetries(originatorID uint32, retries int)

func EmitGatewayCurrentNonce added in v1.0.0 

func EmitGatewayCurrentNonce(nonce float64)

func EmitGatewayGetNodesAvailableNodes added in v1.0.0 

func EmitGatewayGetNodesAvailableNodes(count int)

func EmitGatewayMessageOriginated added in v1.0.0 

func EmitGatewayMessageOriginated(originatorID uint32, count int)

func EmitGatewayPublishDuration added in v1.0.0 

func EmitGatewayPublishDuration(originatorID uint32, duration float64)

func EmitIndexerCurrentBlock added in v0.2.2 

func EmitIndexerCurrentBlock(contractAddress string, block uint64)

func EmitIndexerCurrentBlockLag added in v0.2.2 

func EmitIndexerCurrentBlockLag(contractAddress string, lag uint64)

func EmitIndexerGetLogsDuration added in v0.2.2 

func EmitIndexerGetLogsDuration(contractAddress string, duration time.Duration)

func EmitIndexerLogBytesIndexed added in v1.1.0 

func EmitIndexerLogBytesIndexed(contractAddress string, bytes int)

func EmitIndexerLogProcessingTime added in v0.4.0 

func EmitIndexerLogProcessingTime(contractAddress string, duration time.Duration)

func EmitIndexerMaxBlock added in v0.2.2 

func EmitIndexerMaxBlock(contractAddress string, block uint64)

func EmitIndexerNumLogsFound added in v0.2.2 

func EmitIndexerNumLogsFound(contractAddress string, numLogs int)

func EmitIndexerRetryableStorageError added in v0.2.2 

func EmitIndexerRetryableStorageError(contractAddress string)

func EmitMigratorDestLastSequenceID added in v1.1.0 

func EmitMigratorDestLastSequenceID(table string, sequenceID int64)

func EmitMigratorE2ELatency added in v0.5.1 

func EmitMigratorE2ELatency(table, destination string, duration float64)

func EmitMigratorReaderError added in v0.5.1 

func EmitMigratorReaderError(table, errorType string)

func EmitMigratorReaderFetchDuration added in v0.5.1 

func EmitMigratorReaderFetchDuration(table string, duration float64)

func EmitMigratorReaderNumRowsFound added in v0.5.1 

func EmitMigratorReaderNumRowsFound(table string, numRows int64)

func EmitMigratorSourceLastSequenceID added in v0.5.1 

func EmitMigratorSourceLastSequenceID(table string, sequenceID int64)

func EmitMigratorTargetLastSequenceID added in v1.1.0 

func EmitMigratorTargetLastSequenceID(table string, sequenceID int64)

func EmitMigratorTransformerError added in v0.5.1 

func EmitMigratorTransformerError(table string)

func EmitMigratorWriterBytesMigrated added in v1.1.0 

func EmitMigratorWriterBytesMigrated(table string, destination string, bytes int)

func EmitMigratorWriterError added in v0.5.1 

func EmitMigratorWriterError(table, destination, errorType string)

func EmitMigratorWriterLatency added in v0.5.1 

func EmitMigratorWriterLatency(table, destination string, duration float64)

func EmitMigratorWriterRetryAttempts added in v0.5.1 

func EmitMigratorWriterRetryAttempts(table, destination string, attempts int)

func EmitMigratorWriterRowsMigrated added in v0.5.1 

func EmitMigratorWriterRowsMigrated(table string, numRows int64)

func EmitNewConnectionRequestVersion added in v0.3.0 

func EmitNewConnectionRequestVersion(version string)

func EmitNewFailedGRPCRequest added in v0.4.0 

func EmitNewFailedGRPCRequest(code connect.Code)

func EmitSyncLastSeenOriginatorSequenceID added in v0.5.1 

func EmitSyncLastSeenOriginatorSequenceID(originatorID uint32, lastSequence uint64)

func EmitSyncOriginatorErrorMessages added in v0.2.2 

func EmitSyncOriginatorErrorMessages(originatorID uint32, count int)

func EmitSyncOriginatorReceivedMessagesCount added in v0.2.2 

func EmitSyncOriginatorReceivedMessagesCount(originatorID uint32, count int)

func MeasureBroadcastTransaction added in v1.0.0 

func MeasureBroadcastTransaction[Return any](
	payloadType string,
	fn func() (Return, error),
) (Return, error)

func MeasureGetLogs 

func MeasureGetLogs[Return any](contractAddress string, fn func() (Return, error)) (Return, error)

func MeasurePublishToBlockchainMethod added in v0.4.0 

func MeasurePublishToBlockchainMethod[Return any](
	payloadType string,
	fn func() (Return, error),
) (Return, error)

func MeasureReaderLatency added in v0.5.1 

func MeasureReaderLatency[Return any](table string, fn func() (Return, error)) (Return, error)

func MeasureWaitForTransaction added in v1.0.0 

func MeasureWaitForTransaction[Return any](
	fn func() (Return, error),
) (Return, error)

func MeasureWriterLatency added in v0.5.1 

func MeasureWriterLatency(
	table, destination string,
	fn func() error,
) error

Types

type APIOpenConnection added in v0.5.1 

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

func NewAPIOpenConnection added in v0.5.1 

func NewAPIOpenConnection(style string, method string) *APIOpenConnection

func (*APIOpenConnection) Close added in v0.5.1 

func (oc *APIOpenConnection) Close()

type IncomingConnectionTracker added in v0.3.0 

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

func NewIncomingConnectionTracker added in v0.3.0 

func NewIncomingConnectionTracker(version string) *IncomingConnectionTracker

func (*IncomingConnectionTracker) Close added in v0.3.0 

func (ct *IncomingConnectionTracker) Close()

func (*IncomingConnectionTracker) Open added in v0.3.0 

func (ct *IncomingConnectionTracker) Open()

type PromLogger added in v1.0.0 

type PromLogger struct{}

func (PromLogger) Log added in v1.0.0 

func (PromLogger) Log(
	ctx context.Context,
	level tracelog.LogLevel,
	msg string,
	data map[string]any,
)

type Server 

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

func NewMetricsServer 

func NewMetricsServer(
	ctx context.Context,
	address string,
	port int,
	logger *zap.Logger,
	reg *prometheus.Registry,
) (*Server, error)

func (*Server) Close 

func (s *Server) Close()

type SyncConnectionsStatusCounter added in v0.2.2 

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

func NewSyncConnectionsStatusCounter added in v0.2.2 

func NewSyncConnectionsStatusCounter(originatorID uint32) *SyncConnectionsStatusCounter

func (*SyncConnectionsStatusCounter) Close added in v0.2.2 

func (fc *SyncConnectionsStatusCounter) Close()

func (*SyncConnectionsStatusCounter) MarkFailure added in v0.2.2 

func (fc *SyncConnectionsStatusCounter) MarkFailure()

func (*SyncConnectionsStatusCounter) MarkSuccess added in v0.2.2 

func (fc *SyncConnectionsStatusCounter) MarkSuccess()

Source Files

View all Source files

Directories

Path Synopsis

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.