datastore

May 3, 2022

Changes in this version

+ const DBHostEnv

+ const DBNameEnv

+ const DBPasswordEnv

+ const DBPortEnv

+ const DBSearchPathEnv

+ const DBUserEnv

Feb 22, 2022

Changes in this version

+ func NewNullInt32(i int32) sql.NullInt32

+ func NewNullTime(t time.Time) sql.NullTime

Dec 31, 2021

Changes in this version

+ func NewNullUUID(id uuid.UUID) uuid.NullUUID

+ func ValidatePostgreSQLPool(ctx context.Context, pool *pgxpool.Pool, log zerolog.Logger) error

type PostgreSQLDSN

+ SearchPath string

+ func (dsn PostgreSQLDSN) ConnectionURI() string

+ func (dsn PostgreSQLDSN) KeywordValueConnectionString() string

Sep 24, 2021

Changes in this version

+ func NewPostgreSQLPool(ctx context.Context, dsn PostgreSQLDSN, logger zerolog.Logger) (*pgxpool.Pool, func(), error)

type Datastore

+ func (ds Datastore) Pool() *pgxpool.Pool

Aug 5, 2021

Changes in this version

+ func NewPostgreSQLDB(dsn PostgreSQLDSN, logger zerolog.Logger) (*sql.DB, func(), error)

+ type PostgreSQLDSN struct

+ DBName string

+ Host string

+ Password string

+ Port int

+ User string

+ func NewPostgreSQLDSN(host, dbname, user, password string, port int) PostgreSQLDSN

+ func (dsn PostgreSQLDSN) String() string

Jan 29, 2021

Changes in this version

+ type DefaultDatastore struct

+ func NewDefaultDatastore(db *sql.DB) DefaultDatastore

+ func (ds DefaultDatastore) BeginTx(ctx context.Context) (*sql.Tx, error)

+ func (ds DefaultDatastore) CommitTx(tx *sql.Tx) error

+ func (ds DefaultDatastore) DB() *sql.DB

+ func (ds DefaultDatastore) RollbackTx(tx *sql.Tx, err error) error

Jan 10, 2021

Changes in this version

+ type PGDatasourceName struct

+ DBName string

+ Host string

+ Password string

+ Port int

+ User string

+ func NewPGDatasourceName(host, dbname, user, password string, port int) PGDatasourceName

+ func (dsn PGDatasourceName) String() string

Aug 17, 2020

Changes in this version

+ func NewNullInt64(i int64) sql.NullInt64

+ func NewNullString(s string) sql.NullString

Feb 25, 2020

Changes in this version

type Datastorer

+ DB func() *sql.DB

type MockDatastore

+ func (mds *MockDatastore) DB() *sql.DB

Jan 26, 2020

Changes in this version

+ func NewMockDatastore(n Name) *sql.DB

type Datastore

+ DB *sql.DB

+ type Datastorer interface

+ BeginTx func(context.Context) error

+ CommitTx func() error

+ RollbackTx func(error) error

+ func NewDatastorer(n Name, db *sql.DB) (Datastorer, error)

type MockDatastore

+ func (db *MockDatastore) BeginTx(ctx context.Context) error

+ func (db *MockDatastore) CommitTx() error

+ func (db *MockDatastore) RollbackTx(err error) error

+ func (db *MockDatastore) Tx() (*sql.Tx, error)

+ type Name int

+ const MockedDatastore

+ func (n Name) String() string

Jan 24, 2020

Changes in this version

+ func NewDB(n DSName) (*sql.DB, func(), error)

type DSName

+ const GCPDatastore

Dec 29, 2019

Changes in this version

+ func NewLocalDB(n DSName) (*sql.DB, func(), error)

+ func NewMockDB(n DSName) *sql.DB

+ func OpenGCPDatabase(ctx context.Context, opener *gcppostgres.URLOpener, id gcp.ProjectID, n DSName) (*sql.DB, func(), error)

type DSName

+ const GCPCPDatastore

+ const LocalDatastore

+ func (n DSName) String() string

type Datastore

+ func NewDatastore(n DSName, db *sql.DB) (Datastore, error)

Nov 13, 2019

Changes in this version

+ type DS struct

+ DB *sql.DB

+ func (db *DS) BeginTx(ctx context.Context) error

+ func (db *DS) CommitTx() error

+ func (db *DS) RollbackTx(err error) error

+ func (db *DS) Tx() (*sql.Tx, error)

+ type DSName int

+ const AppDatastore

+ const LogDatastore

+ const MockDatastore

+ type Datastore interface

+ BeginTx func(context.Context) error

+ CommitTx func() error

+ RollbackTx func(error) error

+ Tx func() (*sql.Tx, error)

+ func ProvideDatastore(n DSName) (Datastore, error)

+ type MockDS struct

+ func (db *MockDS) BeginTx(ctx context.Context) error

+ func (db *MockDS) CommitTx() error

+ func (db *MockDS) RollbackTx(err error) error

+ func (db *MockDS) Tx() (*sql.Tx, error)