Documentation ¶
Index ¶
- type Execution
- type MsgService
- type Status
- type Storage
- type TxPool
- func (pool *TxPool) GetStatus() Status
- func (pool *TxPool) GetTx(hash []byte) *core.Transaction
- func (pool *TxPool) GetTxStatus(hash []byte) TxStatus
- func (pool *TxPool) GetTxsFromQueue(max int) [][]byte
- func (pool *TxPool) GetTxsToExecute(hashes [][]byte) ([]*core.Transaction, [][]byte)
- func (pool *TxPool) PopTxsFromQueue(max int) [][]byte
- func (pool *TxPool) PutTxsToQueue(hashes [][]byte)
- func (pool *TxPool) RemoveTxs(hashes [][]byte)
- func (pool *TxPool) SetTxsPending(hashes [][]byte)
- func (pool *TxPool) StoreTxs(txs *core.TxList) error
- func (pool *TxPool) SubmitTx(tx *core.Transaction) error
- func (pool *TxPool) SyncTxs(peer *core.PublicKey, hashes [][]byte) error
- type TxStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Execution ¶
type Execution interface {
VerifyTx(tx *core.Transaction) error
}
type MsgService ¶
type TxPool ¶
type TxPool struct {
// contains filtered or unexported fields
}
func New ¶
func New(storage Storage, execution Execution, msgSvc MsgService, broadcastTx bool) *TxPool
func (*TxPool) GetTxStatus ¶
func (*TxPool) GetTxsFromQueue ¶
func (*TxPool) GetTxsToExecute ¶
func (pool *TxPool) GetTxsToExecute(hashes [][]byte) ([]*core.Transaction, [][]byte)
func (*TxPool) PopTxsFromQueue ¶
func (*TxPool) PutTxsToQueue ¶
func (*TxPool) SetTxsPending ¶
Click to show internal directories.
Click to hide internal directories.