test

Documentation

Index

• type AlertingServerUnit
• type TestEnvAlertingClusterDriver
  • func NewTestEnvAlertingClusterDriver(env *test.Environment, options TestEnvAlertingClusterDriverOptions) *TestEnvAlertingClusterDriver
  • func (l *TestEnvAlertingClusterDriver) ConfigureCluster(_ context.Context, configuration *alertops.ClusterConfiguration) (*emptypb.Empty, error)
  • func (l *TestEnvAlertingClusterDriver) GetClusterConfiguration(_ context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)
  • func (l *TestEnvAlertingClusterDriver) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*alertops.InstallStatus, error)
  • func (l *TestEnvAlertingClusterDriver) GetRuntimeOptions() shared.AlertingClusterOptions
  • func (l *TestEnvAlertingClusterDriver) InstallCluster(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (l *TestEnvAlertingClusterDriver) Name() string
  • func (l *TestEnvAlertingClusterDriver) ShouldDisableNode(_ *corev1.Reference) error
  • func (l *TestEnvAlertingClusterDriver) StartAlertingBackendServer(ctx context.Context, configFilePath string) AlertingServerUnit
  • func (l *TestEnvAlertingClusterDriver) UninstallCluster(_ context.Context, _ *alertops.UninstallRequest) (*emptypb.Empty, error)
• type TestEnvAlertingClusterDriverOptions

Types

type AlertingServerUnit

type AlertingServerUnit struct {
	AlertManagerPort int
	ClusterPort      int
	OpniPort         int
	Ctx              context.Context
	CancelFunc       context.CancelFunc
}

type TestEnvAlertingClusterDriver

type TestEnvAlertingClusterDriver struct {
	ConfigFile string

	*shared.AlertingClusterOptions

	*alertops.ClusterConfiguration

	alertops.UnsafeAlertingAdminServer
	// contains filtered or unexported fields
}

func NewTestEnvAlertingClusterDriver

func NewTestEnvAlertingClusterDriver(env *test.Environment, options TestEnvAlertingClusterDriverOptions) *TestEnvAlertingClusterDriver

func (*TestEnvAlertingClusterDriver) ConfigureCluster

func (l *TestEnvAlertingClusterDriver) ConfigureCluster(_ context.Context, configuration *alertops.ClusterConfiguration) (*emptypb.Empty, error)

func (*TestEnvAlertingClusterDriver) GetClusterConfiguration

func (l *TestEnvAlertingClusterDriver) GetClusterConfiguration(_ context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)

func (*TestEnvAlertingClusterDriver) GetClusterStatus

func (l *TestEnvAlertingClusterDriver) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*alertops.InstallStatus, error)

func (*TestEnvAlertingClusterDriver) GetRuntimeOptions

func (l *TestEnvAlertingClusterDriver) GetRuntimeOptions() shared.AlertingClusterOptions

func (*TestEnvAlertingClusterDriver) InstallCluster

func (l *TestEnvAlertingClusterDriver) InstallCluster(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*TestEnvAlertingClusterDriver) Name

func (l *TestEnvAlertingClusterDriver) Name() string

func (*TestEnvAlertingClusterDriver) ShouldDisableNode

func (l *TestEnvAlertingClusterDriver) ShouldDisableNode(_ *corev1.Reference) error

func (*TestEnvAlertingClusterDriver) StartAlertingBackendServer

func (l *TestEnvAlertingClusterDriver) StartAlertingBackendServer(
	ctx context.Context,
	configFilePath string,
) AlertingServerUnit

func (*TestEnvAlertingClusterDriver) UninstallCluster

func (l *TestEnvAlertingClusterDriver) UninstallCluster(_ context.Context, _ *alertops.UninstallRequest) (*emptypb.Empty, error)

type TestEnvAlertingClusterDriverOptions

type TestEnvAlertingClusterDriverOptions struct {
	AlertingOptions *shared.AlertingClusterOptions            `option:"alertingOptions"`
	Subscribers     []chan shared.AlertingClusterNotification `option:"subscribers"`
}