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, empty *emptypb.Empty) (*alertops.ClusterConfiguration, error)
  • func (a *AlertingClusterManager) GetClusterStatus(ctx context.Context, empty *emptypb.Empty) (status *alertops.InstallStatus, retErr error)
  • func (a *AlertingClusterManager) GetRuntimeOptions() shared.AlertingClusterOptions
  • func (a *AlertingClusterManager) InstallCluster(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)
  • func (a *AlertingClusterManager) ShouldDisableNode(reference *corev1.Reference) error
  • func (a *AlertingClusterManager) UninstallCluster(ctx context.Context, request *alertops.UninstallRequest) (*emptypb.Empty, error)
• type AlertingDriverOptions
• type AlertingGatewayManager
  • func NewAlertingGatewayManager(options AlertingDriverOptions) (*AlertingGatewayManager, error)
  • func (a *AlertingGatewayManager) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)
  • func (a *AlertingGatewayManager) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)
  • func (a *AlertingGatewayManager) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*alertops.InstallStatus, error)
  • func (a *AlertingGatewayManager) GetRuntimeOptions() shared.AlertingClusterOptions
  • func (a *AlertingGatewayManager) InstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (a *AlertingGatewayManager) ShouldDisableNode(_ *corev1.Reference) error
  • func (a *AlertingGatewayManager) UninstallCluster(ctx context.Context, _ *alertops.UninstallRequest) (*emptypb.Empty, error)

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, empty *emptypb.Empty) (*alertops.ClusterConfiguration, error)

func (*AlertingClusterManager) GetClusterStatus

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

func (*AlertingClusterManager) GetRuntimeOptions

func (a *AlertingClusterManager) GetRuntimeOptions() shared.AlertingClusterOptions

func (*AlertingClusterManager) InstallCluster

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

func (*AlertingClusterManager) ShouldDisableNode

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

func (*AlertingClusterManager) UninstallCluster

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

type AlertingDriverOptions

type AlertingDriverOptions struct {
	Logger             *zap.SugaredLogger                        `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 shared.AlertingClusterNotification `option:"subscribers"`
}

type AlertingGatewayManager

type AlertingGatewayManager struct {
	AlertingDriverOptions
	alertops.UnsafeAlertingAdminServer
}

func NewAlertingGatewayManager

func NewAlertingGatewayManager(options AlertingDriverOptions) (*AlertingGatewayManager, error)

func (*AlertingGatewayManager) ConfigureCluster

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

func (*AlertingGatewayManager) GetClusterConfiguration

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

func (*AlertingGatewayManager) GetClusterStatus

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

func (*AlertingGatewayManager) GetRuntimeOptions

func (a *AlertingGatewayManager) GetRuntimeOptions() shared.AlertingClusterOptions

func (*AlertingGatewayManager) InstallCluster

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

func (*AlertingGatewayManager) ShouldDisableNode

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

func (*AlertingGatewayManager) UninstallCluster

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