metrics

package
v0.0.0-...-efbd42f Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2023 License: Apache-2.0 Imports: 3 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) IncGovernorConfigFromGossipNetwork 

func (d *DummyMetrics) IncGovernorConfigFromGossipNetwork(phylaxName string)

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

func (*DummyMetrics) IncGovernorConfigInserted 

func (d *DummyMetrics) IncGovernorConfigInserted(phylaxName string)

IncGovernorConfigInserted increases the number of phylax config inserted in database.

func (*DummyMetrics) IncGovernorStatusFromGossipNetwork 

func (d *DummyMetrics) IncGovernorStatusFromGossipNetwork(phylaxName string)

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

func (*DummyMetrics) IncGovernorStatusInserted 

func (d *DummyMetrics) IncGovernorStatusInserted(phylaxName string)

IncGovernorStatusInserted increases the number of phylax status inserted in database.

func (*DummyMetrics) IncHeartbeatFromGossipNetwork 

func (d *DummyMetrics) IncHeartbeatFromGossipNetwork(phylaxName string)

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

func (*DummyMetrics) IncHeartbeatInserted 

func (d *DummyMetrics) IncHeartbeatInserted(phylaxName 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) 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) 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) 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()

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

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

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

	// max sequence cache metrics
	IncMaxSequenceCacheError(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) IncGovernorConfigFromGossipNetwork 

func (m *PrometheusMetrics) IncGovernorConfigFromGossipNetwork(phylaxName string)

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

func (*PrometheusMetrics) IncGovernorConfigInserted 

func (m *PrometheusMetrics) IncGovernorConfigInserted(phylaxName string)

IncGovernorConfigInserted increases the number of phylax config inserted in database.

func (*PrometheusMetrics) IncGovernorStatusFromGossipNetwork 

func (m *PrometheusMetrics) IncGovernorStatusFromGossipNetwork(phylaxName string)

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

func (*PrometheusMetrics) IncGovernorStatusInserted 

func (m *PrometheusMetrics) IncGovernorStatusInserted(phylaxName string)

IncGovernorStatusInserted increases the number of phylax status inserted in database.

func (*PrometheusMetrics) IncHeartbeatFromGossipNetwork 

func (m *PrometheusMetrics) IncHeartbeatFromGossipNetwork(phylaxName string)

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

func (*PrometheusMetrics) IncHeartbeatInserted 

func (m *PrometheusMetrics) IncHeartbeatInserted(phylaxName 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) 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) 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) 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.