proxy

package module

Go to main page

Versions in this module

v0

v0.7.2

Nov 14, 2023

v0.7.1

Aug 3, 2023

v0.7.0

Jul 22, 2023

v0.6.1

Oct 16, 2021

v0.6.0

Aug 17, 2021

Changes in this version

type Connector

+ func (c *Connector) Close() error

v0.5.0

Jan 11, 2021

Changes in this version

type HooksContext

+ PostPrepare func(c context.Context, ctx interface{}, stmt *Stmt, err error) error

+ PrePrepare func(c context.Context, stmt *Stmt) (interface{}, error)

+ Prepare func(c context.Context, ctx interface{}, stmt *Stmt) error

v0.4.0

Jan 8, 2021

v0.3.0

Aug 12, 2020

Changes in this version

type Conn

+ func (conn *Conn) IsValid() bool

type HooksContext

+ IsValid func(ctx interface{}, conn *Conn) error

+ PostIsValid func(ctx interface{}, conn *Conn, valid bool) error

+ PreIsValid func(conn *Conn) (interface{}, error)

v0.2.0

Jan 15, 2020

Changes in this version

type Conn

+ func (conn *Conn) CheckNamedValue(nv *driver.NamedValue) (err error)

type Stmt

+ func (stmt *Stmt) CheckNamedValue(nv *driver.NamedValue) (err error)

v0.1.2

Jan 4, 2020

v0.1.1

Dec 31, 2018

v0.1.0

Mar 5, 2018

Changes in this version

+ var DefaultPackageFilter = PackageFilter

+ func NewConnector(c driver.Connector, hs ...*HooksContext) driver.Connector

+ func RegisterProxy()

+ func RegisterTracer()

+ func WithHooks(ctx context.Context, hs ...*HooksContext) context.Context

+ type Conn struct

+ Conn driver.Conn

+ Proxy *Proxy

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

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

+ func (conn *Conn) Close() error

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

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

+ func (conn *Conn) Ping(c context.Context) error

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

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

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

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

+ func (conn *Conn) ResetSession(ctx context.Context) error

+ type Connector struct

+ Connector driver.Connector

+ Name string

+ Proxy *Proxy

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

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

+ type Filter interface

+ DoOutput func(packageName string) bool

+ type Hooks struct

+ Begin func(ctx interface{}, conn *Conn) error

+ Close func(ctx interface{}, conn *Conn) error

+ Commit func(ctx interface{}, tx *Tx) error

+ Exec func(ctx interface{}, stmt *Stmt, args []driver.Value, result driver.Result) error

+ Open func(ctx interface{}, conn *Conn) error

+ Ping func(ctx interface{}, conn *Conn) error

+ PostBegin func(ctx interface{}, conn *Conn) error

+ PostClose func(ctx interface{}, conn *Conn, err error) error

+ PostCommit func(ctx interface{}, tx *Tx) error

+ PostExec func(ctx interface{}, stmt *Stmt, args []driver.Value, result driver.Result) error

+ PostOpen func(ctx interface{}, conn *Conn) error

+ PostPing func(ctx interface{}, conn *Conn, err error) error

+ PostQuery func(ctx interface{}, stmt *Stmt, args []driver.Value, rows driver.Rows) error

+ PostResetSession func(ctx interface{}, conn *Conn, err error) error

+ PostRollback func(ctx interface{}, tx *Tx) error

+ PreBegin func(conn *Conn) (interface{}, error)

+ PreClose func(conn *Conn) (interface{}, error)

+ PreCommit func(tx *Tx) (interface{}, error)

+ PreExec func(stmt *Stmt, args []driver.Value) (interface{}, error)

+ PreOpen func(name string) (interface{}, error)

+ PrePing func(conn *Conn) (interface{}, error)

+ PreQuery func(stmt *Stmt, args []driver.Value) (interface{}, error)

+ PreResetSession func(conn *Conn) (interface{}, error)

+ PreRollback func(tx *Tx) (interface{}, error)

+ Query func(ctx interface{}, stmt *Stmt, args []driver.Value, rows driver.Rows) error

