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) GetDefaultReceiver() *config.WebhookConfig
  • func (l *TestEnvAlertingClusterDriver) Info(_ context.Context, _ *emptypb.Empty) (*alertops.ComponentInfo, error)
  • 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
• type TestNodeDriver
  • func NewTestNodeDriver() *TestNodeDriver
  • func (n *TestNodeDriver) ConfigureNode(_ string, _ *node.AlertingCapabilityConfig) error
  • func (n *TestNodeDriver) DiscoverRules(_ context.Context) (*rules.RuleManifest, error)

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
	client.AlertingClient
	// 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) GetDefaultReceiver

func (l *TestEnvAlertingClusterDriver) GetDefaultReceiver() *config.WebhookConfig

func (*TestEnvAlertingClusterDriver) Info

func (l *TestEnvAlertingClusterDriver) Info(_ context.Context, _ *emptypb.Empty) (*alertops.ComponentInfo, error)

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 client.AlertingClient   `option:"subscribers"`
}

type TestNodeDriver

type TestNodeDriver struct {
	// contains filtered or unexported fields
}

func NewTestNodeDriver

func NewTestNodeDriver() *TestNodeDriver

func (*TestNodeDriver) ConfigureNode

func (n *TestNodeDriver) ConfigureNode(_ string, _ *node.AlertingCapabilityConfig) error

func (*TestNodeDriver) DiscoverRules

func (n *TestNodeDriver) DiscoverRules(_ context.Context) (*rules.RuleManifest, error)