ops

Documentation

Index

• type AlertingOpsNode
  • func NewAlertingOpsNode(clusterDriver future.Future[drivers.ClusterDriver], ...) *AlertingOpsNode
  • func (a *AlertingOpsNode) ApplyConfigToBackend(ctx context.Context, config *routing.RoutingTree, ...) error
  • func (a *AlertingOpsNode) ConfigFromBackend(ctx context.Context) (*routing.RoutingTree, *routing.OpniInternalRouting, error)
  • func (a *AlertingOpsNode) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)
  • func (a *AlertingOpsNode) Fetch(ctx context.Context, _ *emptypb.Empty) (*alertops.AlertingConfig, error)
  • func (a *AlertingOpsNode) GetAvailableEndpoint(ctx context.Context, options shared.NewAlertingOptions) (string, error)
  • func (a *AlertingOpsNode) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)
  • func (a *AlertingOpsNode) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*alertops.InstallStatus, error)
  • func (a *AlertingOpsNode) GetRuntimeOptions(ctx context.Context) (shared.NewAlertingOptions, error)
  • func (a *AlertingOpsNode) InstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (a *AlertingOpsNode) Reload(ctx context.Context, info *alertops.ReloadInfo) (*emptypb.Empty, error)
  • func (a *AlertingOpsNode) UninstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (a *AlertingOpsNode) Update(ctx context.Context, config *alertops.AlertingConfig) (*emptypb.Empty, error)
• type AlertingOpsNodeOption
• type AlertingOpsNodeOptions

Types

type AlertingOpsNode

type AlertingOpsNode struct {
	AlertingOpsNodeOptions
	ClusterDriver future.Future[drivers.ClusterDriver]
	alertops.UnsafeAlertingAdminServer
	alertops.UnsafeDynamicAlertingServer
}

Manages all dynamic backend configurations that must interact with & modify the runtime cluster

func NewAlertingOpsNode

func NewAlertingOpsNode(clusterDriver future.Future[drivers.ClusterDriver], opts ...AlertingOpsNodeOption) *AlertingOpsNode

func (*AlertingOpsNode) ApplyConfigToBackend

func (a *AlertingOpsNode) ApplyConfigToBackend(
	ctx context.Context,
	config *routing.RoutingTree,
	internal *routing.OpniInternalRouting,
) error

func (*AlertingOpsNode) ConfigFromBackend

func (a *AlertingOpsNode) ConfigFromBackend(ctx context.Context) (*routing.RoutingTree, *routing.OpniInternalRouting, error)

func (*AlertingOpsNode) ConfigureCluster

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

func (*AlertingOpsNode) Fetch

func (a *AlertingOpsNode) Fetch(ctx context.Context, _ *emptypb.Empty) (*alertops.AlertingConfig, error)

func (*AlertingOpsNode) GetAvailableEndpoint

func (a *AlertingOpsNode) GetAvailableEndpoint(ctx context.Context, options shared.NewAlertingOptions) (string, error)

func (*AlertingOpsNode) GetClusterConfiguration

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

func (*AlertingOpsNode) GetClusterStatus

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

func (*AlertingOpsNode) GetRuntimeOptions

func (a *AlertingOpsNode) GetRuntimeOptions(ctx context.Context) (shared.NewAlertingOptions, error)

func (*AlertingOpsNode) InstallCluster

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

func (*AlertingOpsNode) Reload

func (a *AlertingOpsNode) Reload(ctx context.Context, info *alertops.ReloadInfo) (*emptypb.Empty, error)

func (*AlertingOpsNode) UninstallCluster

func (a *AlertingOpsNode) UninstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*AlertingOpsNode) Update

func (a *AlertingOpsNode) Update(ctx context.Context, config *alertops.AlertingConfig) (*emptypb.Empty, error)

type AlertingOpsNodeOption

type AlertingOpsNodeOption func(*AlertingOpsNodeOptions)

type AlertingOpsNodeOptions

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