+ ResetSession func(ctx interface{}, conn *Conn) error

+ Rollback func(ctx interface{}, tx *Tx) error

+ type HooksContext struct

+ Begin func(c context.Context, ctx interface{}, conn *Conn) error

+ Close func(c context.Context, ctx interface{}, conn *Conn) error

+ Commit func(c context.Context, ctx interface{}, tx *Tx) error

+ Exec func(c context.Context, ctx interface{}, stmt *Stmt, args []driver.NamedValue, ...) error

+ Open func(c context.Context, ctx interface{}, conn *Conn) error

+ Ping func(c context.Context, ctx interface{}, conn *Conn) error

+ PostBegin func(c context.Context, ctx interface{}, conn *Conn, err error) error

+ PostClose func(c context.Context, ctx interface{}, conn *Conn, err error) error

+ PostCommit func(c context.Context, ctx interface{}, tx *Tx, err error) error

+ PostExec func(c context.Context, ctx interface{}, stmt *Stmt, args []driver.NamedValue, ...) error

+ PostOpen func(c context.Context, ctx interface{}, conn *Conn, err error) error

+ PostPing func(c context.Context, ctx interface{}, conn *Conn, err error) error

+ PostQuery func(c context.Context, ctx interface{}, stmt *Stmt, args []driver.NamedValue, ...) error

+ PostResetSession func(c context.Context, ctx interface{}, conn *Conn, err error) error

+ PostRollback func(c context.Context, ctx interface{}, tx *Tx, err error) error

+ PreBegin func(c context.Context, conn *Conn) (interface{}, error)

+ PreClose func(c context.Context, conn *Conn) (interface{}, error)

+ PreCommit func(c context.Context, tx *Tx) (interface{}, error)

+ PreExec func(c context.Context, stmt *Stmt, args []driver.NamedValue) (interface{}, error)

+ PreOpen func(c context.Context, name string) (interface{}, error)

+ PrePing func(c context.Context, conn *Conn) (interface{}, error)

+ PreQuery func(c context.Context, stmt *Stmt, args []driver.NamedValue) (interface{}, error)

+ PreResetSession func(c context.Context, conn *Conn) (interface{}, error)

+ PreRollback func(c context.Context, tx *Tx) (interface{}, error)

+ Query func(c context.Context, ctx interface{}, stmt *Stmt, args []driver.NamedValue, ...) error

+ ResetSession func(c context.Context, ctx interface{}, conn *Conn) error

+ Rollback func(c context.Context, ctx interface{}, tx *Tx) error

+ func NewTraceHooks(opt TracerOptions) *HooksContext

+ type Outputter interface

+ Output func(calldepth int, s string) error

+ type PackageFilter map[string]struct

+ func (f PackageFilter) DoOutput(packageName string) bool

+ func (f PackageFilter) Ignore(packageName string)

+ type Proxy struct

+ Driver driver.Driver

+ func NewProxy(driver driver.Driver, hs ...*Hooks) *Proxy

+ func NewProxyContext(driver driver.Driver, hs ...*HooksContext) *Proxy

+ func NewTraceProxy(d driver.Driver, o Outputter) *Proxy

+ func NewTraceProxyWithFilter(d driver.Driver, o Outputter, f Filter) *Proxy

+ func (p *Proxy) Open(name string) (driver.Conn, error)

+ func (p *Proxy) OpenConnector(name string) (driver.Connector, error)

+ type Stmt struct

+ Conn *Conn

+ Proxy *Proxy

+ QueryString string

+ Stmt driver.Stmt

+ func (stmt *Stmt) Close() error

+ func (stmt *Stmt) ColumnConverter(idx int) driver.ValueConverter

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

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

+ func (stmt *Stmt) NumInput() int

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

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

+ type TracerOptions struct

+ Filter Filter

+ Outputter Outputter

+ SlowQuery time.Duration

+ type Tx struct

+ Conn *Conn

+ Proxy *Proxy

+ Tx driver.Tx

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Rollback() error

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