metrics

package

v0.5.0 Latest Latest Go to latest Published: Aug 12, 2025 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xmtp/xmtpd

Links

Open Source Insights

Documentation ¶

Index ¶

func EmitBlockchainPublish(payloadType string, duration time.Duration)
func EmitBlockchainWaitForTransaction(duration float64)
func EmitIndexerCurrentBlock(contractAddress string, block uint64)
func EmitIndexerCurrentBlockLag(contractAddress string, lag uint64)
func EmitIndexerGetLogsDuration(contractAddress string, duration time.Duration)
func EmitIndexerLogProcessingTime(duration time.Duration)
func EmitIndexerMaxBlock(contractAddress string, block uint64)
func EmitIndexerNumLogsFound(contractAddress string, numLogs int)
func EmitIndexerRetryableStorageError(contractAddress string)
func EmitNewConnectionRequestVersion(version string)
func EmitNewFailedGRPCRequest(code codes.Code)
func EmitPayerBanlistRetries(originatorId uint32, retries int)
func EmitPayerBlockUntilDesiredCursorReached(originatorId uint32, duration float64)
func EmitPayerCurrentNonce(nonce float64)
func EmitPayerGetReaderNodeAvailableNodes(count int)
func EmitPayerMessageOriginated(originatorId uint32, count int)
func EmitPayerNodePublishDuration(originatorId uint32, duration float64)
func EmitSyncLastSeenOriginatorSequenceId(originatorId uint32, lastSequence uint64)
func EmitSyncOriginatorErrorMessages(originatorId uint32, count int)
func EmitSyncOriginatorReceivedMessagesCount(originatorId uint32, count int)
func MeasureGetLogs[Return any](contractAddress string, fn func() (Return, error)) (Return, error)
func MeasurePublishToBlockchainMethod[Return any](payloadType string, fn func() (Return, error)) (Return, error)
type ApiOpenConnection
- func NewApiOpenConnection(style string, method string) *ApiOpenConnection
- func (oc *ApiOpenConnection) Close()
type IncomingConnectionTracker
- func NewIncomingConnectionTracker(version string) *IncomingConnectionTracker
- func (ct *IncomingConnectionTracker) Close()
- func (ct *IncomingConnectionTracker) Open()
type Server
- func NewMetricsServer(ctx context.Context, address string, port int, log *zap.Logger, ...) (*Server, error)
- func (s *Server) Close()
type SyncConnectionsStatusCounter
- func NewSyncConnectionsStatusCounter(originatorId uint32) *SyncConnectionsStatusCounter
- func (fc *SyncConnectionsStatusCounter) Close()
- func (fc *SyncConnectionsStatusCounter) MarkFailure()
- func (fc *SyncConnectionsStatusCounter) MarkSuccess()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EmitBlockchainPublish ¶ added in v0.4.0

func EmitBlockchainPublish(payloadType string, duration time.Duration)

func EmitBlockchainWaitForTransaction ¶ added in v0.4.0

func EmitBlockchainWaitForTransaction(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 EmitNewConnectionRequestVersion ¶ added in v0.3.0

func EmitNewConnectionRequestVersion(version string)

func EmitNewFailedGRPCRequest ¶ added in v0.4.0

func EmitNewFailedGRPCRequest(code codes.Code)

func EmitPayerBanlistRetries ¶ added in v0.2.2

func EmitPayerBanlistRetries(originatorId uint32, retries int)

func EmitPayerBlockUntilDesiredCursorReached ¶ added in v0.2.2

func EmitPayerBlockUntilDesiredCursorReached(originatorId uint32, duration float64)

func EmitPayerCurrentNonce ¶ added in v0.2.2

func EmitPayerCurrentNonce(nonce float64)

func EmitPayerGetReaderNodeAvailableNodes ¶ added in v0.4.0

func EmitPayerGetReaderNodeAvailableNodes(count int)

func EmitPayerMessageOriginated ¶ added in v0.2.2

func EmitPayerMessageOriginated(originatorId uint32, count int)

func EmitPayerNodePublishDuration ¶ added in v0.2.2

func EmitPayerNodePublishDuration(originatorId uint32, duration float64)

func EmitSyncLastSeenOriginatorSequenceId ¶ added in v0.2.2

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 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)

Types ¶

type ApiOpenConnection ¶ added in v0.2.3

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

func NewApiOpenConnection ¶ added in v0.2.3

func NewApiOpenConnection(style string, method string) *ApiOpenConnection

func (*ApiOpenConnection) Close ¶ added in v0.2.3

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 Server ¶

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

func NewMetricsServer ¶

func NewMetricsServer(
	ctx context.Context,
	address string,
	port int,
	log *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
docs

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL