test

Documentation

Index

• Constants
• func ConnectPool(ctx context.Context, t *testing.T, connString string) *pgxpool.Pool
• func ConnectSimple(ctx context.Context, t *testing.T, connString string) *pgx.Conn
• func Context(t *testing.T) context.Context
• func CreatePublication(t *testing.T, conn Querier, pubName string, tables []string)
• func CreateReplicationSlot(t *testing.T, conn Querier, slotName string)
• func IsPgError(is *is.I, err error, wantCode string)
• func RandomIdentifier(t *testing.T) string
• func SetupTestTable(ctx context.Context, t *testing.T, conn Querier) string
• type Querier

Constants

const RegularConnString = "postgres://meroxauser:meroxapass@127.0.0.1:5433/meroxadb?sslmode=disable"

RegularConnString is a non-replication user connection string for the test postgres.

const RepmgrConnString = "postgres://repmgr:repmgrmeroxa@127.0.0.1:5433/meroxadb?sslmode=disable"

RepmgrConnString is a replication user connection string for the test postgres.

const TestTableAvroSchemaV1 = `` /* 715-byte string literal not displayed */

TestTableAvroSchemaV1 is the Avro schema representation of the test table defined through testTableCreateQuery. The fields are sorted by name.

const TestTableAvroSchemaV2 = `` /* 805-byte string literal not displayed */

TestTableAvroSchemaV2 is TestTableAvroSchemaV1 with `column6` (local-timestamp-micros) added.

const TestTableAvroSchemaV3 = `` /* 358-byte string literal not displayed */

TestTableAvroSchemaV3 is TestTableAvroSchemaV1 with `column4` and `column5` dropped.

const TestTableKeyAvroSchema = `{
    "type": "record",
    "name": "%s",
    "fields":
    [
        {"name":"id","type":"long"}
    ]
}`

TestTableKeyAvroSchema is the Avro schema for the test table's key column.

Functions

func ConnectPool

func ConnectPool(ctx context.Context, t *testing.T, connString string) *pgxpool.Pool

func ConnectSimple

func ConnectSimple(ctx context.Context, t *testing.T, connString string) *pgx.Conn

func Context

func Context(t *testing.T) context.Context

func CreatePublication

func CreatePublication(t *testing.T, conn Querier, pubName string, tables []string)

func CreateReplicationSlot

func CreateReplicationSlot(t *testing.T, conn Querier, slotName string)

func IsPgError

func IsPgError(is *is.I, err error, wantCode string)

func RandomIdentifier

func RandomIdentifier(t *testing.T) string

func SetupTestTable

func SetupTestTable(ctx context.Context, t *testing.T, conn Querier) string

SetupTestTable creates a new table and returns its name.

Types

type Querier

type Querier interface {
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
}