tasks

Documentation

Index

• Constants
• func NewReadPhotoFileTask(path string) (*asynq.Task, error)
• func NewRescanFoldersTask() (*asynq.Task, error)
• type FoldersRescanner
  • func NewFoldersRescanner(photoService photoService) *FoldersRescanner
  • func (f *FoldersRescanner) ProcessTask(ctx context.Context, t *asynq.Task) error
• type PhotoFileReader
  • func NewPhotoFileReader(photoService photoService) *PhotoFileReader
  • func (f *PhotoFileReader) ProcessTask(ctx context.Context, t *asynq.Task) error
• type ReadPhotoFilePayload
• type RescanFoldersPayload

Constants

const (
	TypeReadPhotoFile = "photo:read_file"
)

const (
	TypeRescanFolders = "photo:rescan_folders"
)

Functions

func NewReadPhotoFileTask

func NewReadPhotoFileTask(path string) (*asynq.Task, error)

func NewRescanFoldersTask

func NewRescanFoldersTask() (*asynq.Task, error)

Types

type FoldersRescanner

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

func NewFoldersRescanner

func NewFoldersRescanner(photoService photoService) *FoldersRescanner

func (*FoldersRescanner) ProcessTask

func (f *FoldersRescanner) ProcessTask(ctx context.Context, t *asynq.Task) error

type PhotoFileReader

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

func NewPhotoFileReader

func NewPhotoFileReader(photoService photoService) *PhotoFileReader

func (*PhotoFileReader) ProcessTask

func (f *PhotoFileReader) ProcessTask(ctx context.Context, t *asynq.Task) error

type ReadPhotoFilePayload

type ReadPhotoFilePayload struct {
	Path string `json:"path"`
}

type RescanFoldersPayload

type RescanFoldersPayload struct{}