conn

package

v0.4.4 Latest Latest Go to latest Published: Nov 21, 2024 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewConnection(cfg config.Database) *Connection

func NewOpenedConnection(db *sqlx.DB) (*Connection, error)

func (c *Connection) Close() error

func (c *Connection) Connect(ctx context.Context) (*sqlx.DB, error)

func (c *Connection) Database() config.Database

func (c *Connection) ExtContext(ctx context.Context) (sqlx.ExtContext, error)

func (c *Connection) Transact(ctx context.Context, fn func(context.Context) error) error

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

func NewPool() *Pool

func (p *Pool) All() map[string]*Connection

func (p *Pool) Close() error

func (p *Pool) Get(name string) (*Connection, bool)

func (p *Pool) Setup(ds map[string]config.Database)

type Transactioner func(context.Context, func(ctx context.Context) error) error