repositories

Documentation

Index

• type DowntimeRepo
  • func NewDowntimeRepo(db *storm.DB) *DowntimeRepo
  • func (r *DowntimeRepo) Save(downtime *models.Downtime) error
• type DowntimeRepository
• type MetricsRepository
  • func NewMetricsRepo(db *storm.DB) MetricsRepository
• type NodeRepository
  • func NewNodeRepo(db *storm.DB) NodeRepository
• type PingRepository
  • func NewPingRepo(db *storm.DB) PingRepository
• type RecordRepository
  • func NewRecordRepo(db *storm.DB) RecordRepository
• type Repos

Types

type DowntimeRepo

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

func NewDowntimeRepo

func NewDowntimeRepo(db *storm.DB) *DowntimeRepo

func (*DowntimeRepo) Save

func (r *DowntimeRepo) Save(downtime *models.Downtime) error

type DowntimeRepository

type DowntimeRepository interface {
	Save(downtime *models.Downtime) error
}

type MetricsRepository

type MetricsRepository interface {
	FindByID(ID string) (*models.Metrics, error)
	Save(metrics *models.Metrics) error
	SaveAndCheckIfFirstEntry(metrics *models.Metrics) (bool, error)
	GetAll() (*[]models.Metrics, error)
	GetLatestBlockMetrics() (*models.LatestBlockMetrics, error)
}

func NewMetricsRepo

func NewMetricsRepo(db *storm.DB) MetricsRepository

type NodeRepository

type NodeRepository interface {
	FindByID(ID string) (*models.Node, error)
	Save(node *models.Node) error
	GetAll() (*[]models.Node, error)
	GetActiveNodes(selection string) *[]models.Node
	GetAllActiveNodes() *[]models.Node
	IsNodeActive(ID string) bool
	RemoveNodeFromActive(ID string) error
	AddNodeToActive(ID string) error
	RewardNode(node models.Node)
	IncreaseNodeCooldown(ID string) (*models.Node, error)
	ResetNodeCooldown(ID string) (*models.Node, error)
	IsNodeOnCooldown(ID string) (bool, error)
}

func NewNodeRepo

func NewNodeRepo(db *storm.DB) NodeRepository

type PingRepository

type PingRepository interface {
	FindByNodeID(nodeId string) (*models.Ping, error)
	Save(ping *models.Ping) error
	GetAll() (*[]models.Ping, error)
	ResetAllPings() error
	CalculateDowntime(nodeId string, pingTime time.Time) (time.Time, time.Duration, error)
}

func NewPingRepo

func NewPingRepo(db *storm.DB) PingRepository

type RecordRepository

type RecordRepository interface {
	Save(record *models.Record) error
}

func NewRecordRepo

func NewRecordRepo(db *storm.DB) RecordRepository

type Repos

type Repos struct {
	NodeRepo     NodeRepository
	PingRepo     PingRepository
	MetricsRepo  MetricsRepository
	RecordRepo   RecordRepository
	DowntimeRepo DowntimeRepository
}

Repos structure holds all available repositories