Documentation ¶
Index ¶
- Constants
- type BackgroundRunner
- func (b *BackgroundRunner) AddFolder(ctx context.Context, folderName string, d discogs.Discogs, u *pb.StoredUser) error
- func (b *BackgroundRunner) AddMasterWant(ctx context.Context, d discogs.Discogs, want *pb.Want) error
- func (b *BackgroundRunner) AdjustSales(ctx context.Context, c *pb.SaleConfig, user *pb.StoredUser, ...) error
- func (b *BackgroundRunner) AlignWants(ctx context.Context, di discogs.Discogs, c *pb.WantsConfig) error
- func (b *BackgroundRunner) CleanCollection(ctx context.Context, d discogs.Discogs, refreshId int64) error
- func (b *BackgroundRunner) CleanSales(ctx context.Context, userid int32, refreshId int64) error
- func (b *BackgroundRunner) CullWants(ctx context.Context, d discogs.Discogs, sid 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) ProcessScore(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) ProcessSetFolder(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) PullWants(ctx context.Context, d discogs.Discogs, page int32, sid int64, ...) (int32, error)
- func (b *BackgroundRunner) RefreshCollection(ctx context.Context, d discogs.Discogs, authToken string, ...) error
- func (b *BackgroundRunner) RefreshRelease(ctx context.Context, iid int64, d discogs.Discogs, force bool) error
- func (b *BackgroundRunner) RefreshReleaseDate(ctx context.Context, d discogs.Discogs, iid, rid int64) error
- func (b *BackgroundRunner) RefreshReleaseDates(ctx context.Context, d discogs.Discogs, token string, iid, mid int64, ...) error
- func (b *BackgroundRunner) RefreshState(ctx context.Context, iid int64, d discogs.Discogs, force bool) error
- func (b *BackgroundRunner) RefreshUser(ctx context.Context, d discogs.Discogs, utoken string) error
- func (b *BackgroundRunner) RefreshWant(ctx context.Context, d discogs.Discogs, want *pb.Want, authToken string, ...) error
- func (b *BackgroundRunner) RefreshWantlists(ctx context.Context, di discogs.Discogs, auth string, ...) error
- func (b *BackgroundRunner) RefreshWants(ctx context.Context, d discogs.Discogs) 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, releaseid int64, ...) error
Constants ¶
View Source
const ( RefreshReleasePeriod = time.Hour * 24 * 7 // Once a week RefreshReleaseDatesPeriod = time.Hour * 24 * 7 * 30 // Once a month )
View Source
const (
MaxMoves = 3
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BackgroundRunner ¶
type BackgroundRunner struct { ReleaseRefresh int64 // contains filtered or unexported fields }
func GetBackgroundRunner ¶ added in v0.67.0
func GetBackgroundRunner(db db.Database, key, secret, callback string) *BackgroundRunner
func (*BackgroundRunner) AddFolder ¶ added in v0.297.0
func (b *BackgroundRunner) AddFolder(ctx context.Context, folderName string, d discogs.Discogs, u *pb.StoredUser) error
func (*BackgroundRunner) AddMasterWant ¶ added in v0.667.0
func (*BackgroundRunner) AdjustSales ¶ added in v0.317.0
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) AlignWants ¶ added in v0.606.0
func (b *BackgroundRunner) AlignWants(ctx context.Context, di discogs.Discogs, c *pb.WantsConfig) error
Ensures everything is in a wantlist - only used when ORIGIN_GRAMOPHILE is set for wants
func (*BackgroundRunner) CleanCollection ¶ added in v0.249.0
func (*BackgroundRunner) CleanSales ¶ added in v0.550.0
func (*BackgroundRunner) HardLink ¶ added in v0.300.0
func (b *BackgroundRunner) HardLink(ctx context.Context, user *pb.StoredUser, records []*pb.Record, sales []*pb.SaleInfo) error
func (*BackgroundRunner) LinkSales ¶ added in v0.300.0
func (b *BackgroundRunner) LinkSales(ctx context.Context, user *pb.StoredUser) error
func (*BackgroundRunner) ProcessArrived ¶ added in v0.276.0
func (*BackgroundRunner) ProcessCollectionPage ¶ added in v0.67.0
func (*BackgroundRunner) ProcessGoalFolder ¶ added in v0.252.0
func (*BackgroundRunner) ProcessIntents ¶ added in v0.119.0
func (*BackgroundRunner) ProcessKeep ¶ added in v0.297.0
func (*BackgroundRunner) ProcessListenDate ¶ added in v0.191.0
func (*BackgroundRunner) ProcessScore ¶ added in v0.380.0
func (*BackgroundRunner) ProcessSetClean ¶ added in v0.119.0
func (*BackgroundRunner) ProcessSetFolder ¶ added in v0.817.0
func (*BackgroundRunner) ProcessSetWeight ¶ added in v0.241.0
func (*BackgroundRunner) ProcessSetWidth ¶ added in v0.215.0
func (*BackgroundRunner) ProcessSleeve ¶ added in v0.274.0
func (*BackgroundRunner) RefreshCollection ¶ added in v0.421.0
func (b *BackgroundRunner) RefreshCollection(ctx context.Context, d discogs.Discogs, authToken string, enqueue func(context.Context, *pb.EnqueueRequest) (*pb.EnqueueResponse, error)) error
func (*BackgroundRunner) RefreshRelease ¶ added in v0.421.0
func (*BackgroundRunner) RefreshReleaseDate ¶ added in v0.446.0
func (*BackgroundRunner) RefreshReleaseDates ¶ added in v0.446.0
func (b *BackgroundRunner) RefreshReleaseDates(ctx context.Context, d discogs.Discogs, token string, iid, mid int64, enqueue func(context.Context, *pb.EnqueueRequest) (*pb.EnqueueResponse, error)) error
func (*BackgroundRunner) RefreshState ¶ added in v0.775.0
func (*BackgroundRunner) RefreshUser ¶
func (*BackgroundRunner) RefreshWant ¶ added in v0.467.0
func (*BackgroundRunner) RefreshWantlists ¶ added in v0.304.0
func (b *BackgroundRunner) RefreshWantlists(ctx context.Context, di discogs.Discogs, auth string, enqueue func(context.Context, *pb.EnqueueRequest) (*pb.EnqueueResponse, error)) error
func (*BackgroundRunner) RefreshWants ¶ added in v0.467.0
func (*BackgroundRunner) RunMoves ¶ added in v0.318.0
func (b *BackgroundRunner) RunMoves(ctx context.Context, user *pb.StoredUser, enqueue func(context.Context, *pb.EnqueueRequest) (*pb.EnqueueResponse, error)) error
Click to show internal directories.
Click to hide internal directories.