queuelogic

Documentation

Index

• Variables
• type DownloaderBridge
  • func (d *DownloaderBridge) Download(ctx context.Context, url string) (string, error)
• type Queue
  • func GetQueue(r rstore_client.RStoreClient, b *background.BackgroundRunner, ...) *Queue
  • func (q *Queue) Drain(ctx context.Context, req *pb.DrainRequest) (*pb.DrainResponse, error)
  • 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) error
  • func (q *Queue) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
  • func (q *Queue) Run()

Variables

var (
	QUEUE_PREFIX    = "gramophile/taskqueue/"
	DL_QUEUE_PREFIX = "gramophile/dlq/"
)

Types

type DownloaderBridge

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

func (*DownloaderBridge) Download

func (d *DownloaderBridge) Download(ctx context.Context, url string) (string, error)

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) Drain

func (q *Queue) Drain(ctx context.Context, req *pb.DrainRequest) (*pb.DrainResponse, error)

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) error

func (*Queue) List

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

func (*Queue) Run

func (q *Queue) Run()