Documentation ¶
Index ¶
- type Fan
- type Miner
- type MinerLog
- type MinerRepository
- func (r *MinerRepository) List() ([]*Miner, error)
- func (r *MinerRepository) ListByFleetID(ctx context.Context, miner *Miner) ([]*Miner, error)
- func (r *MinerRepository) ListByMacAddresses(mac_addresses []string) ([]*Miner, error)
- func (r *MinerRepository) Upsert(ctx context.Context, miner *Miner) (uint, error)
- type MinerTimeSeries
- type MinerTimeSeriesRepository
- func (r *MinerTimeSeriesRepository) FlushMinerData() error
- func (r *MinerTimeSeriesRepository) FlushPoolData() error
- func (r *MinerTimeSeriesRepository) ReadMinerData(mac_address string, interval int) (MinerTimeSeriesResponse, error)
- func (r *MinerTimeSeriesRepository) ReadPoolData(mac_address string, interval int) (PoolTimeSeriesResponse, error)
- func (r *MinerTimeSeriesRepository) WriteMinerData(mac_address string, data MinerTimeSeries) error
- func (r *MinerTimeSeriesRepository) WritePoolData(mac_address string, data PoolTimeSeries) error
- type MinerTimeSeriesResponse
- type Pool
- type PoolTimeSeries
- type PoolTimeSeriesResponse
- type Temperature
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Fan ¶
type Fan []int
type Miner ¶
type Miner struct { gorm.Model Miner miner_domain.Miner `gorm:"embedded"` Stats miner_domain.Stats `gorm:"embedded"` Config miner_domain.Config `gorm:"embedded"` MinerType scanner_domain.MinerType ModelName string `gorm:"comment: i.e. Antminer s19"` Mode miner_domain.Mode `gorm:"comment: Mode: 0=Normal, 1=Sleep, 2=LowPower"` Status miner_domain.Status `gorm:"comment: Status: 0=Online, 1=Offline, 2=Disabled, 3=Error, 4=Warning"` Pools []Pool `gorm:"onDelete:CASCADE; onUpdate:CASCADE"` Fan Fan `gorm:"type:VARCHAR(255)"` Temperature Temperature `gorm:"type:VARCHAR(255)"` Log []MinerLog FleetID uint }
type MinerLog ¶
type MinerLog struct { gorm.Model Log miner_domain.Log `gorm:"embedded;"` EventType miner_domain.EventType `gorm:"comment: EventType: 0=Operational, 1=SystemIssue, 2=UserActivity"` MinerID uint }
type MinerRepository ¶
type MinerRepository struct {
// contains filtered or unexported fields
}
func NewMinerRepository ¶
func NewMinerRepository(db *gorm.DB) *MinerRepository
func (*MinerRepository) List ¶
func (r *MinerRepository) List() ([]*Miner, error)
func (*MinerRepository) ListByFleetID ¶
[ ] JOIN with miner config
Struct db.Find(&users, User{Age: 20}) SELECT * FROM users WHERE age = 20;
func (*MinerRepository) ListByMacAddresses ¶
func (r *MinerRepository) ListByMacAddresses(mac_addresses []string) ([]*Miner, error)
type MinerTimeSeries ¶
type MinerTimeSeriesRepository ¶
type MinerTimeSeriesRepository struct {
// contains filtered or unexported fields
}
func NewMinerTimeSeriesRepository ¶
func NewMinerTimeSeriesRepository(db timeseries_database.InfluxDBConnectionSettings) *MinerTimeSeriesRepository
func (*MinerTimeSeriesRepository) FlushMinerData ¶
func (r *MinerTimeSeriesRepository) FlushMinerData() error
func (*MinerTimeSeriesRepository) FlushPoolData ¶
func (r *MinerTimeSeriesRepository) FlushPoolData() error
func (*MinerTimeSeriesRepository) ReadMinerData ¶
func (r *MinerTimeSeriesRepository) ReadMinerData(mac_address string, interval int) (MinerTimeSeriesResponse, error)
NOTE: mac_address is null in the response object
func (*MinerTimeSeriesRepository) ReadPoolData ¶
func (r *MinerTimeSeriesRepository) ReadPoolData(mac_address string, interval int) (PoolTimeSeriesResponse, error)
func (*MinerTimeSeriesRepository) WriteMinerData ¶
func (r *MinerTimeSeriesRepository) WriteMinerData(mac_address string, data MinerTimeSeries) error
func (*MinerTimeSeriesRepository) WritePoolData ¶
func (r *MinerTimeSeriesRepository) WritePoolData(mac_address string, data PoolTimeSeries) error
type MinerTimeSeriesResponse ¶
type MinerTimeSeriesResponse struct { Record []MinerTimeSeries `json:"miner_time_series_record"` TimeStamps []time.Time `json:"timestamp"` }
type PoolTimeSeries ¶
type PoolTimeSeriesResponse ¶
type PoolTimeSeriesResponse struct { Record []PoolTimeSeries `json:"pool_time_series_record"` TimeStamps []time.Time `json:"timestamps"` }
type Temperature ¶
type Temperature []int
func (*Temperature) Scan ¶
func (t *Temperature) Scan(value interface{}) error
Click to show internal directories.
Click to hide internal directories.