Versions in this module Expand all Collapse all v0 v0.1.0 Dec 25, 2022 Changes in this version + type ACLViewCatalogAdapter struct + func NewACLViewCatalogAdapter(t mockConstructorTestingTNewACLViewCatalogAdapter) *ACLViewCatalogAdapter + func (_m *ACLViewCatalogAdapter) FindAlbums(keys []catalog.AlbumId) ([]*catalog.Album, error) + func (_m *ACLViewCatalogAdapter) FindAllAlbums(owner string) ([]*catalog.Album, error) + func (_m *ACLViewCatalogAdapter) ListMedias(owner string, folderName string, request catalog.PageRequest) (*catalog.MediaPage, error) + type ARepositoryAdapter struct + func NewARepositoryAdapter(t mockConstructorTestingTNewARepositoryAdapter) *ARepositoryAdapter + func (_m *ARepositoryAdapter) AddLocation(owner string, id string, key string) error + func (_m *ARepositoryAdapter) FindById(owner string, id string) (string, error) + func (_m *ARepositoryAdapter) FindByIds(owner string, ids []string) (map[string]string, error) + func (_m *ARepositoryAdapter) FindIdsFromKeyPrefix(keyPrefix string) (map[string]string, error) + func (_m *ARepositoryAdapter) UpdateLocations(owner string, locations map[string]string) error + type AsyncJobAdapter struct + func NewAsyncJobAdapter(t mockConstructorTestingTNewAsyncJobAdapter) *AsyncJobAdapter + func (_m *AsyncJobAdapter) LoadImagesInCache(images ...*archive.ImageToResize) error + func (_m *AsyncJobAdapter) WarmUpCacheByFolder(owner string, missedStoreKey string, width int) error + type BArchiveAdapter struct + func NewBArchiveAdapter(t mockConstructorTestingTNewBArchiveAdapter) *BArchiveAdapter + func (_m *BArchiveAdapter) ArchiveMedia(owner string, media *backup.BackingUpMediaRequest) (string, error) + type BackupSuggestionPort struct + func NewBackupSuggestionPort(t mockConstructorTestingTNewBackupSuggestionPort) *BackupSuggestionPort + func (_m *BackupSuggestionPort) BackupSuggestion(record *ui.SuggestionRecord, existing *ui.ExistingRecord, ...) error + type CArchiveAdapter struct + func NewCArchiveAdapter(t mockConstructorTestingTNewCArchiveAdapter) *CArchiveAdapter + func (_m *CArchiveAdapter) MoveMedias(owner string, ids []string, name string) error + type CacheAdapter struct + func NewCacheAdapter(t mockConstructorTestingTNewCacheAdapter) *CacheAdapter + func (_m *CacheAdapter) Get(key string) (io.ReadCloser, int, string, error) + func (_m *CacheAdapter) Put(key string, mediaType string, content io.Reader) error + func (_m *CacheAdapter) SignedURL(key string, duration time.Duration) (string, error) + func (_m *CacheAdapter) WalkCacheByPrefix(prefix string, observer func(string)) error + type CatalogAdapter struct + func NewCatalogAdapter(t mockConstructorTestingTNewCatalogAdapter) *CatalogAdapter + func (_m *CatalogAdapter) AssignIdsToNewMedias(owner string, medias []*backup.AnalysedMedia) (map[*backup.AnalysedMedia]string, error) + func (_m *CatalogAdapter) GetAlbumsTimeline(owner string) (backup.TimelineAdapter, error) + func (_m *CatalogAdapter) IndexMedias(owner string, requests []*backup.CatalogMediaRequest) error + type CatalogRules struct + func NewCatalogRules(t mockConstructorTestingTNewCatalogRules) *CatalogRules + func (_m *CatalogRules) CanListMediasFromAlbum(owner string, folderName string) error + func (_m *CatalogRules) CanReadMedia(owner string, id string) error + func (_m *CatalogRules) Owner() (string, error) + func (_m *CatalogRules) SharedByUserGrid(owner string) (map[string][]string, error) + func (_m *CatalogRules) SharedWithUserAlbum() ([]catalog.AlbumId, error) + type CertificateAuthority struct + func NewCertificateAuthority(t mockConstructorTestingTNewCertificateAuthority) *CertificateAuthority + func (_m *CertificateAuthority) RequestCertificate(email string, domain string) (*dnsdomain.CompleteCertificate, error) + type CertificateManager struct + func NewCertificateManager(t mockConstructorTestingTNewCertificateManager) *CertificateManager + func (_m *CertificateManager) FindCertificate(domain string) (*dnsdomain.ExistingCertificate, error) + func (_m *CertificateManager) InstallCertificate(id string, certificate dnsdomain.CompleteCertificate) error + type ClosableFoundMedia struct + func NewClosableFoundMedia(t mockConstructorTestingTNewClosableFoundMedia) *ClosableFoundMedia + func (_m *ClosableFoundMedia) Close() error + type CompletionReport struct + func NewCompletionReport(t mockConstructorTestingTNewCompletionReport) *CompletionReport + func (_m *CompletionReport) CountPerAlbum() map[string]*backup.TypeCounter + func (_m *CompletionReport) NewAlbums() []string + func (_m *CompletionReport) Skipped() backup.MediaCounter + type Config struct + func NewConfig(t mockConstructorTestingTNewConfig) *Config + func (_m *Config) Get(key string) interface{} + func (_m *Config) GetAWSSession() *session.Session + func (_m *Config) GetBool(key string) bool + func (_m *Config) GetInt(key string) int + func (_m *Config) GetIntOrDefault(key string, defaultValue int) int + func (_m *Config) GetString(key string) string + func (_m *Config) GetStringOrDefault(key string, defaultValue string) string + type CreateAlbumPort struct + func NewCreateAlbumPort(t mockConstructorTestingTNewCreateAlbumPort) *CreateAlbumPort + func (_m *CreateAlbumPort) Create(createRequest ui.RecordCreation) error + type DeleteAlbumPort struct + func NewDeleteAlbumPort(t mockConstructorTestingTNewDeleteAlbumPort) *DeleteAlbumPort + func (_m *DeleteAlbumPort) DeleteAlbum(folderName string) error + type DetailsReaderAdapter struct + func NewDetailsReaderAdapter(t mockConstructorTestingTNewDetailsReaderAdapter) *DetailsReaderAdapter + func (_m *DetailsReaderAdapter) ReadDetails(reader io.Reader, options backup.DetailsReaderOptions) (*backup.MediaDetails, error) + func (_m *DetailsReaderAdapter) Supports(media backup.FoundMedia, mediaType backup.MediaType) bool + type DynamoBatchGetItem struct + func NewDynamoBatchGetItem(t mockConstructorTestingTNewDynamoBatchGetItem) *DynamoBatchGetItem + func (_m *DynamoBatchGetItem) BatchGetItem(_a0 *dynamodb.BatchGetItemInput) (*dynamodb.BatchGetItemOutput, error) + type DynamoBatchWriteItem struct + func NewDynamoBatchWriteItem(t mockConstructorTestingTNewDynamoBatchWriteItem) *DynamoBatchWriteItem + func (_m *DynamoBatchWriteItem) BatchWriteItem(_a0 *dynamodb.BatchWriteItemInput) (*dynamodb.BatchWriteItemOutput, error) + type DynamoQuery struct + func NewDynamoQuery(t mockConstructorTestingTNewDynamoQuery) *DynamoQuery + func (_m *DynamoQuery) Query(d *dynamodb.QueryInput) (*dynamodb.QueryOutput, error) + type ExistingRecordRepositoryPort struct + func NewExistingRecordRepositoryPort(t mockConstructorTestingTNewExistingRecordRepositoryPort) *ExistingRecordRepositoryPort + func (_m *ExistingRecordRepositoryPort) FindExistingRecords() ([]*ui.ExistingRecord, error) + type FoundMedia struct + func NewFoundMedia(t mockConstructorTestingTNewFoundMedia) *FoundMedia + func (_m *FoundMedia) MediaPath() backup.MediaPath + func (_m *FoundMedia) ReadMedia() (io.ReadCloser, error) + func (_m *FoundMedia) Size() int + func (_m *FoundMedia) String() string + type GetStreamAdapter struct + func NewGetStreamAdapter(t mockConstructorTestingTNewGetStreamAdapter) *GetStreamAdapter + func (_m *GetStreamAdapter) BatchGet(_a0 []map[string]*dynamodb.AttributeValue) (*dynamodb.BatchGetItemOutput, error) + type GrantRepository struct + func NewGrantRepository(t mockConstructorTestingTNewGrantRepository) *GrantRepository + func (_m *GrantRepository) DeleteScopes(id ...aclcore.ScopeId) error + func (_m *GrantRepository) FindScopesById(ids ...aclcore.ScopeId) ([]*aclcore.Scope, error) + func (_m *GrantRepository) ListOwnerScopes(owner string, types ...aclcore.ScopeType) ([]*aclcore.Scope, error) + func (_m *GrantRepository) ListUserScopes(email string, types ...aclcore.ScopeType) ([]*aclcore.Scope, error) + func (_m *GrantRepository) SaveIfNewScope(scope aclcore.Scope) error + type InteractiveActionsPort struct + func NewInteractiveActionsPort(t mockConstructorTestingTNewInteractiveActionsPort) *InteractiveActionsPort + func (_m *InteractiveActionsPort) BackupSuggestion(record *ui.SuggestionRecord, existing *ui.ExistingRecord, ...) error + func (_m *InteractiveActionsPort) Create(createRequest ui.RecordCreation) error + func (_m *InteractiveActionsPort) DeleteAlbum(folderName string) error + func (_m *InteractiveActionsPort) RenameAlbum(folderName string, newName string, renameFolder bool) error + func (_m *InteractiveActionsPort) UpdateAlbum(folderName string, start time.Time, end time.Time) error + type InteractiveRendererPort struct + func NewInteractiveRendererPort(t mockConstructorTestingTNewInteractiveRendererPort) *InteractiveRendererPort + func (_m *InteractiveRendererPort) Height() int + func (_m *InteractiveRendererPort) Print(question string) + func (_m *InteractiveRendererPort) ReadAnswer() (string, error) + func (_m *InteractiveRendererPort) Render(state *ui.InteractiveViewState) error + func (_m *InteractiveRendererPort) TakeOverScreen() + type Listener struct + func NewListener(t mockConstructorTestingTNewListener) *Listener + func (_m *Listener) Execute(_a0 config.Config) + type MediaAlbumResolver struct + func NewMediaAlbumResolver(t mockConstructorTestingTNewMediaAlbumResolver) *MediaAlbumResolver + func (_m *MediaAlbumResolver) FindAlbumOfMedia(owner string, mediaId string) (string, error) + type PostAnalyseFilter struct + func NewPostAnalyseFilter(t mockConstructorTestingTNewPostAnalyseFilter) *PostAnalyseFilter + func (_m *PostAnalyseFilter) AcceptAnalysedMedia(media *backup.AnalysedMedia, folderName string) bool + type PreScanTransformation struct + func NewPreScanTransformation(t mockConstructorTestingTNewPreScanTransformation) *PreScanTransformation + func (_m *PreScanTransformation) PreScan(run *migrator.TransformationRun) error + type PrintReadTerminalPort struct + func NewPrintReadTerminalPort(t mockConstructorTestingTNewPrintReadTerminalPort) *PrintReadTerminalPort + func (_m *PrintReadTerminalPort) Print(question string) + func (_m *PrintReadTerminalPort) ReadAnswer() (string, error) + type RenameAlbumPort struct + func NewRenameAlbumPort(t mockConstructorTestingTNewRenameAlbumPort) *RenameAlbumPort + func (_m *RenameAlbumPort) RenameAlbum(folderName string, newName string, renameFolder bool) error + type RepositoryAdapter struct + func NewRepositoryAdapter(t mockConstructorTestingTNewRepositoryAdapter) *RepositoryAdapter + func (_m *RepositoryAdapter) DeleteEmptyAlbum(owner string, folderName string) error + func (_m *RepositoryAdapter) FindAlbums(ids ...catalog.AlbumId) ([]*catalog.Album, error) + func (_m *RepositoryAdapter) FindAlbumsByOwner(owner string) ([]*catalog.Album, error) + func (_m *RepositoryAdapter) FindExistingSignatures(owner string, signatures []*catalog.MediaSignature) ([]*catalog.MediaSignature, error) + func (_m *RepositoryAdapter) FindMediaCurrentAlbum(owner string, mediaId string) (string, error) + func (_m *RepositoryAdapter) FindMediaIds(request *catalog.FindMediaRequest) ([]string, error) + func (_m *RepositoryAdapter) FindMedias(request *catalog.FindMediaRequest) ([]*catalog.MediaMeta, error) + func (_m *RepositoryAdapter) InsertAlbum(album catalog.Album) error + func (_m *RepositoryAdapter) InsertMedias(owner string, media []catalog.CreateMediaRequest) error + func (_m *RepositoryAdapter) TransferMedias(owner string, mediaIds []string, newFolderName string) error + func (_m *RepositoryAdapter) UpdateAlbum(album catalog.Album) error + type ResizerAdapter struct + func NewResizerAdapter(t mockConstructorTestingTNewResizerAdapter) *ResizerAdapter + func (_m *ResizerAdapter) ResizeImage(reader io.Reader, width int, fast bool) ([]byte, string, error) + func (_m *ResizerAdapter) ResizeImageAtDifferentWidths(reader io.Reader, width []int) (map[int][]byte, string, error) + type ReverseScopesReader struct + func NewReverseScopesReader(t mockConstructorTestingTNewReverseScopesReader) *ReverseScopesReader + func (_m *ReverseScopesReader) ListOwnerScopes(owner string, types ...aclcore.ScopeType) ([]*aclcore.Scope, error) + type SSOAuthenticator struct + func NewSSOAuthenticator(t mockConstructorTestingTNewSSOAuthenticator) *SSOAuthenticator + func (_m *SSOAuthenticator) AuthenticateFromExternalIDProvider(identityJWT string) (*aclcore.Authentication, *aclcore.Identity, error) + type ScanStreamExecutor struct + func NewScanStreamExecutor(t mockConstructorTestingTNewScanStreamExecutor) *ScanStreamExecutor + func (_m *ScanStreamExecutor) Scan(input *dynamodb.ScanInput) (*dynamodb.ScanOutput, error) + type ScanTransformation struct + func NewScanTransformation(t mockConstructorTestingTNewScanTransformation) *ScanTransformation + func (_m *ScanTransformation) GeneratePatches(run *migrator.TransformationRun, item map[string]*dynamodb.AttributeValue) ([]*dynamodb.WriteRequest, error) + type ScopeRepository struct + func NewScopeRepository(t mockConstructorTestingTNewScopeRepository) *ScopeRepository + func (_m *ScopeRepository) FindScopesById(ids ...aclcore.ScopeId) ([]*aclcore.Scope, error) + func (_m *ScopeRepository) ListOwnerScopes(owner string, types ...aclcore.ScopeType) ([]*aclcore.Scope, error) + func (_m *ScopeRepository) ListUserScopes(email string, types ...aclcore.ScopeType) ([]*aclcore.Scope, error) + type ScopeWriter struct + func NewScopeWriter(t mockConstructorTestingTNewScopeWriter) *ScopeWriter + func (_m *ScopeWriter) DeleteScopes(id ...aclcore.ScopeId) error + func (_m *ScopeWriter) SaveIfNewScope(scope aclcore.Scope) error + type ScopesReader struct + func NewScopesReader(t mockConstructorTestingTNewScopesReader) *ScopesReader + func (_m *ScopesReader) FindScopesById(ids ...aclcore.ScopeId) ([]*aclcore.Scope, error) + func (_m *ScopesReader) ListUserScopes(email string, types ...aclcore.ScopeType) ([]*aclcore.Scope, error) + type Segment struct + func NewSegment(t mockConstructorTestingTNewSegment) *Segment + func (_m *Segment) Content(options screen.RenderingOptions) string + type ShareAlbumCatalogPort struct + func NewShareAlbumCatalogPort(t mockConstructorTestingTNewShareAlbumCatalogPort) *ShareAlbumCatalogPort + func (_m *ShareAlbumCatalogPort) FindAlbum(owner string, folderName string) (*catalog.Album, error) + type SourceVolume struct + func NewSourceVolume(t mockConstructorTestingTNewSourceVolume) *SourceVolume + func (_m *SourceVolume) FindMedias() ([]backup.FoundMedia, error) + func (_m *SourceVolume) String() string + type StoreAdapter struct + func NewStoreAdapter(t mockConstructorTestingTNewStoreAdapter) *StoreAdapter + func (_m *StoreAdapter) Copy(origin string, destination archive.DestructuredKey) (string, error) + func (_m *StoreAdapter) Delete(locations []string) error + func (_m *StoreAdapter) Download(key string) (io.ReadCloser, error) + func (_m *StoreAdapter) SignedURL(key string, duration time.Duration) (string, error) + func (_m *StoreAdapter) Upload(values archive.DestructuredKey, content io.Reader) (string, error) + type StoreAndCache struct + func NewStoreAndCache(t mockConstructorTestingTNewStoreAndCache) *StoreAndCache + func (_m *StoreAndCache) Copy(origin string, destination archive.DestructuredKey) (string, error) + func (_m *StoreAndCache) Delete(locations []string) error + func (_m *StoreAndCache) Download(key string) (io.ReadCloser, error) + func (_m *StoreAndCache) Get(key string) (io.ReadCloser, int, string, error) + func (_m *StoreAndCache) Put(key string, mediaType string, content io.Reader) error + func (_m *StoreAndCache) SignedURL(key string, duration time.Duration) (string, error) + func (_m *StoreAndCache) Upload(values archive.DestructuredKey, content io.Reader) (string, error) + func (_m *StoreAndCache) WalkCacheByPrefix(prefix string, observer func(string)) error + type Stream struct + func NewStream(t mockConstructorTestingTNewStream) *Stream + func (_m *Stream) Count() int64 + func (_m *Stream) Error() error + func (_m *Stream) HasNext() bool + func (_m *Stream) Next() map[string]*dynamodb.AttributeValue + type SuggestionRecordRepositoryPort struct + func NewSuggestionRecordRepositoryPort(t mockConstructorTestingTNewSuggestionRecordRepositoryPort) *SuggestionRecordRepositoryPort + func (_m *SuggestionRecordRepositoryPort) Count() int + func (_m *SuggestionRecordRepositoryPort) FindSuggestionRecords() []*ui.SuggestionRecord + func (_m *SuggestionRecordRepositoryPort) Rejects() int + type TimelineAdapter struct + func NewTimelineAdapter(t mockConstructorTestingTNewTimelineAdapter) *TimelineAdapter + func (_m *TimelineAdapter) FindAlbum(dateTime time.Time) (string, bool, error) + func (_m *TimelineAdapter) FindOrCreateAlbum(mediaTime time.Time) (string, bool, error) + type TrackAnalysed struct + func NewTrackAnalysed(t mockConstructorTestingTNewTrackAnalysed) *TrackAnalysed + func (_m *TrackAnalysed) OnAnalysed(done backup.MediaCounter, total backup.MediaCounter) + type TrackEvents struct + func NewTrackEvents(t mockConstructorTestingTNewTrackEvents) *TrackEvents + func (_m *TrackEvents) OnEvent(event backup.ProgressEvent) + type TrackScanComplete struct + func NewTrackScanComplete(t mockConstructorTestingTNewTrackScanComplete) *TrackScanComplete + func (_m *TrackScanComplete) OnScanComplete(total backup.MediaCounter) + type TrackUploaded struct + func NewTrackUploaded(t mockConstructorTestingTNewTrackUploaded) *TrackUploaded + func (_m *TrackUploaded) OnUploaded(done backup.MediaCounter, total backup.MediaCounter) + type UpdateAlbumPort struct + func NewUpdateAlbumPort(t mockConstructorTestingTNewUpdateAlbumPort) *UpdateAlbumPort + func (_m *UpdateAlbumPort) UpdateAlbum(folderName string, start time.Time, end time.Time) error + type UserInputPort struct + func NewUserInputPort(t mockConstructorTestingTNewUserInputPort) *UserInputPort + func (_m *UserInputPort) StartListening()
Go to main page