metrics

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2025 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 EmitBlockchainBroadcastTransaction added in v1.0.0 

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

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 EmitGatewayBanlistRetries added in v1.0.0 

func EmitGatewayBanlistRetries(originatorID uint32, retries int)

func EmitGatewayBlockUntilDesiredCursorReached added in v1.0.0 

func EmitGatewayBlockUntilDesiredCursorReached(originatorID uint32, duration float64)

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 EmitIndexerLogProcessingTime added in v0.4.0 

func EmitIndexerLogProcessingTime(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 EmitMigratorDestLastSequenceIDBlockchain added in v0.5.1 

func EmitMigratorDestLastSequenceIDBlockchain(table string, sequenceID int64)

func EmitMigratorDestLastSequenceIDDatabase added in v0.5.1 

func EmitMigratorDestLastSequenceIDDatabase(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 EmitMigratorTransformerError added in v0.5.1 

func EmitMigratorTransformerError(table string)

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.