Versions in this module Expand all Collapse all v0 v0.1.0 Dec 25, 2022 Changes in this version + const DynamoReadBatchSize + const DynamoWriteBatchSize + const IsoTime + func AlbumIndexedKeyPK(owner string, folderName string) string + func MediaPrimaryKeyPK(owner string, id string) string + func Must(repository catalog.RepositoryAdapter, err error) catalog.RepositoryAdapter + func NewRepository(awsSession *session.Session, tableName string) (catalog.RepositoryAdapter, error) + type AlbumIndexKey struct + AlbumIndexPK string + AlbumIndexSK string + func AlbumIndexedKey(owner, folderName string) AlbumIndexKey + func MediaAlbumIndexedKey(owner string, folderName string, dateTime time.Time, id string) AlbumIndexKey + type AlbumRecord struct + AlbumEnd time.Time + AlbumFolderName string + AlbumName string + AlbumOwner string + AlbumStart time.Time + type MediaRecord struct + DateTime time.Time + Details map[string]interface{} + Filename string + Id string + SignatureHash string + SignatureSize int + Type string + type Repository struct + func (r *Repository) CountMedias(owner string, folderName string) (int, error) + func (r *Repository) CreateTableIfNecessary() error + func (r *Repository) DeleteEmptyAlbum(owner string, folderName string) error + func (r *Repository) FindAlbums(ids ...catalog.AlbumId) ([]*catalog.Album, error) + func (r *Repository) FindAlbumsByOwner(owner string) ([]*catalog.Album, error) + func (r *Repository) FindExistingSignatures(owner string, signatures []*catalog.MediaSignature) ([]*catalog.MediaSignature, error) + func (r *Repository) FindMediaCurrentAlbum(owner, mediaId string) (string, error) + func (r *Repository) FindMediaIds(request *catalog.FindMediaRequest) ([]string, error) + func (r *Repository) FindMedias(request *catalog.FindMediaRequest) ([]*catalog.MediaMeta, error) + func (r *Repository) InsertAlbum(album catalog.Album) error + func (r *Repository) InsertMedias(owner string, medias []catalog.CreateMediaRequest) error + func (r *Repository) TransferMedias(owner string, mediaIds []string, newFolderName string) error + func (r *Repository) UpdateAlbum(album catalog.Album) error + type TablePk struct + PK string + SK string + func AlbumPrimaryKey(owner string, folderName string) TablePk + func MediaPrimaryKey(owner string, id string) TablePk