testutils

package

v0.0.0-...-c07c10e Latest Latest Go to latest Published: Mar 9, 2026 License: Apache-2.0, MIT Imports: 45 Imported by: 0

Documentation ¶

Index ¶

func CompareSQLStrings(actual, expected string) error
func GetTestConfig() *config.Config
func NewTestServer() *testServer
func WithProvider(p testcontainers.ProviderType) testcontainers.CustomizeRequestOption
type ClickHouseServer
- func NewClickHouseServer(ctx context.Context) (*ClickHouseServer, error)
- func NewClickHouseServerAndConnection(ctx context.Context) (*ClickHouseServer, driver.Conn, error)
type MinioFixture
- func NewMinioServer(t *testing.T, ctx context.Context) *MinioFixture
type OidcServer
- func NewOIDCServer(listeningPort *int, privateKeyFilePath *string) (*OidcServer, error)
- func (s *OidcServer) Close()
- func (s *OidcServer) Token(claims map[string]string) (string, error)
type ProgrammableHTTPServer
- func NewProgrammableHTTPServer(logger *uberzap.SugaredLogger, credentials string) *ProgrammableHTTPServer
type ReplyT
type SyncBuffer
- func (s *SyncBuffer) String() string
- func (s *SyncBuffer) Write(p []byte) (n int, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CompareSQLStrings ¶

func CompareSQLStrings(actual, expected string) error

For two SQL strings, this function does a line-by-line comparison while also normalizing any whitespace to avoid auto-formatting differences such as the usage of tabs vs spaces which can vary across development setups across contributors/developers.

Returns no error if they're equal, fails with an error otherwise.

func GetTestConfig ¶

func GetTestConfig() *config.Config

func NewTestServer ¶

func NewTestServer() *testServer

func WithProvider ¶

func WithProvider(p testcontainers.ProviderType) testcontainers.CustomizeRequestOption

Types ¶

type ClickHouseServer ¶

type ClickHouseServer struct {
	*testcontainersCH.ClickHouseContainer
}

func NewClickHouseServer ¶

func NewClickHouseServer(ctx context.Context) (*ClickHouseServer, error)

func NewClickHouseServerAndConnection ¶

func NewClickHouseServerAndConnection(ctx context.Context) (*ClickHouseServer, driver.Conn, error)

func (*ClickHouseServer) CreateAllDatabasesAndRunMigrations ¶

func (c *ClickHouseServer) CreateAllDatabasesAndRunMigrations(ctx context.Context) error

func (*ClickHouseServer) CreateDatabase ¶

func (c *ClickHouseServer) CreateDatabase(ctx context.Context, dbName string) error

func (*ClickHouseServer) CreateDatabasesAndRunMigrations ¶

func (c *ClickHouseServer) CreateDatabasesAndRunMigrations(ctx context.Context, databases ...string) error

func (*ClickHouseServer) DropDatabase ¶

func (c *ClickHouseServer) DropDatabase(ctx context.Context, dbName string) error

func (*ClickHouseServer) Exec ¶

func (c *ClickHouseServer) Exec(ctx context.Context, sql string) error

func (*ClickHouseServer) GetConnection ¶

func (c *ClickHouseServer) GetConnection(ctx context.Context) (driver.Conn, error)

func (*ClickHouseServer) GetDSN ¶

func (c *ClickHouseServer) GetDSN(ctx context.Context, dbName string) (string, error)

type MinioFixture ¶

type MinioFixture struct {
	S3Client *s3.Client
	URL      string
	Username string
	Password string
}

func NewMinioServer ¶

func NewMinioServer(t *testing.T, ctx context.Context) *MinioFixture

func (*MinioFixture) DownloadAllFiles ¶

func (f *MinioFixture) DownloadAllFiles(t *testing.T, ctx context.Context, bucket string) map[string][]byte

func (*MinioFixture) ListObjects ¶

func (f *MinioFixture) ListObjects(t *testing.T, ctx context.Context, bucket string) []string

func (*MinioFixture) MakeBucket ¶

func (f *MinioFixture) MakeBucket(t *testing.T, ctx context.Context, bucket string)

func (*MinioFixture) SetAWSEnvVars ¶

func (f *MinioFixture) SetAWSEnvVars(t *testing.T)

func (*MinioFixture) UploadFile ¶

func (f *MinioFixture) UploadFile(t *testing.T, ctx context.Context, bucket, key string, data []byte)

type OidcServer ¶

type OidcServer struct {
	*httptest.Server
	// contains filtered or unexported fields
}

func NewOIDCServer ¶

func NewOIDCServer(listeningPort *int, privateKeyFilePath *string) (*OidcServer, error)

func (*OidcServer) Close ¶

func (s *OidcServer) Close()

func (*OidcServer) Token ¶

func (s *OidcServer) Token(claims map[string]string) (string, error)

type ProgrammableHTTPServer ¶

type ProgrammableHTTPServer struct {
	// contains filtered or unexported fields
}

func NewProgrammableHTTPServer ¶

func NewProgrammableHTTPServer(
	logger *uberzap.SugaredLogger,
	credentials string,
) *ProgrammableHTTPServer

func (*ProgrammableHTTPServer) GetRequests ¶

func (phs *ProgrammableHTTPServer) GetRequests(method, path string) []*http.Request

func (*ProgrammableHTTPServer) ServerURL ¶

func (phs *ProgrammableHTTPServer) ServerURL() string

func (*ProgrammableHTTPServer) SetResponse ¶

func (phs *ProgrammableHTTPServer) SetResponse(method, path string, status int, body string)

func (*ProgrammableHTTPServer) SetResponseFunc ¶

func (phs *ProgrammableHTTPServer) SetResponseFunc(method, path string, f func(*http.Request) (int, string))

func (*ProgrammableHTTPServer) Start ¶

func (phs *ProgrammableHTTPServer) Start()

func (*ProgrammableHTTPServer) Stop ¶

func (phs *ProgrammableHTTPServer) Stop()

type ReplyT ¶

type ReplyT struct {
	Status int
	Body   string
	Func   func(*http.Request) (int, string)
}

type SyncBuffer ¶

type SyncBuffer struct {
	// contains filtered or unexported fields
}

func (*SyncBuffer) String ¶

func (s *SyncBuffer) String() string

func (*SyncBuffer) Write ¶

func (s *SyncBuffer) Write(p []byte) (n int, err error)

Source Files ¶

View all Source files

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