mempool

package
v0.19.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 17, 2020 License: LGPL-3.0 Imports: 22 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	BlockBodySize  = 1024 * 1024
	MaxDeferredTxs = 100
)

Variables

View Source 
var (
	DuplicateTxError = errors.New("tx with same hash already exists")
	MempoolFullError = errors.New("mempool is full")
)

Functions

func EncryptPrivateKeysPackage 

func EncryptPrivateKeysPackage(publicFlipKey *ecies.PrivateKey, privateFlipKey *ecies.PrivateKey, pubKeys [][]byte) []byte

Types

type AsyncKeysPool added in v0.19.3 

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

func (*AsyncKeysPool) AddPrivateKeysPackage added in v0.19.3 

func (pool *AsyncKeysPool) AddPrivateKeysPackage(keysPackage *types.PrivateFlipKeysPackage, _ bool) error

func (*AsyncKeysPool) AddPublicFlipKey added in v0.19.3 

func (pool *AsyncKeysPool) AddPublicFlipKey(key *types.PublicFlipKey, _ bool) error

func (*AsyncKeysPool) GetFlipKeys added in v0.19.3 

func (pool *AsyncKeysPool) GetFlipKeys() []*types.PublicFlipKey

func (*AsyncKeysPool) GetFlipPackagesHashes added in v0.19.3 

func (pool *AsyncKeysPool) GetFlipPackagesHashes() []common.Hash128

type AsyncTxPool 

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

func NewAsyncTxPool 

func NewAsyncTxPool(txPool *TxPool) *AsyncTxPool

func (*AsyncTxPool) Add 

func (pool *AsyncTxPool) Add(tx *types.Transaction) error

func (*AsyncTxPool) GetPendingTransaction 

func (pool *AsyncTxPool) GetPendingTransaction() []*types.Transaction

type FlipKeysPool added in v0.19.3 

type FlipKeysPool interface {
	AddPrivateKeysPackage(keysPackage *types.PrivateFlipKeysPackage, own bool) error
	AddPublicFlipKey(key *types.PublicFlipKey, own bool) error
	GetFlipPackagesHashes() []common.Hash128
	GetFlipKeys() []*types.PublicFlipKey
}

func NewAsyncKeysPool added in v0.19.3 

func NewAsyncKeysPool(inner *KeysPool) FlipKeysPool

type KeysPool 

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

func NewKeysPool 

func NewKeysPool(db dbm.DB, appState *appstate.AppState, bus eventbus.Bus, secStore *secstore.SecStore) *KeysPool

func (*KeysPool) Add 

func (p *KeysPool) Add(hash common.Hash128, entry interface{})

func (*KeysPool) AddPrivateFlipKeysPackages added in v0.19.3 

func (p *KeysPool) AddPrivateFlipKeysPackages(batch []*types.PrivateFlipKeysPackage)

func (*KeysPool) AddPrivateKeysPackage 

func (p *KeysPool) AddPrivateKeysPackage(keysPackage *types.PrivateFlipKeysPackage, own bool) error

func (*KeysPool) AddPublicFlipKey 

func (p *KeysPool) AddPublicFlipKey(key *types.PublicFlipKey, own bool) error

func (*KeysPool) AddPublicFlipKeys added in v0.19.3 

func (p *KeysPool) AddPublicFlipKeys(batch []*types.PublicFlipKey)

func (*KeysPool) Clear 

func (p *KeysPool) Clear()

func (*KeysPool) Get 

func (p *KeysPool) Get(hash common.Hash128) (interface{}, bool)

func (*KeysPool) GetFlipKeys 

func (p *KeysPool) GetFlipKeys() []*types.PublicFlipKey

func (*KeysPool) GetFlipPackagesHashes 

func (p *KeysPool) GetFlipPackagesHashes() []common.Hash128

func (*KeysPool) GetPrivateFlipKey 

func (p *KeysPool) GetPrivateFlipKey(address common.Address) *ecies.PrivateKey

func (*KeysPool) GetPublicFlipKey 

func (p *KeysPool) GetPublicFlipKey(address common.Address) *ecies.PrivateKey

func (*KeysPool) Has 

func (p *KeysPool) Has(hash common.Hash128) bool

func (*KeysPool) Initialize 

func (p *KeysPool) Initialize(head *types.Header)

func (*KeysPool) InitializePrivateKeyIndexes 

func (p *KeysPool) InitializePrivateKeyIndexes(indexes map[common.Address]int)

func (*KeysPool) MaxPulls 

func (p *KeysPool) MaxPulls() uint32

type TransactionPool 

type TransactionPool interface {
	Add(tx *types.Transaction) error
	GetPendingTransaction() []*types.Transaction
}

type TxPool 

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

func NewTxPool 

func NewTxPool(appState *appstate.AppState, bus eventbus.Bus, cfg *config.Mempool, minFeePerByte *big.Int) *TxPool

func (*TxPool) Add 

func (pool *TxPool) Add(tx *types.Transaction) error

func (*TxPool) AddTxs added in v0.19.3 

func (pool *TxPool) AddTxs(txs []*types.Transaction)

func (*TxPool) BuildBlockTransactions 

func (pool *TxPool) BuildBlockTransactions() []*types.Transaction

func (*TxPool) GetPendingByAddress 

func (pool *TxPool) GetPendingByAddress(address common.Address) []*types.Transaction

func (*TxPool) GetPendingTransaction 

func (pool *TxPool) GetPendingTransaction() []*types.Transaction

func (*TxPool) GetTx 

func (pool *TxPool) GetTx(hash common.Hash) *types.Transaction

func (*TxPool) Initialize 

func (pool *TxPool) Initialize(head *types.Header, coinbase common.Address)

func (*TxPool) Remove 

func (pool *TxPool) Remove(transaction *types.Transaction)

func (*TxPool) ResetTo 

func (pool *TxPool) ResetTo(block *types.Block)

func (*TxPool) StartSync 

func (pool *TxPool) StartSync()

func (*TxPool) StopSync 

func (pool *TxPool) StopSync(block *types.Block)

func (*TxPool) Validate 

func (pool *TxPool) Validate(tx *types.Transaction) error

validate tx as inbound transaction

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.