listenpool

Documentation

Index

• type ListenPool
  • func NewListenPool() *ListenPool
  • func (p *ListenPool) Obtain(cp func(interface{}) bool, tranSizeLimit int) []types.Transaction
  • func (p *ListenPool) PackageTransaction(transactions []types.Transaction)
  • func (p *ListenPool) Push(tran types.Transaction)

Types

type ListenPool

type ListenPool struct {
	Transactions []types.Transaction
	Size         int
	ChanListen   chan int
	// contains filtered or unexported fields
}

func NewListenPool

func NewListenPool() *ListenPool

func (*ListenPool) Obtain

func (p *ListenPool) Obtain(cp func(interface{}) bool, tranSizeLimit int) []types.Transaction

func (*ListenPool) PackageTransaction

func (p *ListenPool) PackageTransaction(transactions []types.Transaction)

func (*ListenPool) Push

func (p *ListenPool) Push(tran types.Transaction)