db

Documentation

Index

• type DB

Types

type DB

type DB interface {
	// CreateQueue creates queue to db.
	// Returns eboolkiq.ErrQueueExists if queue exists.
	CreateQueue(ctx context.Context, queue *pb.Queue) error

	// GetQueue gets queue from db.
	// Returns eboolkiq.ErrQueueNotFound if queue not found.
	GetQueue(ctx context.Context, name string) (*pb.Queue, error)

	// DeleteQueue deletes queue from db.
	DeleteQueue(ctx context.Context, queue *pb.Queue) error

	// AddTask add task to queue.
	// Returns eboolkiq.ErrQueueNotFound if queue not found.
	AddTask(ctx context.Context, queue *pb.Queue, task *pb.Task) error

	// GetTask gets task from queue.
	// Returns eboolkiq.ErrQueueEmpty if queue has no task.
	GetTask(ctx context.Context, queue *pb.Queue) (*pb.Task, error)

	// FlushTask flush all task from queue.
	FlushTask(ctx context.Context, queue *pb.Queue)

	// AddWorking adds task to working queue.
	AddWorking(ctx context.Context, queue *pb.Queue, task *pb.Task) error

	// FindAndDeleteWorking finds task from working queue and delete.
	FindAndDeleteWorking(ctx context.Context, queue *pb.Queue, task *pb.Task) (*pb.Task, error)
}