Monorepo for Tangled forked from tangled.org/core
Something went wrong. Try again.
Go
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859// Copyright 2021 The Gitea Authors. All rights reserved.// SPDX-License-Identifier: MIT
package bleveutil
import ( "github.com/blevesearch/bleve/v2")
// FlushingBatch is a batch of operations that automatically flushes to the// underlying index once it reaches a certain size.type FlushingBatch struct { maxBatchSize int batch *bleve.Batch index bleve.Index}
// NewFlushingBatch creates a new flushing batch for the specified index. Once// the number of operations in the batch reaches the specified limit, the batch// automatically flushes its operations to the index.func NewFlushingBatch(index bleve.Index, maxBatchSize int) *FlushingBatch { return &FlushingBatch{ maxBatchSize: maxBatchSize, batch: index.NewBatch(), index: index, }}
// Index add a new index to batchfunc (b *FlushingBatch) Index(id string, data any) error { if err := b.batch.Index(id, data); err != nil { return err } return b.flushIfFull()}
// Delete add a delete index to batchfunc (b *FlushingBatch) Delete(id string) error { b.batch.Delete(id) return b.flushIfFull()}
func (b *FlushingBatch) flushIfFull() error { if b.batch.Size() < b.maxBatchSize { return nil } return b.Flush()}
// Flush submit the batch and create a new onefunc (b *FlushingBatch) Flush() error { err := b.index.Batch(b.batch) if err != nil { return err } b.batch = b.index.NewBatch() return nil}