async

Documentation

Index

• type Conn
  • func NewConnection(db awsds.AsyncDB) *Conn
  • func (c *Conn) Begin() (driver.Tx, error)
  • func (c *Conn) CheckNamedValue(v *driver.NamedValue) error
  • func (c *Conn) Close() error
  • func (c *Conn) Ping() error
  • func (c *Conn) PingContext(ctx context.Context) error
  • func (c *Conn) Prepare(query string) (driver.Stmt, error)
  • func (c *Conn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)
• type Driver
• type Loader

Types

type Conn

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

Implements "*sql.DB"

func NewConnection

func NewConnection(db awsds.AsyncDB) *Conn

func (*Conn) Begin

func (c *Conn) Begin() (driver.Tx, error)

func (*Conn) CheckNamedValue

func (c *Conn) CheckNamedValue(v *driver.NamedValue) error

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) Ping

func (c *Conn) Ping() error

func (*Conn) PingContext

func (c *Conn) PingContext(ctx context.Context) error

func (*Conn) Prepare

func (c *Conn) Prepare(query string) (driver.Stmt, error)

func (*Conn) QueryContext

func (c *Conn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

type Driver

type Driver interface {
	sqlDriver.Driver
	GetAsyncDB() (awsds.AsyncDB, error)
}

type Loader

type Loader func(api.AWSAPI) (Driver, error)