jobqueue

type Builder interface {
	// BuildJobs builds new jobs and sends them to the provided channel
	// It should be a blocking call and returns when ctx is cancelled.
	BuildJobs(ctx context.Context, jobsChan chan<- *grpc.Job)

	// OnJobResponse reports back the response of the job execution.
	OnJobResponse(response *grpc.JobResult) error

	// JobsLeft reports the estimated number of jobs left to process.
	// It should be updated when jobs are successfully processed or new work is picked up for execution.
	// It should include in-flight and upcoming jobs even if they are created on-demand.
	// It could just estimate jobs left to be processed for concluding ongoing unit of work.
	// The implementation must be concurrency safe.
	JobsLeft() int
}

type CompactorClient interface {
	JobQueueClient() grpc.JobQueueClient
}

type JobRunner interface {
	Run(ctx context.Context, job *grpc.Job) ([]byte, error)
}

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

type WorkerConfig struct {
	NumWorkers int `yaml:"num_sub_workers"`
}

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