repositories

Documentation

Index

• type DowntimeRepo
  • func NewDowntimeRepo(db *storm.DB) *DowntimeRepo
  • func (r *DowntimeRepo) FindDowntimesInsideInterval(nodeID string, from time.Time, to time.Time) ([]models.Downtime, error)
  • func (r *DowntimeRepo) Save(downtime *models.Downtime) error
• type DowntimeRepository
• type FeeRepository
  • func NewFeeRepo(db *storm.DB) FeeRepository
• type MetricsRepository
  • func NewMetricsRepo(db *storm.DB) MetricsRepository
• type NodeRepository
  • func NewNodeRepo(db *storm.DB) NodeRepository
• type PayoutRepository
  • func NewPayoutRepo(db *storm.DB) PayoutRepository
• 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) FindDowntimesInsideInterval

func (r *DowntimeRepo) FindDowntimesInsideInterval(nodeID string, from time.Time, to time.Time) ([]models.Downtime, error)

func (*DowntimeRepo) Save

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

type DowntimeRepository

type DowntimeRepository interface {
	Save(downtime *models.Downtime) error
	// FindDowntimesInsideInterval returns all models.Downtime that started or ended inside interval
	// defined with arguments from and to
	FindDowntimesInsideInterval(nodeID string, from time.Time, to time.Time) ([]models.Downtime, error)
}

type FeeRepository

type FeeRepository interface {
	RecordNewFee(nodeID string, newFee int64) error
	GetAllFees() (*[]models.Fee, error)
}

func NewFeeRepo

func NewFeeRepo(db *storm.DB) FeeRepository

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
	GetPenalizedNodes() (*[]models.Node, error)
	GetAllActiveNodes() *[]models.Node
	IsNodeActive(ID string) bool
	RemoveNodeFromActive(ID string) error
	AddNodeToActive(ID string) error
	UpdateNodeUsed(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 PayoutRepository

type PayoutRepository interface {
	Save(payment *models.Payout) error
	GetAll() (*[]models.Payout, error)
	FindLatestPayout() (*models.Payout, error)
}

func NewPayoutRepo

func NewPayoutRepo(db *storm.DB) PayoutRepository

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
	// FindSuccessfulRecordsInsideInterval returns all models.Record that happened inside interval
	// defined with arguments from and to
	FindSuccessfulRecordsInsideInterval(nodeID string, from time.Time, to time.Time) ([]models.Record, error)
	CountSuccessfulRequests() (int, error)
	CountFailedRequests() (int, error)
}

func NewRecordRepo

func NewRecordRepo(db *storm.DB) RecordRepository

type Repos

type Repos struct {
	NodeRepo     NodeRepository
	PingRepo     PingRepository
	MetricsRepo  MetricsRepository
	RecordRepo   RecordRepository
	DowntimeRepo DowntimeRepository
	PayoutRepo   PayoutRepository
	FeeRepo      FeeRepository
}

Repos structure holds all available repositories