metrics

Documentation

Index

• type InsertQueue
  • func NewInsertQueue(metrics *Metrics) *InsertQueue
  • func (i *InsertQueue) Add(data *models.CelestiaNode)
  • func (i *InsertQueue) Start() error
  • func (i *InsertQueue) Stop()
• type Metrics
  • func New(db *gorm.DB) *Metrics
  • func (m *Metrics) AddNodeData(data *models.CelestiaNode) error
  • func (m *Metrics) FindByNodeId(nodeId string, offset, limit int) ([]models.CelestiaNode, int64, error)
  • func (m *Metrics) FindByNodeIdAtNetworkHeight(nodeId string, networkHeight uint64) ([]models.CelestiaNode, error)
  • func (m *Metrics) FindByNodeIdAtNetworkHeightRange(nodeId string, networkHeightBegin, networkHeightEnd uint64) ([]models.CelestiaNode, error)
  • func (m *Metrics) GetAllNodes(offset, limit int) ([]models.CelestiaNode, int64, error)
  • func (m *Metrics) GetLatestNodeData(nodeId string) (models.CelestiaNode, error)
  • func (m *Metrics) GetNodeDataByMetricTime(nodeId string, metricTime time.Time) (models.CelestiaNode, error)
  • func (m *Metrics) GetNodeUpTime(nodeId string) (float32, error)
  • func (m *Metrics) GetNodesByType(nType receiver.NodeType, offset, limit int) ([]models.CelestiaNode, int64, error)
  • func (m *Metrics) GetNodesVersions(nodeId string) ([]models.NodeVersion, error)
  • func (m *Metrics) RecomputeUptimeForAll(uptimeStartTime, uptimeEndTime time.Time) ([]models.CelestiaNode, error)

Types

type InsertQueue

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

func NewInsertQueue

func NewInsertQueue(metrics *Metrics) *InsertQueue

func (*InsertQueue) Add

func (i *InsertQueue) Add(data *models.CelestiaNode)

This function puts data in a queue and adds them to the DB whenever it can,

to be able to keep up with a big load of coming data

func (*InsertQueue) Start

func (i *InsertQueue) Start() error

func (*InsertQueue) Stop

func (i *InsertQueue) Stop()

type Metrics

type Metrics struct {
	InsertQueue *InsertQueue
	// contains filtered or unexported fields
}

func New

func New(db *gorm.DB) *Metrics

func (*Metrics) AddNodeData

func (m *Metrics) AddNodeData(data *models.CelestiaNode) error

func (*Metrics) FindByNodeId

func (m *Metrics) FindByNodeId(nodeId string, offset, limit int) ([]models.CelestiaNode, int64, error)

func (*Metrics) FindByNodeIdAtNetworkHeight

func (m *Metrics) FindByNodeIdAtNetworkHeight(nodeId string, networkHeight uint64) ([]models.CelestiaNode, error)

func (*Metrics) FindByNodeIdAtNetworkHeightRange

func (m *Metrics) FindByNodeIdAtNetworkHeightRange(nodeId string, networkHeightBegin, networkHeightEnd uint64) ([]models.CelestiaNode, error)

func (*Metrics) GetAllNodes

func (m *Metrics) GetAllNodes(offset, limit int) ([]models.CelestiaNode, int64, error)

func (*Metrics) GetLatestNodeData

func (m *Metrics) GetLatestNodeData(nodeId string) (models.CelestiaNode, error)

func (*Metrics) GetNodeDataByMetricTime

func (m *Metrics) GetNodeDataByMetricTime(nodeId string, metricTime time.Time) (models.CelestiaNode, error)

func (*Metrics) GetNodeUpTime

func (m *Metrics) GetNodeUpTime(nodeId string) (float32, error)

func (*Metrics) GetNodesByType

func (m *Metrics) GetNodesByType(nType receiver.NodeType, offset, limit int) ([]models.CelestiaNode, int64, error)

func (*Metrics) GetNodesVersions

func (m *Metrics) GetNodesVersions(nodeId string) ([]models.NodeVersion, error)

func (*Metrics) RecomputeUptimeForAll

func (m *Metrics) RecomputeUptimeForAll(uptimeStartTime, uptimeEndTime time.Time) ([]models.CelestiaNode, error)