metrics

package
v0.0.0-...-0248f70 Latest Latest
Warning

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

 Go to latest Published: May 24, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DummyMetrics 

type DummyMetrics struct {
}

DummyMetrics is a dummy implementation of Metric interface.

func NewDummyMetrics 

func NewDummyMetrics() *DummyMetrics

NewDummyMetrics returns a new instance of DummyMetrics.

func (*DummyMetrics) IncConsistencyLevelByChainID 

func (m *DummyMetrics) IncConsistencyLevelByChainID(chainID sdk.ChainID, consistenceLevel uint8)

func (*DummyMetrics) IncDuplicateVaaByChainID 

func (m *DummyMetrics) IncDuplicateVaaByChainID(chain sdk.ChainID)

func (*DummyMetrics) IncFoundTxHash 

func (m *DummyMetrics) IncFoundTxHash(t string)

func (*DummyMetrics) IncGovernorConfigFromGossipNetwork 

func (d *DummyMetrics) IncGovernorConfigFromGossipNetwork(guardianName string)

IncGovernorConfigFromGossipNetwork increases the number of guardian config received by guardian from Gossip network.

func (*DummyMetrics) IncGovernorConfigInserted 

func (d *DummyMetrics) IncGovernorConfigInserted(guardianName string)

IncGovernorConfigInserted increases the number of guardian config inserted in database.

func (*DummyMetrics) IncGovernorStatusFromGossipNetwork 

func (d *DummyMetrics) IncGovernorStatusFromGossipNetwork(guardianName string)

IncGovernorStatusFromGossipNetwork increases the number of guardian status received by guardian from Gossip network.

func (*DummyMetrics) IncGovernorStatusInserted 

func (d *DummyMetrics) IncGovernorStatusInserted(guardianName string)

IncGovernorStatusInserted increases the number of guardian status inserted in database.

func (*DummyMetrics) IncHeartbeatFromGossipNetwork 

func (d *DummyMetrics) IncHeartbeatFromGossipNetwork(guardianName string)

IncHeartbeatFromGossipNetwork increases the number of heartbeat received by guardian from Gossip network.

func (*DummyMetrics) IncHeartbeatInserted 

func (d *DummyMetrics) IncHeartbeatInserted(guardianName string)

IncHeartbeatInserted increases the number of heartbeat inserted in database.

func (*DummyMetrics) IncMaxSequenceCacheError 

func (d *DummyMetrics) IncMaxSequenceCacheError(chain sdk.ChainID)

IncMaxSequenceCacheError increases the number of errors when updating max sequence cache.

func (*DummyMetrics) IncNotFoundTxHash 

func (m *DummyMetrics) IncNotFoundTxHash(t string)

func (*DummyMetrics) IncObservationBadSigner 

func (m *DummyMetrics) IncObservationBadSigner(address string)

IncObservationInvalidGuardian increases the number of bad signer in observation from Gossip network.

func (*DummyMetrics) IncObservationFromGossipNetwork 

func (d *DummyMetrics) IncObservationFromGossipNetwork(chain sdk.ChainID)

IncObservationFromGossipNetwork increases the number of observation received by chain from Gossip network.

func (*DummyMetrics) IncObservationInserted 

func (d *DummyMetrics) IncObservationInserted(chain sdk.ChainID)

IncObservationInserted increases the number of observation inserted in database.

func (*DummyMetrics) IncObservationInvalidGuardian 

func (m *DummyMetrics) IncObservationInvalidGuardian(address string)

IncObservationInvalidGuardian increases the number of invalid guardian in observation from Gossip network.

func (*DummyMetrics) IncObservationTotal 

func (d *DummyMetrics) IncObservationTotal()

IncObservationTotal increases the number of observation received from Gossip network.

func (*DummyMetrics) IncObservationUnfiltered 

func (d *DummyMetrics) IncObservationUnfiltered(chain sdk.ChainID)

IncObservationUnfiltered increases the number of observation not filtered

func (*DummyMetrics) IncObservationValid 

func (m *DummyMetrics) IncObservationValid(address string)

IncObservationInvalidGuardian increases the number of bad signer in observation from Gossip network.

func (*DummyMetrics) IncObservationWithoutTxHash 

func (d *DummyMetrics) IncObservationWithoutTxHash(chain sdk.ChainID)

IncObservationWithoutTxHash increases the number of observation without tx hash.

func (*DummyMetrics) IncVaaConsumedFromQueue 

