test

Documentation

Index

• func NewAdminPrivateAPIClient(helper *test.Helper) *adminprivate.APIClient
• func NewApiClient(helper *test.Helper) *public.APIClient
• func NewKafkaHelper(t *testing.T, server *httptest.Server) (*test.Helper, *public.APIClient, func())
• func NewKafkaHelperWithHooks(t *testing.T, server *httptest.Server, configurationHook interface{}) (*test.Helper, *public.APIClient, func())
• func NewMockDataplaneCluster(name string, capacity int) config.ManualCluster
• func NewPrivateAPIClient(helper *test.Helper) *private.APIClient
• type Services

Functions

func NewAdminPrivateAPIClient

func NewAdminPrivateAPIClient(helper *test.Helper) *adminprivate.APIClient

func NewApiClient

func NewApiClient(helper *test.Helper) *public.APIClient

func NewKafkaHelper

func NewKafkaHelper(t *testing.T, server *httptest.Server) (*test.Helper, *public.APIClient, func())

Register a test This should be run before every integration test

func NewKafkaHelperWithHooks

func NewKafkaHelperWithHooks(t *testing.T, server *httptest.Server, configurationHook interface{}) (*test.Helper, *public.APIClient, func())

func NewMockDataplaneCluster

func NewMockDataplaneCluster(name string, capacity int) config.ManualCluster

func NewPrivateAPIClient

func NewPrivateAPIClient(helper *test.Helper) *private.APIClient

Types

type Services

type Services struct {
	di.Inject
	DBFactory             *db.ConnectionFactory
	KeycloakConfig        *keycloak.KeycloakConfig
	KafkaConfig           *config.KafkaConfig
	MetricsServer         *server.MetricsServer
	HealthCheckServer     *server.HealthCheckServer
	Workers               []coreWorkers.Worker
	LeaderElectionManager *coreWorkers.LeaderElectionManager
	SignalBus             signalbus.SignalBus
	APIServer             *server.ApiServer
	BootupServices        []environments.BootService
	CloudProvidersService services.CloudProvidersService
	ClusterService        services.ClusterService
	OCMClient             ocm.ClusterManagementClient
	OCMConfig             *ocm.OCMConfig
	KafkaService          services.KafkaService
	ObservatoriumClient   *observatorium.Client
	ClusterManager        *cluster_mgrs.ClusterManager
	ServerConfig          *server.ServerConfig
}

var TestServices Services