driver

Jun 1, 2020

retracted

Changes in this version

type Option

+ func WithTracing(level client.LogLevel) Option

Mar 24, 2020

retracted

Changes in this version

+ type Connector struct

+ func (c *Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (c *Connector) Driver() driver.Driver

type Driver

+ func (d *Driver) OpenConnector(name string) (driver.Connector, error)

type Option

+ func WithAttemptTimeout(timeout time.Duration) Option

+ func WithRetryLimit(limit uint) Option

Nov 4, 2019

retracted

Changes in this version

+ const ErrBusy

Aug 29, 2019

retracted

Changes in this version

+ var DefaultNodeStore = client.DefaultNodeStore

+ var ErrNoAvailableLeader = protocol.ErrNoAvailableLeader

+ type Conn struct

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

+ func (c *Conn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (c *Conn) Close() error

+ func (c *Conn) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (c *Conn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

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

+ func (c *Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *Conn) Query(query string, args []driver.Value) (driver.Rows, error)

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

+ type DialFunc = protocol.DialFunc

+ type Driver struct

+ func New(store client.NodeStore, options ...Option) (*Driver, error)

+ func (d *Driver) Open(uri string) (driver.Conn, error)

+ func (d *Driver) SetContextTimeout(timeout time.Duration)

+ type Error = bindings.Error

+ type NodeInfo = client.NodeInfo

+ type NodeStore = client.NodeStore

+ type Option func(*options)

+ func WithConnectionBackoffCap(cap time.Duration) Option

+ func WithConnectionBackoffFactor(factor time.Duration) Option

+ func WithConnectionTimeout(timeout time.Duration) Option

+ func WithContext(context context.Context) Option

+ func WithContextTimeout(timeout time.Duration) Option

+ func WithDialFunc(dial DialFunc) Option

+ func WithLogFunc(log client.LogFunc) Option

+ type Result struct

+ func (r *Result) LastInsertId() (int64, error)

+ func (r *Result) RowsAffected() (int64, error)

+ type Rows struct

+ func (r *Rows) Close() error

+ func (r *Rows) ColumnTypeDatabaseTypeName(i int) string

+ func (r *Rows) ColumnTypeScanType(i int) reflect.Type

+ func (r *Rows) Columns() []string

+ func (r *Rows) Next(dest []driver.Value) error

+ type Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *Stmt) NumInput() int

+ func (s *Stmt) Query(args []driver.Value) (driver.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Rollback() error