Lines Matching defs:Compactor

696 type Compactor struct {  struct
697 	Dir  string
698 	Size int
700 	FileStore interface {
706 	RateLimit limiter.Rate
708 	formatFileName FormatFileNameFunc
709 	parseFileName  ParseFileNameFunc
711 	mu                 sync.RWMutex
712 	snapshotsEnabled   bool
713 	compactionsEnabled bool
716 	lastSnapshotDuration time.Duration
718 	snapshotLatencies *latencies
721 	snapshotsInterrupt chan struct{}
723 	compactionsInterrupt chan struct{}
725 	files map[string]struct{}
736 func (c *Compactor) WithFormatFileNameFunc(formatFileNameFunc FormatFileNameFunc) {
740 func (c *Compactor) WithParseFileNameFunc(parseFileNameFunc ParseFileNameFunc) {
745 func (c *Compactor) Open() {
762 func (c *Compactor) Close() {
779 func (c *Compactor) DisableSnapshots() {
790 func (c *Compactor) EnableSnapshots() {
800 func (c *Compactor) DisableCompactions() {
811 func (c *Compactor) EnableCompactions() {
821 func (c *Compactor) WriteSnapshot(cache *Cache) ([]string, error) {
894 func (c *Compactor) compact(fast bool, tsmFiles []string) ([]string, error) {
957 func (c *Compactor) CompactFull(tsmFiles []string) ([]string, error) {
989 func (c *Compactor) CompactFast(tsmFiles []string) ([]string, error) {
1023 func (c *Compactor) removeTmpFiles(files []string) error {
1034 …wFiles(generation, sequence int, src []string, iter KeyIterator, throttle bool) ([]string, error) {
1084 func (c *Compactor) write(path string, iter KeyIterator, throttle bool) (err error) {
1194 func (c *Compactor) add(files []string) bool {
1212 func (c *Compactor) remove(files []string) {