files

Documentation

Index

• Constants
• type Processor
  • func NewProcessor(deps ProcessorDeps) *Processor
  • func (p *Processor) AddDirectory(ctx context.Context, albumName string, dirPath string) ([]string, error)
  • func (p *Processor) AddFile(ctx context.Context, albumName string, filePath string, ...) (err error)
• type ProcessorDeps

Constants

const (
	ErrSkip = ctxd.SentinelError("unsupported file skipped")
)

Types

type Processor

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

func NewProcessor

func NewProcessor(deps ProcessorDeps) *Processor

func (*Processor) AddDirectory

func (p *Processor) AddDirectory(ctx context.Context, albumName string, dirPath string) ([]string, error)

func (*Processor) AddFile

func (p *Processor) AddFile(ctx context.Context, albumName string, filePath string, after ...func(hash uniq.Hash)) (err error)

type ProcessorDeps

type ProcessorDeps interface {
	StatsTracker() stats.Tracker
	CtxdLogger() ctxd.Logger

	PhotoAlbumFinder() uniq.Finder[photo.Album]
	PhotoAlbumEnsurer() uniq.Ensurer[photo.Album]
	PhotoAlbumImageAdder() photo.AlbumImageAdder

	PhotoImageEnsurer() uniq.Ensurer[photo.Image]
	PhotoImageIndexer() photo.ImageIndexer

	PhotoGpxEnsurer() uniq.Ensurer[photo.Gpx]

	DepCache() *dep.Cache
}