persistence

Documentation

Index

• func ConnectToDatabase(ctx context.Context, databaseConnected chan struct{}, ...) error
• func CreateMongoDBClient(ctx context.Context, uri string) (*mongo.Client, error)
• type MongoDBConfig
• type MongoDBRepository
  • func NewMongoDBRepository(ctx context.Context, client *mongo.Client, databaseName string, ...) (*MongoDBRepository, error)
  • func (repository *MongoDBRepository) StoreFileMetadata(ctx context.Context, fileMetadata *file.FileMetadata) error

Functions

func ConnectToDatabase

func ConnectToDatabase(ctx context.Context, databaseConnected chan struct{}, databaseStopped chan struct{}, config MongoDBConfig) error

func CreateMongoDBClient

func CreateMongoDBClient(ctx context.Context, uri string) (*mongo.Client, error)

Types

type MongoDBConfig

type MongoDBConfig struct {
	HostUri                string
	DatabaseName           string
	FileMetadataCollection string
}

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) StoreFileMetadata

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