File tree 1 file changed +4
-5
lines changed
quickwit/quickwit-indexing/src/source 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -377,30 +377,29 @@ impl Handler<SuggestTruncate> for SourceActor {
377
377
}
378
378
}
379
379
380
- #[ derive( Debug , Default ) ]
381
- struct BatchBuilder {
380
+ pub struct BatchBuilder {
382
381
docs : Vec < Bytes > ,
383
382
num_bytes : u64 ,
384
383
checkpoint_delta : SourceCheckpointDelta ,
385
384
}
386
385
387
386
impl BatchBuilder {
388
- fn build ( self ) -> RawDocBatch {
387
+ pub fn build ( self ) -> RawDocBatch {
389
388
RawDocBatch {
390
389
docs : self . docs ,
391
390
checkpoint_delta : self . checkpoint_delta ,
392
391
force_commit : false ,
393
392
}
394
393
}
395
- fn build_force ( self ) -> RawDocBatch {
394
+ pub fn build_force ( self ) -> RawDocBatch {
396
395
RawDocBatch {
397
396
docs : self . docs ,
398
397
checkpoint_delta : self . checkpoint_delta ,
399
398
force_commit : true ,
400
399
}
401
400
}
402
401
403
- fn push ( & mut self , doc : Bytes , num_bytes : u64 ) {
402
+ pub fn push ( & mut self , doc : Bytes , num_bytes : u64 ) {
404
403
self . docs . push ( doc) ;
405
404
self . num_bytes += num_bytes;
406
405
}
You can’t perform that action at this time.
0 commit comments