ddpgx

Documentation

Index

• type Connection
  • func Connect(ctx context.Context, serviceName, url string) (Connection, error)
  • func ConnectPoolConfig(ctx context.Context, serviceName string, config *pgxpool.Config) (Connection, error)

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) (Connection, error)

func ConnectPoolConfig

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