Documentation ¶
Index ¶
- type AlertingClusterManager
- 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 (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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertingClusterManager ¶ added in v0.10.0
type AlertingClusterManager struct { AlertingDriverOptions alertops.UnsafeAlertingAdminServer }
func NewAlertingClusterManager ¶ added in v0.10.0
func NewAlertingClusterManager(options AlertingDriverOptions) (*AlertingClusterManager, error)
func (*AlertingClusterManager) ConfigureCluster ¶ added in v0.10.0
func (a *AlertingClusterManager) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)
func (*AlertingClusterManager) GetClusterConfiguration ¶ added in v0.10.0
func (a *AlertingClusterManager) GetClusterConfiguration(ctx context.Context, empty *emptypb.Empty) (*alertops.ClusterConfiguration, error)
func (*AlertingClusterManager) GetClusterStatus ¶ added in v0.10.0
func (a *AlertingClusterManager) GetClusterStatus(ctx context.Context, empty *emptypb.Empty) (status *alertops.InstallStatus, retErr error)
func (*AlertingClusterManager) GetRuntimeOptions ¶ added in v0.10.0
func (a *AlertingClusterManager) GetRuntimeOptions() shared.AlertingClusterOptions
func (*AlertingClusterManager) InstallCluster ¶ added in v0.10.0
func (*AlertingClusterManager) ShouldDisableNode ¶ added in v0.10.0
func (a *AlertingClusterManager) ShouldDisableNode(reference *corev1.Reference) error
func (*AlertingClusterManager) UninstallCluster ¶ added in v0.10.0
func (a *AlertingClusterManager) UninstallCluster(ctx context.Context, request *alertops.UninstallRequest) (*emptypb.Empty, error)
type AlertingDriverOptions ¶ added in v0.10.0
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 ¶ added in v0.10.0
type AlertingGatewayManager struct { AlertingDriverOptions alertops.UnsafeAlertingAdminServer }
func NewAlertingGatewayManager ¶ added in v0.10.0
func NewAlertingGatewayManager(options AlertingDriverOptions) (*AlertingGatewayManager, error)
func (*AlertingGatewayManager) ConfigureCluster ¶ added in v0.10.0
func (a *AlertingGatewayManager) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)
func (*AlertingGatewayManager) GetClusterConfiguration ¶ added in v0.10.0
func (a *AlertingGatewayManager) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)
func (*AlertingGatewayManager) GetClusterStatus ¶ added in v0.10.0
func (a *AlertingGatewayManager) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*alertops.InstallStatus, error)
func (*AlertingGatewayManager) GetRuntimeOptions ¶ added in v0.10.0
func (a *AlertingGatewayManager) GetRuntimeOptions() shared.AlertingClusterOptions
func (*AlertingGatewayManager) InstallCluster ¶ added in v0.10.0
func (*AlertingGatewayManager) ShouldDisableNode ¶ added in v0.10.0
func (a *AlertingGatewayManager) ShouldDisableNode(_ *corev1.Reference) error
func (*AlertingGatewayManager) UninstallCluster ¶ added in v0.10.0
func (a *AlertingGatewayManager) UninstallCluster(ctx context.Context, _ *alertops.UninstallRequest) (*emptypb.Empty, error)
Click to show internal directories.
Click to hide internal directories.