compactionworker

type Config struct {
	JobConcurrency       int            `yaml:"job_capacity" category:"advanced"`
	JobPollInterval      time.Duration  `yaml:"job_poll_interval" category:"advanced"`
	SmallObjectSize      int            `yaml:"small_object_size_bytes" category:"advanced"`
	TempDir              string         `yaml:"temp_dir" category:"advanced" doc:"default=/tmp"`
	RequestTimeout       time.Duration  `yaml:"request_timeout" category:"advanced"`
	CleanupMaxDuration   time.Duration  `yaml:"cleanup_max_duration" category:"advanced"`
	MetadataSource       string         `yaml:"metadata_source" category:"advanced"`
	MetadataFetchTimeout time.Duration  `yaml:"metadata_fetch_timeout" category:"advanced"`
	MetricsExporter      metrics.Config `yaml:"metrics_exporter" category:"advanced"`
}

type MetastoreClient interface {
	metastorev1.CompactionServiceClient
	metastorev1.IndexServiceClient
}

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