mempool

May 9, 2022

Changes in this version

type MemPool

+ RemoveAliveTimeoutTxs func(removeDuration time.Duration) uint64

Sep 15, 2021

Changes in this version

type TxCache

+ func (tc *TxCache) StopTxListen()

Aug 20, 2021

Changes in this version

type Config

+ BlockTimeout time.Duration

+ IsTimed bool

Jun 8, 2021

Changes in this version

type TxCache

+ TxRespC chan *TxWithResp

+ type TxWithResp struct

+ Ch chan bool

+ Tx pb.Transaction

May 7, 2021

Changes in this version

type External

+ GetPendingTransactions func(max int) []pb.Transaction

+ GetTransaction func(hash *types.Hash) pb.Transaction

type MemPool

+ SubscribeTxEvent func(chan<- pb.Transactions) event.Subscription

Jun 2, 2021

Changes in this version

type Config

+ GetAccountNonce GetAccountNonceFunc

+ type GetAccountNonceFunc func(address *types.Address) uint64

Feb 24, 2021

Changes in this version

type Config

+ RebroadcastTimeout time.Duration

+ StoragePath string

type MemPool

+ GetTimeoutTransactions func(rebroadcastDuration time.Duration) [][]*pb.Transaction

Jan 5, 2021

Changes in this version

+ type ChainState struct

+ BlockHash *types.Hash

+ Height uint64

+ TxHashList []*types.Hash

+ type External interface

+ GetPendingNonceByAccount func(account string) uint64

+ IsPoolFull func() bool

type MemPool

+ GenerateBlock func() *raftproto.RequestBatch

+ HasPendingRequest func() bool

+ ProcessTransactions func(txs []*pb.Transaction, isLeader bool) *raftproto.RequestBatch

+ SetBatchSeqNo func(batchSeq uint64)

type TxCache

+ RecvTxC chan *pb.Transaction

+ TxSetC chan *raftproto.TxSlice

+ func NewTxCache(txSliceTimeout time.Duration, txSetSize uint64, logger logrus.FieldLogger) *TxCache

+ func (tc *TxCache) ListenEvent()

Oct 30, 2020

Changes in this version

+ const DefaultBatchSize

+ const DefaultBatchTick

+ const DefaultFetchTxnTimeout

+ const DefaultPoolSize

+ const DefaultTestBatchSize

+ const DefaultTestChainHeight

+ const DefaultTestTxSetSize

+ const DefaultTxCacheSize

+ const DefaultTxSetSize

+ const DefaultTxSetTick

+ const LevelDBDir

+ const StartReason1

+ const StartReason2

+ const StopReason1

+ const StopReason2

+ const StopReason3

+ var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")

+ var InterchainContractAddr = types.NewAddressByStr("000000000000000000000000000000000000000a")

+ type Config struct

+ BatchSize uint64

+ BatchTick time.Duration

+ ChainHeight uint64

+ FetchTimeout time.Duration

+ GetTransactionFunc func(hash *types.Hash) (*pb.Transaction, error)

+ ID uint64

+ Logger logrus.FieldLogger

+ PeerMgr peermgr.PeerManager

+ PoolSize uint64

+ TxSliceSize uint64

+ TxSliceTimeout time.Duration

+ type FetchTxnRequest struct

+ Height uint64

+ MissingTxHashes map[uint64]string

+ ReplicaId uint64

+ func (*FetchTxnRequest) Descriptor() ([]byte, []int)

+ func (*FetchTxnRequest) ProtoMessage()

+ func (m *FetchTxnRequest) GetHeight() uint64

+ func (m *FetchTxnRequest) GetMissingTxHashes() map[uint64]string

+ func (m *FetchTxnRequest) GetReplicaId() uint64

+ func (m *FetchTxnRequest) Marshal() (dAtA []byte, err error)

+ func (m *FetchTxnRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FetchTxnRequest) Reset()

+ func (m *FetchTxnRequest) Size() (n int)

+ func (m *FetchTxnRequest) String() string

+ func (m *FetchTxnRequest) Unmarshal(dAtA []byte) error

+ func (m *FetchTxnRequest) XXX_DiscardUnknown()

+ func (m *FetchTxnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FetchTxnRequest) XXX_Merge(src proto.Message)

+ func (m *FetchTxnRequest) XXX_Size() int

+ func (m *FetchTxnRequest) XXX_Unmarshal(b []byte) error

+ type FetchTxnResponse struct

+ Height uint64

+ MissingTxnList map[uint64]*pb.Transaction

+ ReplicaId uint64

+ func (*FetchTxnResponse) Descriptor() ([]byte, []int)

+ func (*FetchTxnResponse) ProtoMessage()

+ func (m *FetchTxnResponse) GetHeight() uint64

+ func (m *FetchTxnResponse) GetMissingTxnList() map[uint64]*pb.Transaction

+ func (m *FetchTxnResponse) GetReplicaId() uint64

+ func (m *FetchTxnResponse) Marshal() (dAtA []byte, err error)

+ func (m *FetchTxnResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *FetchTxnResponse) Reset()

+ func (m *FetchTxnResponse) Size() (n int)

+ func (m *FetchTxnResponse) String() string

+ func (m *FetchTxnResponse) Unmarshal(dAtA []byte) error

+ func (m *FetchTxnResponse) XXX_DiscardUnknown()

+ func (m *FetchTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FetchTxnResponse) XXX_Merge(src proto.Message)

+ func (m *FetchTxnResponse) XXX_Size() int

+ func (m *FetchTxnResponse) XXX_Unmarshal(b []byte) error

+ type LocalMissingTxnEvent struct

+ Height uint64

+ MissingTxnHashList map[uint64]string

+ WaitC chan bool

+ type MemPool interface

+ CommitTransactions func(ready *raftproto.Ready)

+ FetchTxn func(lostTxnEvent *LocalMissingTxnEvent)

+ GetBlockByHashList func(ready *raftproto.Ready) (map[uint64]string, []*pb.Transaction)

+ GetChainHeight func() uint64

+ GetPendingNonceByAccount func(account string) uint64

+ IncreaseChainHeight func()

+ RecvFetchTxnRequest func(fetchTxnRequest *FetchTxnRequest)

+ RecvFetchTxnResponse func(fetchTxnResponse *FetchTxnResponse)

+ RecvForwardTxs func(txSlice *TxSlice)

+ RecvTransaction func(tx *pb.Transaction) error

+ Start func() error

+ Stop func()

+ UpdateLeader func(uint64)

+ func NewMempool(config *Config, storage storage.Storage, batchC chan *raftproto.Ready) MemPool

+ type TxCache struct

+ func (tc *TxCache) IsFull() bool

+ type TxSlice struct

+ TxList []*pb.Transaction

+ func (*TxSlice) Descriptor() ([]byte, []int)

+ func (*TxSlice) ProtoMessage()

+ func (m *TxSlice) GetTxList() []*pb.Transaction

+ func (m *TxSlice) Marshal() (dAtA []byte, err error)

+ func (m *TxSlice) MarshalTo(dAtA []byte) (int, error)

+ func (m *TxSlice) Reset()

+ func (m *TxSlice) Size() (n int)

+ func (m *TxSlice) String() string

+ func (m *TxSlice) Unmarshal(dAtA []byte) error

+ func (m *TxSlice) XXX_DiscardUnknown()

+ func (m *TxSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TxSlice) XXX_Merge(src proto.Message)

+ func (m *TxSlice) XXX_Size() int

+ func (m *TxSlice) XXX_Unmarshal(b []byte) error