func (d *DummyMetrics) IncVaaConsumedFromQueue(chain sdk.ChainID)

IncVaaConsumedFromQueue increases the number of vaa consumed from SQS queue with deduplication policy.

func (*DummyMetrics) IncVaaFromGossipNetwork 

func (d *DummyMetrics) IncVaaFromGossipNetwork(chain sdk.ChainID)

IncVaaFromGossipNetwork increases the number of vaa received by chain from Gossip network.

func (*DummyMetrics) IncVaaInserted 

func (d *DummyMetrics) IncVaaInserted(chain sdk.ChainID)

IncVaaInserted increases the number of vaa inserted into the database.

func (*DummyMetrics) IncVaaSendNotification 

func (d *DummyMetrics) IncVaaSendNotification(chain sdk.ChainID)

IncVaaSendNotification increases the number of vaa send notifcations to pipeline.

func (*DummyMetrics) IncVaaTotal 

func (d *DummyMetrics) IncVaaTotal()

IncVaaTotal increases the number of vaa received from Gossip network.

func (*DummyMetrics) IncVaaUnfiltered 

func (d *DummyMetrics) IncVaaUnfiltered(chain sdk.ChainID)

IncVaaUnfiltered increases the number of vaa passing through the local deduplicator.

type Metrics 

type Metrics interface {
	// vaa metrics
	IncVaaFromGossipNetwork(chain sdk.ChainID)
	IncVaaUnfiltered(chain sdk.ChainID)
	IncVaaConsumedFromQueue(chain sdk.ChainID)
	IncVaaInserted(chain sdk.ChainID)
	IncVaaSendNotification(chain sdk.ChainID)
	IncVaaTotal()

	// observation metrics
	IncObservationFromGossipNetwork(chain sdk.ChainID)
	IncObservationUnfiltered(chain sdk.ChainID)
	IncObservationInserted(chain sdk.ChainID)
	IncObservationWithoutTxHash(chain sdk.ChainID)
	IncObservationTotal()
	IncObservationInvalidGuardian(address string)
	IncObservationBadSigner(address string)
	IncObservationValid(address string)

	// heartbeat metrics
	IncHeartbeatFromGossipNetwork(guardianName string)
	IncHeartbeatInserted(guardianName string)

	// governor config metrics
	IncGovernorConfigFromGossipNetwork(guardianName string)
	IncGovernorConfigInserted(guardianName string)

	// governor status metrics
	IncGovernorStatusFromGossipNetwork(guardianName string)
	IncGovernorStatusInserted(guardianName string)

	// max sequence cache metrics
	IncMaxSequenceCacheError(chain sdk.ChainID)

	// tx hash metrics
	IncFoundTxHash(t string)
	IncNotFoundTxHash(t string)

	// chain consistency level metrics
	IncConsistencyLevelByChainID(chainID sdk.ChainID, consistenceLevel uint8)

	// duplicate vaa metrics
	IncDuplicateVaaByChainID(chain sdk.ChainID)
}

type PrometheusMetrics 

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

PrometheusMetrics is a Prometheus implementation of Metric interface.

func NewPrometheusMetrics 

func NewPrometheusMetrics(environment string) *PrometheusMetrics

NewPrometheusMetrics returns a new instance of PrometheusMetrics.

func (*PrometheusMetrics) IncConsistencyLevelByChainID 

func (m *PrometheusMetrics) IncConsistencyLevelByChainID(chainID sdk.ChainID, consistenceLevel uint8)

IncConsistencyLevelByChainID increases the number of errors when updating max sequence cache.

func (*PrometheusMetrics) IncDuplicateVaaByChainID 

func (m *PrometheusMetrics) IncDuplicateVaaByChainID(chain sdk.ChainID)

IncDuplicateVaaByChainID increases the number of duplicate vaa by chain.

func (*PrometheusMetrics) IncFoundTxHash 

func (m *PrometheusMetrics) IncFoundTxHash(t string)

func (*PrometheusMetrics) IncGovernorConfigFromGossipNetwork 

func (m *PrometheusMetrics) IncGovernorConfigFromGossipNetwork(guardianName string)

IncGovernorConfigFromGossipNetwork increases the number of guardian config received by guardian from Gossip network.

func (*PrometheusMetrics) IncGovernorConfigInserted 

func (m *PrometheusMetrics) IncGovernorConfigInserted(guardianName string)

IncGovernorConfigInserted increases the number of guardian config inserted in database.

func (*PrometheusMetrics) IncGovernorStatusFromGossipNetwork 

