alerting_manager

Documentation

Index

• type AlertingClusterManager
  • func NewAlertingClusterManager(options AlertingDriverOptions) (*AlertingClusterManager, error)
  • func (a *AlertingClusterManager) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)
  • func (a *AlertingClusterManager) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)
  • func (a *AlertingClusterManager) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (status *alertops.InstallStatus, retErr error)
  • func (a *AlertingClusterManager) GetDefaultReceiver() *config.WebhookConfig
  • func (a *AlertingClusterManager) Info(_ context.Context, _ *emptypb.Empty) (*alertops.ComponentInfo, error)
  • func (a *AlertingClusterManager) InstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (a *AlertingClusterManager) ShouldDisableNode(_ *corev1.Reference) error
  • func (a *AlertingClusterManager) UninstallCluster(ctx context.Context, _ *alertops.UninstallRequest) (*emptypb.Empty, error)
• type AlertingDriverOptions

Types

type AlertingClusterManager

type AlertingClusterManager struct {
	AlertingDriverOptions
	alertops.UnsafeAlertingAdminServer
}

func NewAlertingClusterManager

func NewAlertingClusterManager(options AlertingDriverOptions) (*AlertingClusterManager, error)

func (*AlertingClusterManager) ConfigureCluster

func (a *AlertingClusterManager) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)

func (*AlertingClusterManager) GetClusterConfiguration

func (a *AlertingClusterManager) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)

func (*AlertingClusterManager) GetClusterStatus

func (a *AlertingClusterManager) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (status *alertops.InstallStatus, retErr error)

func (*AlertingClusterManager) GetDefaultReceiver

func (a *AlertingClusterManager) GetDefaultReceiver() *config.WebhookConfig

func (*AlertingClusterManager) Info

func (a *AlertingClusterManager) Info(_ context.Context, _ *emptypb.Empty) (*alertops.ComponentInfo, error)

func (*AlertingClusterManager) InstallCluster

func (a *AlertingClusterManager) InstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*AlertingClusterManager) ShouldDisableNode

func (a *AlertingClusterManager) ShouldDisableNode(_ *corev1.Reference) error

func (*AlertingClusterManager) UninstallCluster

func (a *AlertingClusterManager) UninstallCluster(ctx context.Context, _ *alertops.UninstallRequest) (*emptypb.Empty, error)

type AlertingDriverOptions

type AlertingDriverOptions struct {
	Logger             *slog.Logger                         `option:"logger"`
	K8sClient          client.Client                        `option:"k8sClient"`
	GatewayRef         types.NamespacedName                 `option:"gatewayRef"`
	ConfigKey          string                               `option:"configKey"`
	InternalRoutingKey string                               `option:"internalRoutingKey"`
	AlertingOptions    *shared.AlertingClusterOptions       `option:"alertingOptions"`
	Subscribers        []chan alertingClient.AlertingClient `option:"subscribers"`
	TlsConfig          *tls.Config                          `option:"tlsConfig"`
}