database

package

v0.0.0-...-224a6a0 Latest Latest Go to latest Published: Jan 8, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/neoxelox/odin

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Database
- func New(ctx context.Context, retries int, configuration internal.Configuration, ...) (*Database, error)
type PgxLogger
- func NewPgxLogger(logger core.Logger) *PgxLogger
- func (self PgxLogger) Log(ctx context.Context, level pgx.LogLevel, msg string, ...)
type Scan

Constants ¶

View Source

const (
	POSTGRES_DSN                                = "postgresql://%s:%s@%s:%d/%s?sslmode=%s"
	CONTEXT_TRANSACTION_KEY internal.ContextKey = "database:tx"
)

View Source

const PGERRCODE_PATTERN = `\(SQLSTATE (.*)\)`

Variables ¶

View Source

var (
	ErrGeneric     = internal.NewError("Database failed")
	ErrBelowMin    = internal.NewError("Database pool size below minimum")
	ErrTransaction = internal.NewError("Database transaction failed")
)

View Source

var (
	ErrNoRows             = internal.NewError("No rows in result set")
	ErrIntegrityViolation = internal.NewError("Integrity constraint violation")
)

Functions ¶

This section is empty.

Types ¶

type Database ¶

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

func New ¶

func New(ctx context.Context, retries int, configuration internal.Configuration, logger core.Logger) (*Database, error)

func (*Database) Close ¶

func (self *Database) Close(ctx context.Context) error

func (*Database) Exec ¶

func (self *Database) Exec(ctx context.Context, sql string, args ...interface{}) (int, error)

func (*Database) Health ¶

func (self *Database) Health(ctx context.Context) error

func (*Database) Query ¶

func (self *Database) Query(ctx context.Context, sql string, args ...interface{}) Scan

func (*Database) Transaction ¶

func (self *Database) Transaction(ctx context.Context, fn func(ctx context.Context) error) error

type PgxLogger ¶

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

func NewPgxLogger ¶

func NewPgxLogger(logger core.Logger) *PgxLogger

func (PgxLogger) Log ¶

func (self PgxLogger) Log(ctx context.Context, level pgx.LogLevel, msg string, data map[string]interface{})

type Scan ¶

type Scan struct {
	Scan func(dest ...interface{}) error
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL