xraysql

Aug 16, 2019

Changes in this version

+ type ConnInfo struct

+ DbName string

+ DbType string

+ DbUser string

+ DbVersion string

+ DriverName string

+ SanitizedConnString string

+ type ConnectionProvider interface

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

+ type FakeDriver struct

+ func (w *FakeDriver) Open(dsn string) (driver.Conn, error)

+ type InstrumentedConn struct

+ func (ic *InstrumentedConn) Begin() (driver.Tx, error)

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

+ func (ic *InstrumentedConn) Close() error

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

+ func (ic *InstrumentedConn) Ping(ctx context.Context) error

+ func (ic *InstrumentedConn) Prepare(query string) (driver.Stmt, error)

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

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

+ type InstrumentedStmt struct

+ func (is *InstrumentedStmt) Close() error

+ func (is *InstrumentedStmt) Exec(args []driver.Value) (driver.Result, error)

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

+ func (is *InstrumentedStmt) NumInput() int

+ func (is *InstrumentedStmt) Query(args []driver.Value) (driver.Rows, error)

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

+ type PgConnectorWithRds struct

+ func MakePgConnector(ctx context.Context, connStr string, sslCaPath string, config aws.Config) (*PgConnectorWithRds, error)

+ func (pc *PgConnectorWithRds) Connect(ctx context.Context) (driver.Conn, *ConnInfo, error)

+ type SqliteConnector struct

+ func NewSqliteConnector(connString string) *SqliteConnector

+ func (s *SqliteConnector) Connect(ctx context.Context) (driver.Conn, *ConnInfo, error)

+ type XrayConnector struct

+ ConnProvider ConnectionProvider

+ func NewXrayConnector(connProvider ConnectionProvider) *XrayConnector

+ func (ic *XrayConnector) Connect(ctx context.Context) (driver.Conn, error)

+ func (ic *XrayConnector) Driver() driver.Driver