background

package
v0.609.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 16, 2024 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	RefreshReleasePeriod      = time.Hour * 24          // 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) 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 (b *BackgroundRunner) CleanCollection(ctx context.Context, d discogs.Discogs, refreshId int64) error

func (*BackgroundRunner) CleanSales added in v0.550.0 

func (b *BackgroundRunner) CleanSales(ctx context.Context, userid int32, refreshId int64) error

func (*BackgroundRunner) CullWants added in v0.465.0 

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, 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 (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 added in v0.67.0 

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

func (*BackgroundRunner) ProcessGoalFolder added in v0.252.0 

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 added in v0.119.0 

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

func (*BackgroundRunner) ProcessKeep added in v0.297.0 

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 added in v0.191.0 

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) ProcessScore added in v0.380.0 

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

func (*BackgroundRunner) ProcessSetClean added in v0.119.0 

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 added in v0.241.0 

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 added in v0.215.0 

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 added in v0.274.0 

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) PullWants added in v0.465.0 

func (b *BackgroundRunner) PullWants(ctx context.Context, d discogs.Discogs, page int32, sid int64, wc *pb.WantsConfig) (int32, error)

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 (b *BackgroundRunner) RefreshRelease(ctx context.Context, iid int64, d discogs.Discogs) error

func (*BackgroundRunner) RefreshReleaseDate added in v0.446.0 

func (b *BackgroundRunner) RefreshReleaseDate(ctx context.Context, d discogs.Discogs, iid, rid int64) error

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) RefreshUpdates added in v0.273.0 

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) RefreshWant added in v0.467.0 

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

func (*BackgroundRunner) RefreshWantlists added in v0.304.0 

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

func (*BackgroundRunner) RefreshWants added in v0.467.0 

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

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

func (*BackgroundRunner) SyncSales added in v0.300.0 

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

func (*BackgroundRunner) SyncWants added in v0.467.0 

func (b *BackgroundRunner) SyncWants(ctx context.Context, d discogs.Discogs, user *pb.StoredUser, enqueue func(context.Context, *pb.EnqueueRequest) (*pb.EnqueueResponse, error)) error

func (*BackgroundRunner) UpdateSalePrice added in v0.317.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.