test

package

v0.14.0 Latest Latest Go to latest Published: Jun 12, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

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 SetupEmptyTestTable(ctx context.Context, t *testing.T, conn Querier) string
func SetupEmptyTestTableWithName(ctx context.Context, t *testing.T, conn Querier, table string)
func SetupTestTable(ctx context.Context, t *testing.T, conn Querier) string
func SetupTestTableWithName(ctx context.Context, t *testing.T, conn Querier, table 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.

View Source

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

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

View Source

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

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

View Source

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

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

View Source

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

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

View Source

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

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

Variables ¶

This section is empty.

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 ¶ added in v0.10.0

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

func CreatePublication ¶ added in v0.7.1

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

func CreateReplicationSlot ¶ added in v0.7.1

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 SetupEmptyTestTable ¶ added in v0.11.0

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

SetupTestTable creates a new table and returns its name.

func SetupEmptyTestTableWithName ¶ added in v0.11.1

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

func SetupTestTable ¶

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

SetupTestTable creates a new table and returns its name.

func SetupTestTableWithName ¶ added in v0.11.1

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

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
}

Source Files ¶

View all Source files

helper.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL