pool

Documentation

Index

• type Pool
  • func NewPool(horn *horn.Horn, msgMgt msglist.IMsgList) *Pool
  • func (p *Pool) All() ([]types.IMessage, []types.IMessage)
  • func (p *Pool) Delete(msg types.IMessage)
  • func (p *Pool) Info() map[string]interface{}
  • func (p *Pool) Name() string
  • func (p *Pool) NeedPackaged(count int) []types.IMessage
  • func (p *Pool) Put(msg types.IMessage, isPeer bool) error
  • func (p *Pool) ReceiveMsgFromPeer(msg types.IMessage) error
  • func (p *Pool) Start() error
  • func (p *Pool) Stop() error

Types

type Pool

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

func NewPool

func NewPool(horn *horn.Horn, msgMgt msglist.IMsgList) *Pool

func (*Pool) All

func (p *Pool) All() ([]types.IMessage, []types.IMessage)

Get all transactions in the trading pool

func (*Pool) Delete

func (p *Pool) Delete(msg types.IMessage)

func (*Pool) Info

func (p *Pool) Info() map[string]interface{}

func (*Pool) Name

func (p *Pool) Name() string

func (*Pool) NeedPackaged

func (p *Pool) NeedPackaged(count int) []types.IMessage

func (*Pool) Put

func (p *Pool) Put(msg types.IMessage, isPeer bool) error

Verify adding messages to the message pool

func (*Pool) ReceiveMsgFromPeer

func (p *Pool) ReceiveMsgFromPeer(msg types.IMessage) error

func (*Pool) Start

func (p *Pool) Start() error

func (*Pool) Stop

func (p *Pool) Stop() error