ddpgx

Documentation

Index

• type Connection
  • func Connect(ctx context.Context, serviceName, url string, tracerOpts ...TracerOpt) (Connection, error)
  • func ConnectPoolConfig(ctx context.Context, serviceName string, config *pgxpool.Config, ...) (Connection, error)
• type NoopFormatter
• type StripNewLinesFormatter
• type TagValueFormatter
  • func NewDefaultFormatter() TagValueFormatter
  • func NewNoopFormatter() TagValueFormatter
• type TracerOpt
  • func NoopSpanValueFormatter() TracerOpt

Types

type Connection

type Connection interface {
	ConnInfo() *pgtype.ConnInfo
	Begin(context.Context) (pgx.Tx, error)
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	Close(context.Context) error
}

func Connect

func Connect(ctx context.Context, serviceName, url string, tracerOpts ...TracerOpt) (Connection, error)

func ConnectPoolConfig

func ConnectPoolConfig(ctx context.Context, serviceName string, config *pgxpool.Config, tracerOpts ...TracerOpt) (Connection, error)

type NoopFormatter

type NoopFormatter struct{}

type StripNewLinesFormatter

type StripNewLinesFormatter struct{}

type TagValueFormatter

type TagValueFormatter interface {
	// contains filtered or unexported methods
}

func NewDefaultFormatter

func NewDefaultFormatter() TagValueFormatter

func NewNoopFormatter

func NewNoopFormatter() TagValueFormatter

type TracerOpt

type TracerOpt func(c *internalTracer)

func NoopSpanValueFormatter

func NoopSpanValueFormatter() TracerOpt