collect

package

v0.2.2 Latest Latest Go to latest Published: Apr 20, 2026 License: MIT Imports: 4 Imported by: 0

Details

Package collect 提供内存收集的 Sink，主要用于测试

This section is empty.

This section is empty.

This section is empty.

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

Sink 将数据收集到内存中

func New() *Sink

New 创建新的 Sink

func (s *Sink) Consume(ctx context.Context, in <-chan types.Record) error

Consume 收集数据到内存

func (s *Sink) Count() int

Count 返回收集的数据数量

func (s *Sink) Data() []types.Record

Data 返回收集的数据

func (s *Sink) Init(config []byte) error

Init 初始化 Sink (无配置)

func (s *Sink) Reset()

Reset 清空收集的数据