Versions in this module Expand all Collapse all v0 v0.1.1 Oct 24, 2023 v0.1.0 Oct 7, 2023 Changes in this version + type BlockData struct + BlkTotalFee *big.Int + CoinBaseValue *big.Int + Difficulty int64 + ENonce1 string + ENonce2 string + ExtraReward *big.Int + Hash string + Height int64 + ImmatureReward string + Nonce string + Orphan bool + Reward *big.Int + RewardString string + RoundHeight int64 + Timestamp int64 + TotalShares int64 + Uncle bool + UncleHeight int64 + func (b *BlockData) RewardInSatoshi() int64 + func (b *BlockData) RoundKey() string + type HashRateStatsData struct + SharesCount uint64 + TotalWorks uint64 + type Miner struct + HR int64 + LastBeat int64 + Offline bool + type PendingPayment struct + Address string + Amount int64 + Timestamp int64 + type RedisClient struct + func NewRedisClient(cfg *pool.StorageConfig, prefix string) *RedisClient + func NewRedisFailoverClient(cfg *pool.StorageConfigFailover, prefix string) *RedisClient + func (r *RedisClient) BgSave() (string, error) + func (r *RedisClient) Check() (string, error) + func (r *RedisClient) Client() *redis.Client + func (r *RedisClient) CollectLuckStats(windows []int) (map[string]interface{}, error) + func (r *RedisClient) CollectStats(smallWindow time.Duration, maxBlocks, maxPayments int64) (map[string]interface{}, error) + func (r *RedisClient) CollectWorkersStats(sWindow, lWindow time.Duration, login string) (map[string]interface{}, error) + func (r *RedisClient) FlushStaleStats(window, largeWindow time.Duration) (int64, error) + func (r *RedisClient) GetBalance(login string) (int64, error) + func (r *RedisClient) GetBlacklist() ([]string, error) + func (r *RedisClient) GetCandidates(maxHeight int64) ([]*BlockData, error) + func (r *RedisClient) GetImmatureBlocks(maxHeight int64) ([]*BlockData, error) + func (r *RedisClient) GetMinerStats(login string, maxPayments int64) (map[string]interface{}, error) + func (r *RedisClient) GetNodeStates() ([]map[string]interface{}, error) + func (r *RedisClient) GetPayees() ([]string, error) + func (r *RedisClient) GetPendingPayments() []*PendingPayment + func (r *RedisClient) GetRoundShares(height int64, nonce string) (map[string]int64, error) + func (r *RedisClient) GetWhitelist() ([]string, error) + func (r *RedisClient) IsMinerExists(login string) (bool, error) + func (r *RedisClient) IsPayoutsLocked() (bool, error) + func (r *RedisClient) LockPayouts(login string, amount int64) error + func (r *RedisClient) RollbackBalance(login string, amount int64) error + func (r *RedisClient) UnlockPayouts() error + func (r *RedisClient) UpdateBalance(login string, amount int64) error + func (r *RedisClient) WriteBlock(login, id string, params []string, diff, roundDiff int64, height uint64, ...) (bool, error) + func (r *RedisClient) WriteImmatureBlock(block *BlockData, roundRewards map[string]int64) error + func (r *RedisClient) WriteInvalidShare(ms, ts int64, login, id string, diff int64) error + func (r *RedisClient) WriteMaturedBlock(block *BlockData, roundRewards map[string]int64) error + func (r *RedisClient) WriteNodeState(id string, height uint32, diff *big.Int) error + func (r *RedisClient) WriteOrphan(block *BlockData) error + func (r *RedisClient) WritePayment(login, txHash string, amount int64) error + func (r *RedisClient) WritePendingOrphans(blocks []*BlockData) error + func (r *RedisClient) WriteRejectShare(ms, ts int64, login, id string, diff int64) error + func (r *RedisClient) WriteShare(login, id string, params []string, diff int64, height uint64, ...) (bool, error) + type Worker struct + TotalHR int64