opentracing

Documentation

Index

• type Interceptor
  • func NewInterceptor(driver string, tracer otr.Tracer, interceptor sqlmw.Interceptor) *Interceptor
  • func (i *Interceptor) ConnBeginTx(ctx context.Context, conn driver.ConnBeginTx, txOpts driver.TxOptions) (driver.Tx, error)
  • func (i *Interceptor) ConnExecContext(ctx context.Context, conn driver.ExecerContext, query string, ...) (driver.Result, error)
  • func (i *Interceptor) ConnPing(ctx context.Context, conn driver.Pinger) error
  • func (i *Interceptor) ConnPrepareContext(ctx context.Context, conn driver.ConnPrepareContext, query string) (driver.Stmt, error)
  • func (i *Interceptor) ConnQueryContext(ctx context.Context, conn driver.QueryerContext, query string, ...) (driver.Rows, error)
  • func (i *Interceptor) ConnectorConnect(ctx context.Context, connect driver.Connector) (driver.Conn, error)
  • func (i *Interceptor) ResultLastInsertId(res driver.Result) (int64, error)
  • func (i *Interceptor) ResultRowsAffected(res driver.Result) (int64, error)
  • func (i *Interceptor) RowsClose(ctx context.Context, rows driver.Rows) error
  • func (i *Interceptor) RowsNext(ctx context.Context, rows driver.Rows, dest []driver.Value) error
  • func (i *Interceptor) StmtClose(ctx context.Context, stmt driver.Stmt) error
  • func (i *Interceptor) StmtExecContext(ctx context.Context, stmt driver.StmtExecContext, query string, ...) (driver.Result, error)
  • func (i *Interceptor) StmtQueryContext(ctx context.Context, stmt driver.StmtQueryContext, query string, ...) (driver.Rows, error)
  • func (i *Interceptor) TxCommit(ctx context.Context, tx driver.Tx) error
  • func (i *Interceptor) TxRollback(ctx context.Context, tx driver.Tx) error

Types

type Interceptor

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

Interceptor for opentracing.

func NewInterceptor

func NewInterceptor(driver string, tracer otr.Tracer, interceptor sqlmw.Interceptor) *Interceptor

NewInterceptor for opentracing.

func (*Interceptor) ConnBeginTx

func (i *Interceptor) ConnBeginTx(ctx context.Context, conn driver.ConnBeginTx, txOpts driver.TxOptions) (driver.Tx, error)

func (*Interceptor) ConnExecContext

func (i *Interceptor) ConnExecContext(ctx context.Context, conn driver.ExecerContext, query string, args []driver.NamedValue) (driver.Result, error)

nolint:dupl

func (*Interceptor) ConnPing

func (i *Interceptor) ConnPing(ctx context.Context, conn driver.Pinger) error

func (*Interceptor) ConnPrepareContext

func (i *Interceptor) ConnPrepareContext(ctx context.Context, conn driver.ConnPrepareContext, query string) (driver.Stmt, error)

func (*Interceptor) ConnQueryContext

func (i *Interceptor) ConnQueryContext(ctx context.Context, conn driver.QueryerContext, query string, args []driver.NamedValue) (driver.Rows, error)

nolint:dupl

func (*Interceptor) ConnectorConnect

func (i *Interceptor) ConnectorConnect(ctx context.Context, connect driver.Connector) (driver.Conn, error)

func (*Interceptor) ResultLastInsertId

func (i *Interceptor) ResultLastInsertId(res driver.Result) (int64, error)

nolint:revive,stylecheck

func (*Interceptor) ResultRowsAffected

func (i *Interceptor) ResultRowsAffected(res driver.Result) (int64, error)

func (*Interceptor) RowsClose

func (i *Interceptor) RowsClose(ctx context.Context, rows driver.Rows) error

func (*Interceptor) RowsNext

func (i *Interceptor) RowsNext(ctx context.Context, rows driver.Rows, dest []driver.Value) error

func (*Interceptor) StmtClose

func (i *Interceptor) StmtClose(ctx context.Context, stmt driver.Stmt) error

func (*Interceptor) StmtExecContext

func (i *Interceptor) StmtExecContext(ctx context.Context, stmt driver.StmtExecContext, query string, args []driver.NamedValue) (driver.Result, error)

nolint:dupl

func (*Interceptor) StmtQueryContext

func (i *Interceptor) StmtQueryContext(ctx context.Context, stmt driver.StmtQueryContext, query string, args []driver.NamedValue) (driver.Rows, error)

nolint:dupl

func (*Interceptor) TxCommit

func (i *Interceptor) TxCommit(ctx context.Context, tx driver.Tx) error

func (*Interceptor) TxRollback

func (i *Interceptor) TxRollback(ctx context.Context, tx driver.Tx) error