testutils

package

v1.0.0 Latest Latest Go to latest Published: Apr 28, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MinioContainer struct {
	*minioDocker.MinioContainer
	S3ClientConfig config.S3ClientConfig
}

type MinioSuite struct {
	suite.Suite
	*MinioContainer
	MinioClient *minio.Client
}

func (suite *MinioSuite) CreateBucket(ctx context.Context, bucket string)

func (suite *MinioSuite) PutObject(ctx context.Context, bucket string, key string, data []byte)

func (suite *MinioSuite) RemoveBucket(ctx context.Context, bucket string)

func (suite *MinioSuite) SetupSuite()

func (suite *MinioSuite) TearDownSuite()

func (suite *MinioSuite) UniqueBucketName() string

type ParquetSuite struct {
	MinioSuite
}

func (suite *ParquetSuite) PutParquet(ctx context.Context, bucket, key string, data []byte)

func (suite *ParquetSuite) WriteParquetGenericRows(schema parquet.Group, rows []TestParquetTypeRow) []byte

func (suite *ParquetSuite) WriteTestParquetFile(rows []TestParquetRow) []byte

type PostgresContainer struct {
	*postgres.PostgresContainer
	ConnectionConfig config.DatabaseConnectionConfig
	RawConnection    string
}

type PostgresSuite struct {
	suite.Suite
	*PostgresContainer
	Connection *pgxpool.Pool
}

func (suite *PostgresSuite) ExecuteSQL(sql string)

func (suite *PostgresSuite) FetchRows(sql string) pgx.Rows

func (suite *PostgresSuite) SetupSuite()

func (suite *PostgresSuite) TearDownSuite()

func (suite *PostgresSuite) UniqueTableName(prefix string) string

type TestParquetRow struct {
	ID     int64  `parquet:"id"`
	Name   string `parquet:"name"`
	Active bool   `parquet:"active"`
}

TestParquetRow uses types that map cleanly through ConvertSchema.

type TestParquetTypeRow struct {
	ID    int64
	Value any
}