mg

Documentation

Index

• Constants
• func NewPgController(dbConfig Config, entityDefinitions, baseEntities []database.DocumentBase) database.DatabaseController
• func NewTransactionFactory(db *MongoDatabase) database.MongoTransactionFactory
• type Config
  • func (config *Config) DSN() string
  • func (config *Config) GetTableSchema() string
  • func (config *Config) RawDSN() string
• type MongoController
  • func (d *MongoController) Generate() error
  • func (d *MongoController) GetTransactionFactory() (database.MongoTransactionFactory, error)
  • func (d *MongoController) Init() error
• type MongoDatabase
  • func NewMoDatabase(DBConfig Config) *MongoDatabase
  • func (md *MongoDatabase) GetMongo() *mongo.Database
  • func (md *MongoDatabase) Open() error
  • func (md *MongoDatabase) OpenRaw() error
• type Transaction
  • func (m *Transaction) Begin(_ context.Context) error
  • func (m *Transaction) Commit(ctx context.Context) error
  • func (m *Transaction) GetDataContext() any
  • func (m *Transaction) Rollback(ctx context.Context) error
  • func (m *Transaction) RollbackUnlessCommitted(ctx context.Context)
• type TransactionFactory
  • func (t TransactionFactory) New() database.Transaction

Constants

const Public = "public"

Functions

func NewPgController

func NewPgController(dbConfig Config, entityDefinitions, baseEntities []database.DocumentBase) database.DatabaseController

func NewTransactionFactory

func NewTransactionFactory(db *MongoDatabase) database.MongoTransactionFactory

Types

type Config

type Config struct {
	Host                   string
	Port                   int
	Username               string
	Password               string
	Name                   string
	Driver                 string
	Schema                 string
	IgnorePermissionDenied bool
	Timeout                int
	SSL                    string
	Clustered              bool
}

func (*Config) DSN

func (config *Config) DSN() string

func (*Config) GetTableSchema

func (config *Config) GetTableSchema() string

func (*Config) RawDSN

func (config *Config) RawDSN() string

type MongoController

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

func (*MongoController) Generate

func (d *MongoController) Generate() error

func (*MongoController) GetTransactionFactory

func (d *MongoController) GetTransactionFactory() (database.MongoTransactionFactory, error)

func (*MongoController) Init

func (d *MongoController) Init() error

type MongoDatabase

type MongoDatabase struct {
	Database *mongo.Database
	Client   *mongo.Client
	DBConfig Config
}

func NewMoDatabase

func NewMoDatabase(DBConfig Config) *MongoDatabase

func (*MongoDatabase) GetMongo

func (md *MongoDatabase) GetMongo() *mongo.Database

func (*MongoDatabase) Open

func (md *MongoDatabase) Open() error

func (*MongoDatabase) OpenRaw

func (md *MongoDatabase) OpenRaw() error

type Transaction

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

func (*Transaction) Begin

func (m *Transaction) Begin(_ context.Context) error

func (*Transaction) Commit

func (m *Transaction) Commit(ctx context.Context) error

func (*Transaction) GetDataContext

func (m *Transaction) GetDataContext() any

func (*Transaction) Rollback

func (m *Transaction) Rollback(ctx context.Context) error

func (*Transaction) RollbackUnlessCommitted

func (m *Transaction) RollbackUnlessCommitted(ctx context.Context)

type TransactionFactory

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

func (TransactionFactory) New

func (t TransactionFactory) New() database.Transaction