uploaders

Documentation

Index

• type CatalogProxy
  • func (c CatalogProxy) Create(createRequest catalog.CreateAlbum) error
  • func (c CatalogProxy) FindAllAlbums() ([]*catalog.Album, error)
  • func (c CatalogProxy) FindSignatures(signatures []*catalog.MediaSignature) ([]*catalog.MediaSignature, error)
  • func (c CatalogProxy) InsertMedias(medias []catalog.CreateMediaRequest) error
• type CatalogProxyAdapter
• type Uploader
  • func NewUploader(catalogProxy CatalogProxyAdapter, ...) (*Uploader, error)
  • func (u *Uploader) Upload(buffer []*backupmodel.AnalysedMedia, ...) error

Types

type CatalogProxy

type CatalogProxy struct{}

func (CatalogProxy) Create

func (c CatalogProxy) Create(createRequest catalog.CreateAlbum) error

func (CatalogProxy) FindAllAlbums

func (c CatalogProxy) FindAllAlbums() ([]*catalog.Album, error)

func (CatalogProxy) FindSignatures

func (c CatalogProxy) FindSignatures(signatures []*catalog.MediaSignature) ([]*catalog.MediaSignature, error)

func (CatalogProxy) InsertMedias

func (c CatalogProxy) InsertMedias(medias []catalog.CreateMediaRequest) error

type CatalogProxyAdapter

type CatalogProxyAdapter interface {
	FindAllAlbums() ([]*catalog.Album, error)
	InsertMedias(medias []catalog.CreateMediaRequest) error
	Create(createRequest catalog.CreateAlbum) error
	FindSignatures(signatures []*catalog.MediaSignature) ([]*catalog.MediaSignature, error)
}

type Uploader

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

func NewUploader

func NewUploader(catalogProxy CatalogProxyAdapter, onlineStorage backupmodel.OnlineStorageAdapter, owner string, postFilter backupmodel.PostAnalyseFilter) (*Uploader, error)

func (*Uploader) Upload

func (u *Uploader) Upload(buffer []*backupmodel.AnalysedMedia, progressChannel chan *backupmodel.ProgressEvent) error