backend

Documentation

Index

• Constants
• type BloomBackend
  • func NewBloomBackend() *BloomBackend
  • func (b *BloomBackend) BloomStatus() (uint32, uint32)
  • func (b *BloomBackend) Close()
  • func (b *BloomBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)
  • func (b *BloomBackend) StartBloomHandlers(sectionSize uint32, db *leveldbstore.LevelDBStore) error

Constants

const (
	// bloomServiceThreads is the number of goroutines used globally by an Ethereum
	// instance to service bloombits lookups for all running filters.
	BloomServiceThreads = 16

	// bloomFilterThreads is the number of goroutines used locally per filter to
	// multiplex requests onto the global servicing goroutines.
	BloomFilterThreads = 3

	// bloomRetrievalBatch is the maximum number of bloom bit retrievals to service
	// in a single batch.
	BloomRetrievalBatch = 16

	// bloomRetrievalWait is the maximum time to wait for enough bloom bit requests
	// to accumulate request an entire batch (avoiding hysteresis).
	BloomRetrievalWait = time.Duration(0)
)

Types

type BloomBackend

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

func NewBloomBackend

func NewBloomBackend() *BloomBackend

func (*BloomBackend) BloomStatus

func (b *BloomBackend) BloomStatus() (uint32, uint32)

func (*BloomBackend) Close

func (b *BloomBackend) Close()

Close

func (*BloomBackend) ServiceFilter

func (b *BloomBackend) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)

func (*BloomBackend) StartBloomHandlers

func (b *BloomBackend) StartBloomHandlers(sectionSize uint32, db *leveldbstore.LevelDBStore) error

startBloomHandlers starts a batch of goroutines to accept bloom bit database retrievals from possibly a range of filters and serving the data to satisfy.