pool

Documentation

Index

• type JobList
  • func (l *JobList) Append(job *types.StratumJob) bool
  • func (l *JobList) Get(id string) (*types.StratumJob, bool)
  • func (l *JobList) GetPrior(id string) (*types.StratumJob, bool)
  • func (l *JobList) Latest() *types.StratumJob
  • func (l *JobList) Oldest() *types.StratumJob
  • func (l *JobList) Size() int
• type JobManager
  • func (m *JobManager) AddConn(c *stratum.Conn)
  • func (m *JobManager) GetJob(id string) (*types.StratumJob, bool)
  • func (m *JobManager) GetPriorJob(id string) (*types.StratumJob, bool)
  • func (m *JobManager) LatestJob() *types.StratumJob
  • func (m *JobManager) RemoveConn(id uint64)
• type Options
• type Pool
  • func New(node types.MiningNode, dbClient *dbcl.Client, redisClient *redis.Client, ...) (*Pool, error)
  • func (p *Pool) Port(idx int) int
  • func (p *Pool) Serve()
  • func (p *Pool) Stop()
• type ProtocolHandler

Types

type JobList

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

func (*JobList) Append

func (l *JobList) Append(job *types.StratumJob) bool

func (*JobList) Get

func (l *JobList) Get(id string) (*types.StratumJob, bool)

func (*JobList) GetPrior

func (l *JobList) GetPrior(id string) (*types.StratumJob, bool)

func (*JobList) Latest

func (l *JobList) Latest() *types.StratumJob

func (*JobList) Oldest

func (l *JobList) Oldest() *types.StratumJob

func (*JobList) Size

func (l *JobList) Size() int

type JobManager

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

func (*JobManager) AddConn

func (m *JobManager) AddConn(c *stratum.Conn)

func (*JobManager) GetJob

func (m *JobManager) GetJob(id string) (*types.StratumJob, bool)

func (*JobManager) GetPriorJob

func (m *JobManager) GetPriorJob(id string) (*types.StratumJob, bool)

func (*JobManager) LatestJob

func (m *JobManager) LatestJob() *types.StratumJob

func (*JobManager) RemoveConn

func (m *JobManager) RemoveConn(id uint64)

type Options

type Options struct {
	Chain                string
	PortDiffIdx          map[int]int
	WindowSize           int
	ExtraNonceSize       int
	JobListSize          int
	JobListAgeLimit      int
	SoloEnabled          bool
	VarDiffEnabled       bool
	StreamEnabled        bool
	ForceErrorOnResponse bool
	Flush                bool
	PollingPeriod        time.Duration
	PingingPeriod        time.Duration
	Metrics              *metrics.Client
}

type Pool

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

func New

func New(
	node types.MiningNode,
	dbClient *dbcl.Client,
	redisClient *redis.Client,
	logger *log.Logger,
	telegramClient *telegram.Client,
	metricsClient *metrics.Client,
	opt *Options,
) (*Pool, error)

func (*Pool) Port

func (p *Pool) Port(idx int) int

func (*Pool) Serve

func (p *Pool) Serve()

func (*Pool) Stop

func (p *Pool) Stop()

type ProtocolHandler

type ProtocolHandler func(*stratum.Conn, *rpc.Request) error