Searched refs:correctnessBatcher (Results 1 – 1 of 1) sorted by relevance
36 type correctnessBatcher struct { struct44 func (cb *correctnessBatcher) AggregatorFor(*export.Descriptor) export.Aggregator { argument48 func (cb *correctnessBatcher) CheckpointSet() export.CheckpointSet { argument53 func (*correctnessBatcher) FinishedCollection() { argument56 func (cb *correctnessBatcher) Process(_ context.Context, record export.Record) error { argument68 batcher := &correctnessBatcher{103 batcher := &correctnessBatcher{138 batcher := &correctnessBatcher{153 batcher := &correctnessBatcher{173 batcher := &correctnessBatcher{