Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v0.8.2
func (a *AlertingOpsNode) ConnectRemoteSyncer( req *alertops.ConnectRequest, remoteServer alertops.ConfigReconciler_ConnectRemoteSyncerServer, ) error
func (*AlertingOpsNode) GetAvailableCacheEndpoint ¶ added in v0.9.0
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 (*AlertingOpsNode) SendManualSyncRequest ¶ added in v0.8.2
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
}
Click to show internal directories.
Click to hide internal directories.