Documentation ¶
Index ¶
- Constants
- Variables
- func EncryptPrivateKeysPackage(publicFlipKey *ecies.PrivateKey, privateFlipKey *ecies.PrivateKey, ...) []byte
- type AsyncKeysPool
- func (pool *AsyncKeysPool) AddPrivateKeysPackage(keysPackage *types.PrivateFlipKeysPackage, _ bool) error
- func (pool *AsyncKeysPool) AddPublicFlipKey(key *types.PublicFlipKey, _ bool) error
- func (pool *AsyncKeysPool) GetFlipKeys() []*types.PublicFlipKey
- func (pool *AsyncKeysPool) GetFlipPackagesHashes() []common.Hash128
- type AsyncTxPool
- type FlipKeysPool
- type KeysPool
- func (p *KeysPool) Add(hash common.Hash128, entry interface{}, highPriority bool)
- func (p *KeysPool) AddPrivateFlipKeysPackages(batch []*types.PrivateFlipKeysPackage)
- func (p *KeysPool) AddPrivateKeysPackage(keysPackage *types.PrivateFlipKeysPackage, own bool) error
- func (p *KeysPool) AddPublicFlipKey(key *types.PublicFlipKey, own bool) error
- func (p *KeysPool) AddPublicFlipKeys(batch []*types.PublicFlipKey)
- func (p *KeysPool) Clear()
- func (p *KeysPool) Get(hash common.Hash128) (entry interface{}, highPriority bool, present bool)
- func (p *KeysPool) GetFlipKeys() []*types.PublicFlipKey
- func (p *KeysPool) GetFlipPackagesHashes() []common.Hash128
- func (p *KeysPool) GetPrivateFlipKey(address common.Address) *ecies.PrivateKey
- func (p *KeysPool) GetPublicFlipKey(address common.Address) *ecies.PrivateKey
- func (p *KeysPool) Has(hash common.Hash128) bool
- func (p *KeysPool) Initialize(head *types.Header)
- func (p *KeysPool) InitializePrivateKeyIndexes(indexes map[common.Address]int)
- func (p *KeysPool) MaxParallelPulls() uint32
- func (p *KeysPool) PushTracker() pushpull.PendingPushTracker
- func (p *KeysPool) SupportPendingRequests() bool
- type TransactionPool
- type TxPool
- func (pool *TxPool) Add(tx *types.Transaction) error
- func (pool *TxPool) AddTxs(txs []*types.Transaction)
- func (pool *TxPool) BuildBlockTransactions() []*types.Transaction
- func (pool *TxPool) GetPendingByAddress(address common.Address) []*types.Transaction
- func (pool *TxPool) GetPendingTransaction() []*types.Transaction
- func (pool *TxPool) GetTx(hash common.Hash) *types.Transaction
- func (pool *TxPool) Initialize(head *types.Header, coinbase common.Address)
- func (pool *TxPool) Remove(transaction *types.Transaction)
- func (pool *TxPool) ResetTo(block *types.Block)
- func (pool *TxPool) StartSync()
- func (pool *TxPool) StopSync(block *types.Block)
- func (pool *TxPool) Validate(tx *types.Transaction) error
Constants ¶
View Source
const ( BlockBodySize = 300 * 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 (*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) GetFlipKeys ¶
func (p *KeysPool) GetFlipKeys() []*types.PublicFlipKey
func (*KeysPool) GetFlipPackagesHashes ¶
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) Initialize ¶
func (*KeysPool) InitializePrivateKeyIndexes ¶
func (*KeysPool) MaxParallelPulls ¶ added in v0.19.5
func (*KeysPool) PushTracker ¶ added in v0.19.5
func (p *KeysPool) PushTracker() pushpull.PendingPushTracker
func (*KeysPool) SupportPendingRequests ¶ added in v0.19.5
type TransactionPool ¶
type TransactionPool interface { Add(tx *types.Transaction) error GetPendingTransaction() []*types.Transaction }
type TxPool ¶
type TxPool struct {
// contains filtered or unexported fields
}
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) Initialize ¶
func (*TxPool) Remove ¶
func (pool *TxPool) Remove(transaction *types.Transaction)
Click to show internal directories.
Click to hide internal directories.