mempool

Documentation

Index

• Constants
• type Backend
  • func NewBackend(limit int) *Backend
• type BloomFilter
  • func NewBloomFilter() *BloomFilter
  • func (bf BloomFilter) Add(value string)
  • func (bf BloomFilter) Contains(value string) bool
• type MemPool
  • func NewMemPool() *MemPool
• type Producer
  • func NewProducer() *Producer
  • func (pd *Producer) AddTxn(txn *message.Transaction)
  • func (pd *Producer) CollectTxn(txn *message.Transaction)
  • func (pd *Producer) GeneratePayload() []*message.Transaction
  • func (pd *Producer) TotalReceivedTxNo() int64
• type SimpleHash

Constants

const DEFAULT_SIZE = 2 << 24

Types

type Backend

type Backend struct {
	*BloomFilter
	// contains filtered or unexported fields
}

func NewBackend

func NewBackend(limit int) *Backend

type BloomFilter

type BloomFilter struct {
	Set   *bitset.BitSet
	Funcs [6]SimpleHash
}

func NewBloomFilter

func NewBloomFilter() *BloomFilter

func (BloomFilter) Add

func (bf BloomFilter) Add(value string)

func (BloomFilter) Contains

func (bf BloomFilter) Contains(value string) bool

type MemPool

type MemPool struct {
	*Backend
}

func NewMemPool

func NewMemPool() *MemPool

NewTransactions creates a new memory pool for transactions.

type Producer

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

func NewProducer

func NewProducer() *Producer

func (*Producer) AddTxn

func (pd *Producer) AddTxn(txn *message.Transaction)

func (*Producer) CollectTxn

func (pd *Producer) CollectTxn(txn *message.Transaction)

func (*Producer) GeneratePayload

func (pd *Producer) GeneratePayload() []*message.Transaction

func (*Producer) TotalReceivedTxNo

func (pd *Producer) TotalReceivedTxNo() int64

type SimpleHash

type SimpleHash struct {
	Cap  uint
	Seed uint
}