queuelogic

Documentation

Index

• Variables
• type Queue
  • func GetQueue(r rstore_client.RStoreClient, b *background.BackgroundRunner, ...) *Queue
  • func (q *Queue) Enqueue(ctx context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)
  • func (q *Queue) Execute(ctx context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)
  • func (q *Queue) ExecuteInternal(ctx context.Context, d discogs.Discogs, u *pb.StoredUser, ...) error
  • func (q *Queue) FlushQueue(ctx context.Context)
  • func (q *Queue) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
  • func (q *Queue) Run()

Variables

var (
	QUEUE_PREFIX = "gramophile/taskqueue/"
)

Types

type Queue

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

func GetQueue

func GetQueue(r rstore_client.RStoreClient, b *background.BackgroundRunner, d discogs.Discogs, db db.Database) *Queue

func (*Queue) Enqueue

func (q *Queue) Enqueue(ctx context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)

func (*Queue) Execute

func (q *Queue) Execute(ctx context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)

func (*Queue) ExecuteInternal

func (q *Queue) ExecuteInternal(ctx context.Context, d discogs.Discogs, u *pb.StoredUser, entry *pb.QueueElement) error

func (*Queue) FlushQueue

func (q *Queue) FlushQueue(ctx context.Context)

func (*Queue) List

func (q *Queue) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)

func (*Queue) Run

func (q *Queue) Run()