opentracing

Documentation

Index

• func StartSpanFromContext(ctx context.Context, tracer Tracer, operation, method string, ...) (context.Context, otr.Span)
• type Interceptor
  • func NewInterceptor(tracer 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
• type Tracer
  • func NewTracer(params TracerParams) (Tracer, error)
• type TracerParams

Functions

func StartSpanFromContext

func StartSpanFromContext(ctx context.Context, tracer Tracer, operation, method string, opts ...otr.StartSpanOption) (context.Context, otr.Span)

StartSpanFromContext for opentracing.

Types

type Interceptor

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

Interceptor for opentracing.

func NewInterceptor

func NewInterceptor(tracer 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

type Tracer

type Tracer otr.Tracer

Tracer for opentracing.

func NewTracer

func NewTracer(params TracerParams) (Tracer, error)

NewTracer for opentracing.

type TracerParams

type TracerParams struct {
	fx.In

	Lifecycle fx.Lifecycle
	Config    *opentracing.Config
	Version   version.Version
}

TracerParams for opentracing.