persistence

Documentation

Index

• func ConnectToMongoDB(ctx context.Context, databaseConnected chan struct{}, ...) (file.FileMetadataRepository, 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 ConnectToMongoDB

func ConnectToMongoDB(ctx context.Context, databaseConnected chan struct{}, databaseDisconnected chan struct{}, config MongoDBConfig) (file.FileMetadataRepository, 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