ops

Documentation

Index

• type AlertingOpsNode
  • func NewAlertingOpsNode(ctx context.Context, clusterDriver future.Future[drivers.ClusterDriver], ...) *AlertingOpsNode
  • func (a *AlertingOpsNode) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)
  • func (a *AlertingOpsNode) ConnectRemoteSyncer(req *alertops.ConnectRequest, ...) error
  • func (a *AlertingOpsNode) GetAvailableCacheEndpoint(ctx context.Context, options *shared.AlertingClusterOptions) (string, error)
  • func (a *AlertingOpsNode) GetAvailableEndpoint(ctx context.Context, options *shared.AlertingClusterOptions) (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.AlertingClusterOptions, error)
  • func (a *AlertingOpsNode) InstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (a *AlertingOpsNode) SendManualSyncRequest(ctx context.Context, routerKeys []string, routers storage.RouterStorage)
  • func (a *AlertingOpsNode) UninstallCluster(ctx context.Context, req *alertops.UninstallRequest) (*emptypb.Empty, error)
• type AlertingOpsNodeOption
• type AlertingOpsNodeOptions

Types

type AlertingOpsNode

type AlertingOpsNode struct {
	alertops.UnsafeAlertingAdminServer
	alertops.UnsafeConfigReconcilerServer

	AlertingOpsNodeOptions

	*shared.AlertingClusterOptions

	ClusterDriver future.Future[drivers.ClusterDriver]
	// contains filtered or unexported fields
}

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

func NewAlertingOpsNode

func NewAlertingOpsNode(
	ctx context.Context,
	clusterDriver future.Future[drivers.ClusterDriver],
	storageClientSet future.Future[storage.AlertingClientSet],
	opts ...AlertingOpsNodeOption) *AlertingOpsNode

func (*AlertingOpsNode) ConfigureCluster

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

func (*AlertingOpsNode) ConnectRemoteSyncer

func (a *AlertingOpsNode) ConnectRemoteSyncer(
	req *alertops.ConnectRequest,
	remoteServer alertops.ConfigReconciler_ConnectRemoteSyncerServer,
) error

func (*AlertingOpsNode) GetAvailableCacheEndpoint

func (a *AlertingOpsNode) GetAvailableCacheEndpoint(ctx context.Context, options *shared.AlertingClusterOptions) (string, error)

func (*AlertingOpsNode) GetAvailableEndpoint

func (a *AlertingOpsNode) GetAvailableEndpoint(ctx context.Context, options *shared.AlertingClusterOptions) (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.AlertingClusterOptions, error)

func (*AlertingOpsNode) InstallCluster

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

func (*AlertingOpsNode) SendManualSyncRequest

func (a *AlertingOpsNode) SendManualSyncRequest(
	ctx context.Context,
	routerKeys []string,
	routers storage.RouterStorage,
)

routerKeys correspond to the global key or tenant-ed keys

func (*AlertingOpsNode) UninstallCluster

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

type AlertingOpsNodeOption

type AlertingOpsNodeOption func(*AlertingOpsNodeOptions)

type AlertingOpsNodeOptions

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