extpool

Documentation

Index

• type Pool
  • func New(bc blockchainer.Blockchainer, capacity int) *Pool
  • func (p *Pool) Add(e *payload.Extensible) (bool, error)
  • func (p *Pool) Get(h util.Uint256) *payload.Extensible
  • func (p *Pool) RemoveStale(index uint32)

Types

type Pool

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

Pool represents pool of extensible payloads.

func New

func New(bc blockchainer.Blockchainer, capacity int) *Pool

New returns new payload pool using provided chain.

func (*Pool) Add

func (p *Pool) Add(e *payload.Extensible) (bool, error)

Add adds extensible payload to the pool. First return value specifies if payload was new. Second one is nil if and only if payload is valid.

func (*Pool) Get

func (p *Pool) Get(h util.Uint256) *payload.Extensible

Get returns payload by hash.

func (*Pool) RemoveStale

func (p *Pool) RemoveStale(index uint32)

RemoveStale removes invalid payloads after block processing.