pkgfactory

package
v1.6.27 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2024 License: AGPL-3.0 Imports: 23 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AWSFactory 

func AWSFactory(ctx context.Context) awsfactory.AWSFactory

func AclCatalogAuthoriser added in v1.6.4 

func AclCatalogAuthoriser(ctx context.Context) *catalogacl.CatalogAuthorizer

func AclCatalogShare added in v1.6.4 

func AclCatalogShare(ctx context.Context) *catalogacl.ShareAlbumCase

func AclCatalogUnShare added in v1.6.4 

func AclCatalogUnShare(ctx context.Context) *catalogacl.UnShareAlbumCase

func AclQueries added in v1.5.49 

func AclQueries(ctx context.Context) *aclcore.ScopeQueries

func AclRepository added in v1.5.49 

func AclRepository(ctx context.Context) *aclscopedynamodb.Repository

func AlbumQueries added in v1.6.4 

func AlbumQueries(ctx context.Context) *catalog.AlbumQueries

func AlbumView added in v1.5.49 

func AlbumView(ctx context.Context) *catalogviews.AlbumView

func AlbumViewRepository added in v1.6.4 

func AlbumViewRepository(ctx context.Context) *catalogviewsdynamodb.AlbumViewRepository

func AmendAlbumDatesCase added in v1.5.45 

func AmendAlbumDatesCase(ctx context.Context) *catalog.AmendAlbumDates

func ArchiveTimelineMutationObserver 

func ArchiveTimelineMutationObserver(ctx context.Context) *catalogarchivesync.Observer

func CatalogMediaQueries added in v1.6.4 

func CatalogMediaQueries(ctx context.Context) *catalog.MediaQueries

func CatalogRepository 

func CatalogRepository(ctx context.Context) *catalogdynamo.Repository

func CatalogToACLAdapter added in v1.6.4 

func CatalogToACLAdapter(ctx context.Context) *catalogacl.ReverseReader

func CommandHandlerAlbumSize added in v1.6.4 

func CommandHandlerAlbumSize(ctx context.Context) *catalogviews.CommandHandlerAlbumSize

func CreateAlbumCase 

func CreateAlbumCase(ctx context.Context) *catalog.CreateAlbum

func CreateAlbumDeleteCase added in v1.5.41 

func CreateAlbumDeleteCase(ctx context.Context) *catalog.DeleteAlbum

func InsertMediasCase added in v1.5.47 

func InsertMediasCase(ctx context.Context) *catalog.InsertMedias

func NewInsertMediaAdapter added in v1.5.57 

func NewInsertMediaAdapter(ctx context.Context) backup.InsertMediaPort

func NewReferencerFactory added in v1.5.54 

func NewReferencerFactory() backup.ReferencerFactory

func OwnerDriftReconciler added in v1.6.7 

func OwnerDriftReconciler(ctx context.Context, dry bool, options ...catalogviews.DriftOption) *catalogviews.OwnerDriftReconciler

func RenameAlbumCase added in v1.5.43 

func RenameAlbumCase(ctx context.Context) *catalog.RenameAlbum

Types

type AWSAdapterNames 

type AWSAdapterNames interface {
	DynamoDBName() string
	ArchiveMainBucketName() string
	ArchiveCacheBucketName() string
	ArchiveJobsSNSARN() string
	ArchiveJobsSQSURL() string
}
var (
	OverriddenAWSFactory awsfactory.AWSFactory // AWSConfigFactory will be defaulted with awsfactory.ContextualAWSFactory() if not set
	AWSNames             AWSAdapterNames       // Names provides the config required by the adapters

)

type AWSCloud added in v1.6.13 

type AWSCloud struct {
	awsfactory.AWSFactory
	ArchiveFactory
	Names AWSAdapterNames
}

func (*AWSCloud) InitArchive added in v1.6.18 

func (a *AWSCloud) InitArchive(ctx context.Context)

type AWSCloudBuilder added in v1.6.13 

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

func StartAWSCloudBuilder added in v1.6.13 

func StartAWSCloudBuilder(names AWSAdapterNames) *AWSCloudBuilder

StartAWSCloudBuilder creates a version of the application directly connected to AWS cloud using DynamoDB and S3.

func (*AWSCloudBuilder) Build added in v1.6.13 

func (a *AWSCloudBuilder) Build(ctx context.Context) (*AWSCloud, error)

