bloombits

package

v0.0.0-...-f8b7a73 Latest Latest Go to latest Published: Mar 16, 2019 License: GPL-3.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/linapex/ethereum-go-chinese

Links

Open Source Insights

Documentation ¶

Overview ¶

包BloomBits对成批数据执行Bloom过滤。

Index ¶

type Generator
- func NewGenerator(sections uint) (*Generator, error)
- func (b *Generator) AddBloom(index uint, bloom types.Bloom) error
- func (b *Generator) Bitset(idx uint) ([]byte, error)
type Matcher
- func NewMatcher(sectionSize uint64, filters [][][]byte) *Matcher
- func (m *Matcher) Start(ctx context.Context, begin, end uint64, results chan uint64) (*MatcherSession, error)
type MatcherSession
type Retrieval

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Generator ¶

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

发电机接收许多布卢姆滤波器并生成旋转的布卢姆位用于批量过滤。

func NewGenerator ¶

func NewGenerator(sections uint) (*Generator, error)

NewGenerator创建一个旋转的Bloom Generator，它可以迭代填充批量布卢姆过滤器的钻头。

func (*Generator) AddBloom ¶

func (b *Generator) AddBloom(index uint, bloom types.Bloom) error

addbloom接受一个bloom过滤器并设置相应的位列在记忆中。

func (*Generator) Bitset ¶

func (b *Generator) Bitset(idx uint) ([]byte, error)

位集返回属于给定位索引的位向量。花开了。

type Matcher ¶

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

Matcher是一个由调度程序和逻辑匹配程序组成的流水线系统，执行位流上的二进制和/或操作，创建一个潜在的流要检查数据内容的块。

func NewMatcher ¶

func NewMatcher(sectionSize uint64, filters [][][]byte) *Matcher

NewMatcher创建了一个新的管道，用于检索Bloom位流并执行地址和主题过滤。将筛选器组件设置为“nil”是允许并将导致跳过该筛选规则（或0x11…1）。

func (*Matcher) Start ¶

func (m *Matcher) Start(ctx context.Context, begin, end uint64, results chan uint64) (*MatcherSession, error)

Start启动匹配过程并返回一个bloom匹配流给定的块范围。如果范围内没有更多匹配项，则返回结果通道关闭。

type MatcherSession ¶

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

MatcherSession由已启动的Matcher返回，用作终止符对于正在运行的匹配操作。

func (*MatcherSession) AllocateRetrieval ¶

func (s *MatcherSession) AllocateRetrieval() (uint, bool)

allocateretrieval将一个bloom位索引分配给一个客户端进程，该进程可以立即请求并获取分配给该位的节内容或等待有一段时间需要更多的部分。

func (*MatcherSession) AllocateSections ¶

func (s *MatcherSession) AllocateSections(bit uint, count int) []uint64

分配操作分配已分配的位任务队列的全部或部分到请求过程。

func (*MatcherSession) Close ¶

func (s *MatcherSession) Close()

关闭停止匹配进程并等待所有子进程终止返回前。超时可用于正常关机，允许当前正在运行要在此时间之前完成的检索。

func (*MatcherSession) DeliverSections ¶

func (s *MatcherSession) DeliverSections(bit uint, sections []uint64, bitsets [][]byte)

deliversections为特定的bloom提供一批区段位向量要注入处理管道的位索引。

func (*MatcherSession) Error ¶

func (s *MatcherSession) Error() error

错误返回匹配会话期间遇到的任何失败。

func (*MatcherSession) Multiplex ¶

func (s *MatcherSession) Multiplex(batch int, wait time.Duration, mux chan chan *Retrieval)

多路复用轮询匹配器会话以执行检索任务，并将其多路复用到请求的检索队列将与其他会话一起提供服务。

此方法将在会话的生存期内阻塞。即使在终止之后在会议期间，任何在飞行中的请求都需要得到响应！空响应不过在那种情况下还是可以的。

func (*MatcherSession) PendingSections ¶

func (s *MatcherSession) PendingSections(bit uint) int

PendingSections返回属于给定的牙轮钻头指数。

type Retrieval ¶

type Retrieval struct {
	Bit      uint
	Sections []uint64
	Bitsets  [][]byte

	Context context.Context
	Error   error
}

检索表示对给定任务的检索任务分配的请求具有给定数量的提取元素的位，或对这种请求的响应。它还可以将实际结果集用作传递数据结构。

“竞赛”和“错误”字段由轻型客户端用于终止匹配如果在管道的某个路径上遇到错误，则为早期。

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL