persistence

Documentation

Index

• Variables
• func ConnectToMongoDB(ctx context.Context, databaseConnected chan struct{}, ...) (file.FileMetadataRepository, error)
• func CreateMongoDBClient(ctx context.Context, config MongoDBConfig) (*mongo.Client, error)
• func EnsureDirectoryIsWritable(config PersistentVolumeConfig) error
• func EnsurePathExists(config PersistentVolumeConfig) error
• func PersistentVolumeListenToGracefulShutdown(storageDisconnected chan struct{})
• type GoogleCloudStorageFileRepository
  • func ConnectToGoogleCloudStorage(ctx context.Context, storageConnected chan struct{}, ...) (*GoogleCloudStorageFileRepository, error)
  • func (g *GoogleCloudStorageFileRepository) CreateFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.WriteCloser, error)
  • func (g *GoogleCloudStorageFileRepository) OpenFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.ReadCloser, error)
• type GoogleCloundStorageConfig
• type MongoDBConfig
• type MongoDBRepository
  • func NewMongoDBRepository(ctx context.Context, client *mongo.Client, databaseName string, ...) (*MongoDBRepository, error)
  • func (repository *MongoDBRepository) FetchFileMetadata(ctx context.Context, fileId uuid.UUID) (file.FileMetadata, error)
  • func (repository *MongoDBRepository) NoMatchError() error
  • func (repository *MongoDBRepository) NotFoundError() error
  • func (repository *MongoDBRepository) StoreFileMetadata(ctx context.Context, fileMetadata file.FileMetadata) error
  • func (repository *MongoDBRepository) StoreRevision(ctx context.Context, fileId uuid.UUID, revision file.Revision) error
• type PersistentVolumeConfig
• type PersistentVolumeFileRepository
  • func ConnectToPersistentVolume(ctx context.Context, storageConnected chan struct{}, ...) (*PersistentVolumeFileRepository, error)
  • func (g *PersistentVolumeFileRepository) CreateFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.WriteCloser, error)
  • func (g *PersistentVolumeFileRepository) OpenFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.ReadCloser, error)

Variables

var ErrNoMatch = errors.New("no matching documents")

Functions

func ConnectToMongoDB

func ConnectToMongoDB(ctx context.Context, databaseConnected chan struct{}, databaseDisconnected chan struct{}, config MongoDBConfig) (file.FileMetadataRepository, error)

func CreateMongoDBClient

func CreateMongoDBClient(ctx context.Context, config MongoDBConfig) (*mongo.Client, error)

func EnsureDirectoryIsWritable

func EnsureDirectoryIsWritable(config PersistentVolumeConfig) error

func EnsurePathExists

func EnsurePathExists(config PersistentVolumeConfig) error

func PersistentVolumeListenToGracefulShutdown

func PersistentVolumeListenToGracefulShutdown(storageDisconnected chan struct{})

Types

type GoogleCloudStorageFileRepository

type GoogleCloudStorageFileRepository struct {
	Client *storage.Client
}

func ConnectToGoogleCloudStorage

func ConnectToGoogleCloudStorage(ctx context.Context, storageConnected chan struct{}, storageDisconnected chan struct{}, config GoogleCloundStorageConfig) (*GoogleCloudStorageFileRepository, error)

func (*GoogleCloudStorageFileRepository) CreateFile

func (g *GoogleCloudStorageFileRepository) CreateFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.WriteCloser, error)

func (*GoogleCloudStorageFileRepository) OpenFile

func (g *GoogleCloudStorageFileRepository) OpenFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.ReadCloser, error)

type GoogleCloundStorageConfig

type GoogleCloundStorageConfig struct {
}

type MongoDBConfig

type MongoDBConfig struct {
	HostUri                string
	DatabaseName           string
	FileMetadataCollection string
	Timeout                time.Duration
}

type MongoDBRepository

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

func NewMongoDBRepository

func NewMongoDBRepository(ctx context.Context, client *mongo.Client, databaseName string, collectionName string) (*MongoDBRepository, error)

func (*MongoDBRepository) FetchFileMetadata

func (repository *MongoDBRepository) FetchFileMetadata(ctx context.Context, fileId uuid.UUID) (file.FileMetadata, error)

func (*MongoDBRepository) NoMatchError

func (repository *MongoDBRepository) NoMatchError() error

func (*MongoDBRepository) NotFoundError

func (repository *MongoDBRepository) NotFoundError() error

func (*MongoDBRepository) StoreFileMetadata

func (repository *MongoDBRepository) StoreFileMetadata(ctx context.Context, fileMetadata file.FileMetadata) error

func (*MongoDBRepository) StoreRevision

func (repository *MongoDBRepository) StoreRevision(ctx context.Context, fileId uuid.UUID, revision file.Revision) error

type PersistentVolumeConfig

type PersistentVolumeConfig struct {
	Path string
}

type PersistentVolumeFileRepository

type PersistentVolumeFileRepository struct {
	StoragePath string
}

func ConnectToPersistentVolume

func ConnectToPersistentVolume(ctx context.Context, storageConnected chan struct{}, storageDisconnected chan struct{}, config PersistentVolumeConfig) (*PersistentVolumeFileRepository, error)

func (*PersistentVolumeFileRepository) CreateFile

func (g *PersistentVolumeFileRepository) CreateFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.WriteCloser, error)

func (*PersistentVolumeFileRepository) OpenFile

func (g *PersistentVolumeFileRepository) OpenFile(ctx context.Context, fileId uuid.UUID, revisionId uuid.UUID) (io.ReadCloser, error)