background

Documentation

Index

• type BackgroundRunner
  • func GetBackgroundRunner(db db.Database, key, secret, callback string) *BackgroundRunner
  • func (b *BackgroundRunner) AddFolder(ctx context.Context, folderName string, d discogs.Discogs, u *pb.StoredUser) error
  • func (b *BackgroundRunner) AdjustSales(ctx context.Context, c *pb.SaleConfig, user *pb.StoredUser, ...) error
  • func (b *BackgroundRunner) CleanCollection(ctx context.Context, d discogs.Discogs, refreshId int64) error
  • func (b *BackgroundRunner) HardLink(ctx context.Context, user *pb.StoredUser, records []*pb.Record, ...) error
  • func (b *BackgroundRunner) LinkSales(ctx context.Context, user *pb.StoredUser) error
  • func (b *BackgroundRunner) ProcessArrived(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessCollectionPage(ctx context.Context, d discogs.Discogs, page int32, refreshId int64) (int32, error)
  • func (b *BackgroundRunner) ProcessGoalFolder(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessIntents(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessKeep(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessListenDate(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessSetClean(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessSetWeight(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessSetWidth(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) ProcessSleeve(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, ...) error
  • func (b *BackgroundRunner) RefereshWants(ctx context.Context, d discogs.Discogs) error
  • func (b *BackgroundRunner) RefreshUpdates(ctx context.Context, d discogs.Discogs) error
  • func (b *BackgroundRunner) RefreshUser(ctx context.Context, d discogs.Discogs, utoken string) error
  • func (b *BackgroundRunner) RefreshWantlists(ctx context.Context, di discogs.Discogs, auth string) error
  • func (b *BackgroundRunner) RunMoves(ctx context.Context, user *pb.StoredUser, ...) error
  • func (b *BackgroundRunner) SyncSales(ctx context.Context, d discogs.Discogs, page int32, id int64) (*pbd.Pagination, error)
  • func (b *BackgroundRunner) UpdateSalePrice(ctx context.Context, d discogs.Discogs, sid int64, newprice int32) error

Types

type BackgroundRunner

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

func GetBackgroundRunner

func GetBackgroundRunner(db db.Database, key, secret, callback string) *BackgroundRunner

func (*BackgroundRunner) AddFolder

func (b *BackgroundRunner) AddFolder(ctx context.Context, folderName string, d discogs.Discogs, u *pb.StoredUser) error

func (*BackgroundRunner) AdjustSales

func (b *BackgroundRunner) AdjustSales(ctx context.Context, c *pb.SaleConfig, user *pb.StoredUser, enqueue func(context.Context, *pb.EnqueueRequest) (*pb.EnqueueResponse, error)) error

func (*BackgroundRunner) CleanCollection

func (b *BackgroundRunner) CleanCollection(ctx context.Context, d discogs.Discogs, refreshId int64) error

func (*BackgroundRunner) HardLink

func (b *BackgroundRunner) HardLink(ctx context.Context, user *pb.StoredUser, records []*pb.Record, sales []*pb.SaleInfo) error

func (*BackgroundRunner) LinkSales

func (b *BackgroundRunner) LinkSales(ctx context.Context, user *pb.StoredUser) error

func (*BackgroundRunner) ProcessArrived

func (b *BackgroundRunner) ProcessArrived(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) ProcessCollectionPage

func (b *BackgroundRunner) ProcessCollectionPage(ctx context.Context, d discogs.Discogs, page int32, refreshId int64) (int32, error)

func (*BackgroundRunner) ProcessGoalFolder

func (b *BackgroundRunner) ProcessGoalFolder(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) ProcessIntents

func (b *BackgroundRunner) ProcessIntents(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, auth string) error

func (*BackgroundRunner) ProcessKeep

func (b *BackgroundRunner) ProcessKeep(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) ProcessListenDate

func (b *BackgroundRunner) ProcessListenDate(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) ProcessSetClean

func (b *BackgroundRunner) ProcessSetClean(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) ProcessSetWeight

func (b *BackgroundRunner) ProcessSetWeight(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) ProcessSetWidth

func (b *BackgroundRunner) ProcessSetWidth(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) ProcessSleeve

func (b *BackgroundRunner) ProcessSleeve(ctx context.Context, d discogs.Discogs, r *pb.Record, i *pb.Intent, user *pb.StoredUser, fields []*pbd.Field) error

func (*BackgroundRunner) RefereshWants

func (b *BackgroundRunner) RefereshWants(ctx context.Context, d discogs.Discogs) error

func (*BackgroundRunner) RefreshUpdates

func (b *BackgroundRunner) RefreshUpdates(ctx context.Context, d discogs.Discogs) error

func (*BackgroundRunner) RefreshUser

func (b *BackgroundRunner) RefreshUser(ctx context.Context, d discogs.Discogs, utoken string) error

func (*BackgroundRunner) RefreshWantlists

func (b *BackgroundRunner) RefreshWantlists(ctx context.Context, di discogs.Discogs, auth string) error

func (*BackgroundRunner) RunMoves

func (b *BackgroundRunner) RunMoves(ctx context.Context, user *pb.StoredUser, enqueue func(context.Context, *pb.EnqueueRequest) (*pb.EnqueueResponse, error)) error

func (*BackgroundRunner) SyncSales

func (b *BackgroundRunner) SyncSales(ctx context.Context, d discogs.Discogs, page int32, id int64) (*pbd.Pagination, error)

func (*BackgroundRunner) UpdateSalePrice

func (b *BackgroundRunner) UpdateSalePrice(ctx context.Context, d discogs.Discogs, sid int64, newprice int32) error