poolManager

Documentation

Index

• type Pool
  • func NewPool(options *config.Options) *Pool
  • func (p *Pool) AttachMiners(miners []*stratum.Client)
  • func (p *Pool) CheckAllSynced() bool
  • func (p *Pool) DetectCoinData()
  • func (p *Pool) Init()
  • func (p *Pool) OutputPoolInfo()
  • func (p *Pool) SetupBlockPolling()
  • func (p *Pool) SetupP2PBlockNotify()
  • func (p *Pool) StartStratumServer()
• type Stats
  • func NewStats() *Stats

Types

type Pool

type Pool struct {
	DaemonManager *daemonManager.DaemonManager
	JobManager    *jobManager.JobManager
	P2PManager    *p2pManager.Peer

	StratumServer *stratum.Server

	Options                    *config.Options
	Magnitude                  uint64
	CoinPrecision              int
	HasGetInfo                 bool
	Stats                      *Stats
	BlockPollingIntervalTicker *time.Ticker
	Recipients                 []*config.Recipient
	ProtocolVersion            int
	APIServer                  *api.Server
}

func NewPool

func NewPool(options *config.Options) *Pool

func (*Pool) AttachMiners

func (p *Pool) AttachMiners(miners []*stratum.Client)

func (*Pool) CheckAllSynced

func (p *Pool) CheckAllSynced() bool

func (*Pool) DetectCoinData

func (p *Pool) DetectCoinData()

enrich the config options from rpc

func (*Pool) Init

func (p *Pool) Init()

func (*Pool) OutputPoolInfo

func (p *Pool) OutputPoolInfo()

func (*Pool) SetupBlockPolling

func (p *Pool) SetupBlockPolling()

func (*Pool) SetupP2PBlockNotify

func (p *Pool) SetupP2PBlockNotify()

func (*Pool) StartStratumServer

func (p *Pool) StartStratumServer()

type Stats

type Stats struct {
	Connections     int
	Difficulty      float64
	NetworkHashrate float64
	StratumPorts    []int
}

func NewStats

func NewStats() *Stats