testutils

Documentation

Index

• func CompareSQLStrings(actual, expected string) error
• type ClickHouseServer
  • func NewClickHouseServer(ctx context.Context) (*ClickHouseServer, error)
  • func (c *ClickHouseServer) CreateDatabase(ctx context.Context, dbName string) error
  • func (c *ClickHouseServer) DropDatabase(ctx context.Context, dbName string) error
  • func (c *ClickHouseServer) Exec(ctx context.Context, sql string) error
  • func (c *ClickHouseServer) GetConnection(ctx context.Context) (driver.Conn, error)
  • func (c *ClickHouseServer) GetDSN(ctx context.Context, dbName string) (string, error)
• type ProgrammableHTTPServer
  • func NewProgrammableHTTPServer(logger *uberzap.SugaredLogger, credentials string) *ProgrammableHTTPServer
  • func (phs *ProgrammableHTTPServer) GetRequests(method, path string) []*http.Request
  • func (phs *ProgrammableHTTPServer) ServerURL() string
  • func (phs *ProgrammableHTTPServer) SetResponse(method, path string, status int, body string)
  • func (phs *ProgrammableHTTPServer) SetResponseFunc(method, path string, f func(*http.Request) (int, string))
  • func (phs *ProgrammableHTTPServer) Start()
  • func (phs *ProgrammableHTTPServer) Stop()
• type ReplyT
• type SyncBuffer
  • func (s *SyncBuffer) String() string
  • func (s *SyncBuffer) Write(p []byte) (n int, err error)

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.

Types

type ClickHouseServer

type ClickHouseServer struct {
	*testcontainersCH.ClickHouseContainer
}

func NewClickHouseServer

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

func (*ClickHouseServer) CreateDatabase

func (c *ClickHouseServer) CreateDatabase(ctx context.Context, dbName 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 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)