Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pool

package

Go to main page

Versions in this module

v1

v1.4.1

Oct 12, 2019

v1.4.1-rc1

Sep 28, 2019

v1.4.1-RC2

Oct 8, 2019

v1.4.0

Jun 23, 2019

v1.3.8

Feb 10, 2019

Changes in this version

+ const MajorVersion

+ const MinorVersion

+ const SiaCoinAlgo

+ const SiaCoinID

+ const SiaCoinSymbol

+ var BlockMemory = ...

+ var ErrCreateClient = errors.New("Error when creating a new client")

+ var ErrDuplicateUserInDifferentCoin = errors.New("duplicate user in different coin, you need use a different address")

+ var ErrNoUsernameInDatabase = errors.New("user is not found in db")

+ var HeaderMemory = ...

+ var MaxSourceBlockAge = ...

+ var ShiftDuration = ...

+ func BigToCompact(n *big.Int) uint32

+ type Client struct

+ func (c *Client) Name() string

+ func (c *Client) Pool() *Pool

+ func (c *Client) SetName(n string)

+ func (c *Client) SetWallet(w types.UnlockHash)

+ func (c *Client) Wallet() *types.UnlockHash

+ type ClientRecord struct

+ type Dispatcher struct

+ func (d *Dispatcher) AddHandler(conn net.Conn)

+ func (d *Dispatcher) ClearJobAndNotifyClients()

+ func (d *Dispatcher) IncrementConnectionsOpened()

+ func (d *Dispatcher) ListenHandlers(port string)

+ func (d *Dispatcher) NotifyClients()

+ func (d *Dispatcher) NumConnections() int

+ func (d *Dispatcher) NumConnectionsOpened() uint64

+ type Handler struct

+ func (h *Handler) Listen()

+ type Job struct

+ JobID uint64

+ MarshalledBlock []byte

+ MerkleRoot crypto.Hash

+ SubmitedNonce map[string]bool

+ type Pool struct

+ func New(cs modules.ConsensusSet, tpool modules.TransactionPool, gw modules.Gateway, ...) (*Pool, error)

+ func (p *Pool) AddClient(c *Client)

+ func (p *Pool) AddClientDB(c *Client) error

+ func (p *Pool) Client(name string) *Client

+ func (p *Pool) Close() error

+ func (p *Pool) DeleteAllWorkerRecords() error

+ func (p *Pool) FindClientDB(name string) (*Client, error)

+ func (p *Pool) InternalSettings() modules.PoolInternalSettings

+ func (p *Pool) NumConnections() int

+ func (p *Pool) NumConnectionsOpened() uint64

+ func (p *Pool) ProcessConsensusChange(cc modules.ConsensusChange)

+ func (p *Pool) ReceiveUpdatedUnconfirmedTransactions(diff *modules.TransactionPoolDiff)

+ func (p *Pool) SetInternalSettings(settings modules.PoolInternalSettings) error

+ type Session struct

+ Client *Client

+ CurrentJobs []*Job

+ CurrentShift *Shift

+ CurrentWorker *Worker

+ ExtraNonce1 uint32

+ SessionID uint64

+ func (s *Session) Authorized() bool

+ func (s *Session) CurrentDifficulty() float64

+ func (s *Session) DetectDisconnected() bool

+ func (s *Session) HighestDifficulty() float64

+ func (s *Session) IsStable() bool

+ func (s *Session) SetAuthorized(b bool)

+ func (s *Session) SetClientVersion(v string)

+ func (s *Session) SetCurrentDifficulty(d float64)

+ func (s *Session) SetDisableVarDiff(flag bool)

+ func (s *Session) SetHeartbeat()

+ func (s *Session) SetHighestDifficulty(d float64)

+ func (s *Session) SetLastShareTimestamp(t time.Time)

+ func (s *Session) ShareDurationAverage() (float64, float64)

+ func (s *Session) Shift() *Shift

+ type Share struct

+ type Shift struct

+ func (s *Shift) IncrementInvalid()

+ func (s *Shift) IncrementShares(share *Share)

+ func (s *Shift) LastShareTime() time.Time

+ func (s *Shift) PoolID() uint64

+ func (s *Shift) SaveShift() error

+ func (s *Shift) SetLastShareTime(t time.Time)

+ func (s *Shift) Shares() []Share

+ func (s *Shift) ShiftID() uint64

+ func (s *Shift) StartShiftTime() time.Time

+ type Vardiff struct

+ type Worker struct

+ func (w *Worker) CurrentDifficulty() float64

+ func (w *Worker) IncrementInvalidShares()

+ func (w *Worker) IncrementShares(sessionDifficulty float64, reward float64)

+ func (w *Worker) LastShareTime() time.Time

+ func (w *Worker) Name() string

+ func (w *Worker) Online() bool

+ func (w *Worker) Parent() *Client

+ func (w *Worker) Session() *Session

+ func (w *Worker) SetLastShareTime(t time.Time)

+ func (w *Worker) SetName(n string)

+ func (w *Worker) SetParent(p *Client)

+ func (w *Worker) SetSession(s *Session)

+ type WorkerRecord struct