func (m *PrometheusMetrics) IncGovernorStatusFromGossipNetwork(guardianName string)

IncGovernorStatusFromGossipNetwork increases the number of guardian status received by guardian from Gossip network.

func (*PrometheusMetrics) IncGovernorStatusInserted 

func (m *PrometheusMetrics) IncGovernorStatusInserted(guardianName string)

IncGovernorStatusInserted increases the number of guardian status inserted in database.

func (*PrometheusMetrics) IncHeartbeatFromGossipNetwork 

func (m *PrometheusMetrics) IncHeartbeatFromGossipNetwork(guardianName string)

IncHeartbeatFromGossipNetwork increases the number of heartbeat received by guardian from Gossip network.

func (*PrometheusMetrics) IncHeartbeatInserted 

func (m *PrometheusMetrics) IncHeartbeatInserted(guardianName string)

IncHeartbeatInserted increases the number of heartbeat inserted in database.

func (*PrometheusMetrics) IncMaxSequenceCacheError 

func (m *PrometheusMetrics) IncMaxSequenceCacheError(chain sdk.ChainID)

IncMaxSequenceCacheError increases the number of errors when updating max sequence cache.

func (*PrometheusMetrics) IncNotFoundTxHash 

func (m *PrometheusMetrics) IncNotFoundTxHash(t string)

func (*PrometheusMetrics) IncObservationBadSigner 

func (m *PrometheusMetrics) IncObservationBadSigner(address string)

IncObservationInvalidGuardian increases the number of bad signer in observation from Gossip network.

func (*PrometheusMetrics) IncObservationFromGossipNetwork 

func (m *PrometheusMetrics) IncObservationFromGossipNetwork(chain sdk.ChainID)

IncObservationFromGossipNetwork increases the number of observation received by chain from Gossip network.

func (*PrometheusMetrics) IncObservationInserted 

func (m *PrometheusMetrics) IncObservationInserted(chain sdk.ChainID)

IncObservationInserted increases the number of observation inserted in database.

func (*PrometheusMetrics) IncObservationInvalidGuardian 

func (m *PrometheusMetrics) IncObservationInvalidGuardian(address string)

IncObservationInvalidGuardian increases the number of invalid guardian in observation from Gossip network.

func (*PrometheusMetrics) IncObservationTotal 

func (m *PrometheusMetrics) IncObservationTotal()

IncObservationTotal increases the number of observation received from Gossip network.

func (*PrometheusMetrics) IncObservationUnfiltered 

func (m *PrometheusMetrics) IncObservationUnfiltered(chain sdk.ChainID)

IncObservationUnfiltered increases the number of observation not filtered

func (*PrometheusMetrics) IncObservationValid 

func (m *PrometheusMetrics) IncObservationValid(address string)

IncObservationInvalidGuardian increases the number of bad signer in observation from Gossip network.

func (*PrometheusMetrics) IncObservationWithoutTxHash 

func (m *PrometheusMetrics) IncObservationWithoutTxHash(chain sdk.ChainID)

IncObservationWithoutTxHash increases the number of observation without tx hash.

func (*PrometheusMetrics) IncVaaConsumedFromQueue 

func (m *PrometheusMetrics) IncVaaConsumedFromQueue(chain sdk.ChainID)

IncVaaConsumedFromQueue increases the number of vaa consumed from SQS queue with deduplication policy.

func (*PrometheusMetrics) IncVaaFromGossipNetwork 

func (m *PrometheusMetrics) IncVaaFromGossipNetwork(chain sdk.ChainID)

IncVaaFromGossipNetwork increases the number of vaa received by chain from Gossip network.

func (*PrometheusMetrics) IncVaaInserted 

func (m *PrometheusMetrics) IncVaaInserted(chain sdk.ChainID)

IncVaaInserted increases the number of vaa inserted in database.

func (*PrometheusMetrics) IncVaaSendNotification 

func (m *PrometheusMetrics) IncVaaSendNotification(chain sdk.ChainID)

IncVaaSendNotification increases the number of vaa send notifcations to pipeline.

func (*PrometheusMetrics) IncVaaTotal 

func (m *PrometheusMetrics) IncVaaTotal()

IncVaaTotal increases the number of vaa received from Gossip network.

func (*PrometheusMetrics) IncVaaUnfiltered 

func (m *PrometheusMetrics) IncVaaUnfiltered(chain sdk.ChainID)

IncVaaUnfiltered increases the number of vaa passing through the local deduplicator.

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.