store

type Store interface {
	GetLock(name string) lock.Locker

	CreateJob(j *job.Job) error
	ReplaceJob(j *job.Job) error
	LoadJob(j *job.Job) error
	DeleteJob(j *job.Job) (bool, error)

	CreateJobInBucket(bucket string, j *job.Job, isTTR bool) error
	GetReadyJobsInBucket(bucket string, num uint) ([]job.NameVersion, error)
	CollectInFlightJobNumberBucket(bucket string) (uint64, error)

	PushJobToQueue(queuePrefix, queueName string, j *job.Job) error
	PopJobFromQueue(queue string) (job.NameVersion, error)
	BPopJobFromQueue(queue string, blockTime time.Duration) (job.NameVersion, error)
	CollectInFlightJobNumberQueue(queuePrefix string) (map[string]uint64, error)
}