Build creates the application factory ; and set legacy global variables

func (*AWSCloudBuilder) OverridesAWSFactory added in v1.6.13 

func (a *AWSCloudBuilder) OverridesAWSFactory(factory awsfactory.AWSFactory, err error) *AWSCloudBuilder

OverridesAWSFactory allows to use an alternative AWS configuration where credentials are not contextual (unlike lambdas)

func (*AWSCloudBuilder) WithAdvancedAWSAsyncFeatures added in v1.6.13 

func (a *AWSCloudBuilder) WithAdvancedAWSAsyncFeatures() *AWSCloudBuilder

WithAdvancedAWSAsyncFeatures enable the use of SNS/SQS to process asynchronously the archive jobs. (required lambdas to be listening the messages)

type ArchiveFactory added in v1.6.13 

type ArchiveFactory interface {
	ArchiveAsyncJobAdapter(ctx context.Context) archive.AsyncJobAdapter
}

type AsyncArchiveFactory added in v1.6.13 

type AsyncArchiveFactory struct{}

func (*AsyncArchiveFactory) ArchiveAsyncJobAdapter added in v1.6.13 

func (a *AsyncArchiveFactory) ArchiveAsyncJobAdapter(ctx context.Context) archive.AsyncJobAdapter

type BackupReferencerFactory added in v1.6.13 

type BackupReferencerFactory struct{}

func (*BackupReferencerFactory) NewCreatorReferencer added in v1.6.13 

func (f *BackupReferencerFactory) NewCreatorReferencer(ctx context.Context, owner ownermodel.Owner) (backup.CatalogReferencer, error)

func (*BackupReferencerFactory) NewDryRunReferencer added in v1.6.13 

func (f *BackupReferencerFactory) NewDryRunReferencer(ctx context.Context, owner ownermodel.Owner) (backup.CatalogReferencer, error)

type Factory added in v1.5.54 

type Factory interface {
	ArchiveFactory

	// InitArchive shouldn't be used directly but is exposed to support legacy implementation
	InitArchive(ctx context.Context)
}

Factory is the builder of the application ; any direct variables are deprecated in favour of moving to the appropriate factory implementation.

type MultiFilesBackup added in v1.6.13 

type MultiFilesBackup func(ctx context.Context, owner ownermodel.Owner, volumeSource backup.SourceVolume, optionsSlice ...backup.Options) (backup.CompletionReport, error)

func NewMultiFilesBackup added in v1.6.13 

func NewMultiFilesBackup(ctx context.Context) MultiFilesBackup

type MultiFilesScanner added in v1.6.13 

type MultiFilesScanner func(ctx context.Context, owner string, volume backup.SourceVolume, optionSlice ...backup.Options) ([]*backup.ScannedFolder, []backup.FoundMedia, error)

func NewMultiFilesScanner added in v1.6.13 

func NewMultiFilesScanner(ctx context.Context) MultiFilesScanner

type StaticAWSAdapterNames added in v1.6.13 

type StaticAWSAdapterNames struct {
	DynamoDBNameValue           string
	ArchiveMainBucketNameValue  string
	ArchiveCacheBucketNameValue string
	ArchiveJobsSNSARNValue      string
	ArchiveJobsSQSURLValue      string
}

func (StaticAWSAdapterNames) ArchiveCacheBucketName added in v1.6.13 

func (s StaticAWSAdapterNames) ArchiveCacheBucketName() string

func (StaticAWSAdapterNames) ArchiveJobsSNSARN added in v1.6.13 

func (s StaticAWSAdapterNames) ArchiveJobsSNSARN() string

func (StaticAWSAdapterNames) ArchiveJobsSQSURL added in v1.6.13 

func (s StaticAWSAdapterNames) ArchiveJobsSQSURL() string

func (StaticAWSAdapterNames) ArchiveMainBucketName added in v1.6.13 

func (s StaticAWSAdapterNames) ArchiveMainBucketName() string

func (StaticAWSAdapterNames) DynamoDBName added in v1.6.13 

func (s StaticAWSAdapterNames) DynamoDBName() string

type SyncArchiveFactory added in v1.6.13 

type SyncArchiveFactory struct{}

func (*SyncArchiveFactory) ArchiveAsyncJobAdapter added in v1.6.13 

func (a *SyncArchiveFactory) ArchiveAsyncJobAdapter(ctx context.Context) archive.AsyncJobAdapter

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.