test

package
v0.0.0-...-9b598c7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 28, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis
integration
kafka
Ensures the user has at least one kafka cluster created and stores it's id in a scenario variable:
Ensures the user has at least one kafka cluster created and stores it's id in a scenario variable:
mocks

Jump to

Keyboard shortcuts

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