metrics

package

v0.3.0 Latest Latest Go to latest Published: Apr 9, 2025 License: MIT Imports: 12 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 EmitIndexerCurrentBlock(contractAddress string, block uint64)
func EmitIndexerCurrentBlockLag(contractAddress string, lag uint64)
func EmitIndexerGetLogsDuration(contractAddress string, duration time.Duration)
func EmitIndexerMaxBlock(contractAddress string, block uint64)
func EmitIndexerNumLogsFound(contractAddress string, numLogs int)
func EmitIndexerRetryableStorageError(contractAddress string)
func EmitNewConnectionRequestVersion(version string)
func EmitPayerBanlistRetries(originatorId uint32, retries int)
func EmitPayerBlockUntilDesiredCursorReached(originatorId uint32, duration float64)
func EmitPayerCurrentNonce(nonce float64)
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)
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 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 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 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 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)

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

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