suite

Documentation

Index

• func TestInvalidLogin[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](s *Base[ID, IDBUILDER], dsiSrc *api_common.TDataSourceInstance, ...)
• func TestInvalidPassword[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](s *Base[ID, IDBUILDER], dsiSrc *api_common.TDataSourceInstance, ...)
• func TestMissingDataSource[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](s *Base[ID, IDBUILDER], dsi *api_common.TDataSourceInstance)
• func TestPositiveStats[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](s *Base[ID, IDBUILDER], dataSource *datasource.DataSource, ...)
• func TestUnsupportedPushdownFilteringMandatory[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](s *Base[ID, IDBUILDER], dsi *api_common.TDataSourceInstance, ...)
• type Base
  • func NewBase[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](t *testing.T, state *State, name string, suiteOptions ...BaseOption) *Base[ID, IDBUILDER]
  • func (b *Base[_, _]) BeforeSuite(_ string)
  • func (b *Base[_, _]) BeforeTest(_, testName string)
  • func (b *Base[_, _]) SetupSuite()
  • func (b *Base[_, _]) TearDownSuite()
  • func (b *Base[_, _]) TearDownTest()
  • func (b *Base[ID, IDBUILDER]) ValidateTable(ds *datasource.DataSource, table *test_utils.Table[ID, IDBUILDER], ...)
• type BaseOption
  • func WithEmbeddedOptions(options ...server.EmbeddedOption) BaseOption
• type State
  • func NewState() (*State, error)
  • func (s *State) SkipSuiteIfNotEnabled(t *testing.T)
• type ValidateTableOption
  • func WithDateTimeFormat(val api_service_protos.EDateTimeFormat) ValidateTableOption
  • func WithFiltering(val api_service_protos.TReadSplitsRequest_EFiltering) ValidateTableOption
  • func WithPredicate(val *api_service_protos.TPredicate) ValidateTableOption

Functions

func TestInvalidLogin

func TestInvalidLogin[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](
	s *Base[ID, IDBUILDER],
	dsiSrc *api_common.TDataSourceInstance,
	table *test_utils.Table[ID, IDBUILDER],
)

func TestInvalidPassword

func TestInvalidPassword[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](
	s *Base[ID, IDBUILDER],
	dsiSrc *api_common.TDataSourceInstance,
	table *test_utils.Table[ID, IDBUILDER],
)

func TestMissingDataSource

func TestMissingDataSource[
	ID test_utils.TableIDTypes,
	IDBUILDER test_utils.ArrowIDBuilder[ID],
](s *Base[ID, IDBUILDER], dsi *api_common.TDataSourceInstance)

func TestPositiveStats

func TestPositiveStats[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](
	s *Base[ID, IDBUILDER],
	dataSource *datasource.DataSource,
	table *test_utils.Table[ID, IDBUILDER],
)

func TestUnsupportedPushdownFilteringMandatory

func TestUnsupportedPushdownFilteringMandatory[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]](
	s *Base[ID, IDBUILDER],
	dsi *api_common.TDataSourceInstance,
	table *test_utils.Table[ID, IDBUILDER],
	predicate *api_service_protos.TPredicate,
)

Types

type Base

type Base[ID test_utils.TableIDTypes, IDBUILDER test_utils.ArrowIDBuilder[ID]] struct {
	testify_suite.Suite
	*State
	Connector common.TestingServer
	// contains filtered or unexported fields
}

func NewBase

func NewBase[
	ID test_utils.TableIDTypes,
	IDBUILDER test_utils.ArrowIDBuilder[ID],
](t *testing.T, state *State, name string, suiteOptions ...BaseOption) *Base[ID, IDBUILDER]

func (*Base[_, _]) BeforeSuite

func (b *Base[_, _]) BeforeSuite(_ string)

func (*Base[_, _]) BeforeTest

func (b *Base[_, _]) BeforeTest(_, testName string)

func (*Base[_, _]) SetupSuite

func (b *Base[_, _]) SetupSuite()

func (*Base[_, _]) TearDownSuite

func (b *Base[_, _]) TearDownSuite()

func (*Base[_, _]) TearDownTest

func (b *Base[_, _]) TearDownTest()

func (*Base[ID, IDBUILDER]) ValidateTable

func (b *Base[ID, IDBUILDER]) ValidateTable(
	ds *datasource.DataSource,
	table *test_utils.Table[ID, IDBUILDER],
	customOptions ...ValidateTableOption,
)

type BaseOption

type BaseOption interface {
	// contains filtered or unexported methods
}

func WithEmbeddedOptions

func WithEmbeddedOptions(options ...server.EmbeddedOption) BaseOption

type State

type State struct {
	EndpointDeterminer *docker_compose.EndpointDeterminer
	// contains filtered or unexported fields
}

Global-scope services and objects that will be accessible from every test suite during the testing lifecycle

func NewState

func NewState() (*State, error)

func (*State) SkipSuiteIfNotEnabled

func (s *State) SkipSuiteIfNotEnabled(t *testing.T)

type ValidateTableOption

type ValidateTableOption interface {
	// contains filtered or unexported methods
}

func WithDateTimeFormat

func WithDateTimeFormat(val api_service_protos.EDateTimeFormat) ValidateTableOption

func WithFiltering

func WithFiltering(val api_service_protos.TReadSplitsRequest_EFiltering) ValidateTableOption

func WithPredicate

func WithPredicate(val *api_service_protos.TPredicate) ValidateTableOption