compactor

type Config struct {
	JobConcurrency  int            `yaml:"job_capacity"`
	JobPollInterval time.Duration  `yaml:"job_poll_interval"`
	SmallObjectSize int            `yaml:"small_object_size_bytes"`
	TempDir         string         `yaml:"temp_dir"`
	RequestTimeout  time.Duration  `yaml:"request_timeout"`
	MetricsExporter metrics.Config `yaml:"metrics_exporter"`
}

type MetastoreClient interface {
	metastorev1.CompactionServiceClient
	metastorev1.IndexServiceClient
}

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