task

Documentation

Index

• type BlobCleaner
• type BlobStoreMigrator
• type CleanGeneratedJob
  • func (j *CleanGeneratedJob) Execute(ctx context.Context, progress *job.Progress)
• type CleanGeneratedOptions
• type InstallPackagesJob
  • func (j *InstallPackagesJob) Execute(ctx context.Context, progress *job.Progress)
• type MigrateBlobsJob
  • func (j *MigrateBlobsJob) Execute(ctx context.Context, progress *job.Progress)
• type MigrateSceneScreenshotsJob
  • func (j *MigrateSceneScreenshotsJob) Execute(ctx context.Context, progress *job.Progress)
• type PackagesJob
• type UninstallPackagesJob
  • func (j *UninstallPackagesJob) Execute(ctx context.Context, progress *job.Progress)
• type UpdatePackagesJob
  • func (j *UpdatePackagesJob) Execute(ctx context.Context, progress *job.Progress)
• type Vacuumer

Types

type BlobCleaner

type BlobCleaner interface {
	EntryExists(ctx context.Context, checksum string) (bool, error)
}

type BlobStoreMigrator

type BlobStoreMigrator interface {
	Count(ctx context.Context) (int, error)
	FindBlobs(ctx context.Context, n uint, lastChecksum string) ([]string, error)
	MigrateBlob(ctx context.Context, checksum string, deleteOld bool) error
}

type CleanGeneratedJob

type CleanGeneratedJob struct {
	Options CleanGeneratedOptions

	Paths                    *paths.Paths
	BlobsStorageType         config.BlobsStorageType
	VideoFileNamingAlgorithm models.HashAlgorithm

	BlobCleaner BlobCleaner
	Repository  models.Repository
	// contains filtered or unexported fields
}

func (*CleanGeneratedJob) Execute

func (j *CleanGeneratedJob) Execute(ctx context.Context, progress *job.Progress)

type CleanGeneratedOptions

type CleanGeneratedOptions struct {
	BlobFiles bool `json:"blobs"`

	Sprites     bool `json:"sprites"`
	Screenshots bool `json:"screenshots"`
	Transcodes  bool `json:"transcodes"`

	Markers bool `json:"markers"`

	ImageThumbnails bool `json:"imageThumbnails"`

	DryRun bool `json:"dryRun"`
}

type InstallPackagesJob

type InstallPackagesJob struct {
	PackagesJob
	Packages []*models.PackageSpecInput
}

func (*InstallPackagesJob) Execute

func (j *InstallPackagesJob) Execute(ctx context.Context, progress *job.Progress)

type MigrateBlobsJob

type MigrateBlobsJob struct {
	TxnManager txn.Manager
	BlobStore  BlobStoreMigrator
	Vacuumer   Vacuumer
	DeleteOld  bool
}

func (*MigrateBlobsJob) Execute

func (j *MigrateBlobsJob) Execute(ctx context.Context, progress *job.Progress)

type MigrateSceneScreenshotsJob

type MigrateSceneScreenshotsJob struct {
	ScreenshotsPath string
	Input           scene.MigrateSceneScreenshotsInput
	SceneRepo       scene.HashFinderCoverUpdater
	TxnManager      txn.Manager
}

func (*MigrateSceneScreenshotsJob) Execute

func (j *MigrateSceneScreenshotsJob) Execute(ctx context.Context, progress *job.Progress)

type PackagesJob

type PackagesJob struct {
	PackageManager *pkg.Manager
	OnComplete     func()
}

type UninstallPackagesJob

type UninstallPackagesJob struct {
	PackagesJob
	Packages []*models.PackageSpecInput
}

func (*UninstallPackagesJob) Execute

func (j *UninstallPackagesJob) Execute(ctx context.Context, progress *job.Progress)

type UpdatePackagesJob

type UpdatePackagesJob struct {
	PackagesJob
	Packages []*models.PackageSpecInput
}

func (*UpdatePackagesJob) Execute

func (j *UpdatePackagesJob) Execute(ctx context.Context, progress *job.Progress)

type Vacuumer

type Vacuumer interface {
	Vacuum(ctx context.Context) error
}