Documentation ¶
Index ¶
- type MetricsBackend
- func (m *MetricsBackend) AddTarget(_ context.Context, request *remoteread.TargetAddRequest) (*emptypb.Empty, error)
- func (m *MetricsBackend) CanInstall(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
- func (m *MetricsBackend) CancelUninstall(ctx context.Context, cluster *corev1.Reference) (*emptypb.Empty, error)
- func (m *MetricsBackend) ConfigureCluster(ctx context.Context, in *cortexops.ClusterConfiguration) (*emptypb.Empty, error)
- func (m *MetricsBackend) Discover(ctx context.Context, request *remoteread.DiscoveryRequest) (*remoteread.DiscoveryResponse, error)
- func (m *MetricsBackend) EditTarget(ctx context.Context, request *remoteread.TargetEditRequest) (*emptypb.Empty, error)
- func (m *MetricsBackend) GetClusterConfiguration(ctx context.Context, in *emptypb.Empty) (*cortexops.ClusterConfiguration, error)
- func (m *MetricsBackend) GetClusterStatus(ctx context.Context, in *emptypb.Empty) (*cortexops.InstallStatus, error)
- func (m *MetricsBackend) GetTargetStatus(ctx context.Context, request *remoteread.TargetStatusRequest) (*remoteread.TargetStatus, error)
- func (m *MetricsBackend) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)
- func (m *MetricsBackend) Initialize(conf MetricsBackendConfig)
- func (m *MetricsBackend) Install(ctx context.Context, req *capabilityv1.InstallRequest) (*capabilityv1.InstallResponse, error)
- func (m *MetricsBackend) InstallerTemplate(context.Context, *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)
- func (m *MetricsBackend) ListTargets(ctx context.Context, request *remoteread.TargetListRequest) (*remoteread.TargetList, error)
- func (m *MetricsBackend) RemoveTarget(ctx context.Context, request *remoteread.TargetRemoveRequest) (*emptypb.Empty, error)
- func (m *MetricsBackend) Start(ctx context.Context, request *remoteread.StartReadRequest) (*emptypb.Empty, error)
- func (m *MetricsBackend) Status(_ context.Context, req *capabilityv1.StatusRequest) (*capabilityv1.NodeCapabilityStatus, error)
- func (m *MetricsBackend) Stop(ctx context.Context, request *remoteread.StopReadRequest) (*emptypb.Empty, error)
- func (m *MetricsBackend) Sync(ctx context.Context, req *node.SyncRequest) (*node.SyncResponse, error)
- func (m *MetricsBackend) Uninstall(ctx context.Context, req *capabilityv1.UninstallRequest) (*emptypb.Empty, error)
- func (m *MetricsBackend) UninstallCluster(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
- func (m *MetricsBackend) UninstallStatus(_ context.Context, cluster *corev1.Reference) (*corev1.TaskStatus, error)
- type MetricsBackendConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetricsBackend ¶
type MetricsBackend struct { capabilityv1.UnsafeBackendServer node.UnsafeNodeMetricsCapabilityServer cortexops.UnsafeCortexOpsServer remoteread.UnsafeRemoteReadGatewayServer MetricsBackendConfig util.Initializer // contains filtered or unexported fields }
func (*MetricsBackend) AddTarget ¶ added in v0.8.2
func (m *MetricsBackend) AddTarget(_ context.Context, request *remoteread.TargetAddRequest) (*emptypb.Empty, error)
func (*MetricsBackend) CanInstall ¶
func (*MetricsBackend) CancelUninstall ¶
func (*MetricsBackend) ConfigureCluster ¶
func (m *MetricsBackend) ConfigureCluster(ctx context.Context, in *cortexops.ClusterConfiguration) (*emptypb.Empty, error)
func (*MetricsBackend) Discover ¶ added in v0.8.2
func (m *MetricsBackend) Discover(ctx context.Context, request *remoteread.DiscoveryRequest) (*remoteread.DiscoveryResponse, error)
func (*MetricsBackend) EditTarget ¶ added in v0.8.2
func (m *MetricsBackend) EditTarget(ctx context.Context, request *remoteread.TargetEditRequest) (*emptypb.Empty, error)
func (*MetricsBackend) GetClusterConfiguration ¶
func (m *MetricsBackend) GetClusterConfiguration(ctx context.Context, in *emptypb.Empty) (*cortexops.ClusterConfiguration, error)
func (*MetricsBackend) GetClusterStatus ¶
func (m *MetricsBackend) GetClusterStatus(ctx context.Context, in *emptypb.Empty) (*cortexops.InstallStatus, error)
func (*MetricsBackend) GetTargetStatus ¶ added in v0.8.2
func (m *MetricsBackend) GetTargetStatus(ctx context.Context, request *remoteread.TargetStatusRequest) (*remoteread.TargetStatus, error)
func (*MetricsBackend) Info ¶
func (m *MetricsBackend) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)
func (*MetricsBackend) Initialize ¶
func (m *MetricsBackend) Initialize(conf MetricsBackendConfig)
func (*MetricsBackend) Install ¶
func (m *MetricsBackend) Install(ctx context.Context, req *capabilityv1.InstallRequest) (*capabilityv1.InstallResponse, error)
func (*MetricsBackend) InstallerTemplate ¶
func (m *MetricsBackend) InstallerTemplate(context.Context, *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)
func (*MetricsBackend) ListTargets ¶ added in v0.8.2
func (m *MetricsBackend) ListTargets(ctx context.Context, request *remoteread.TargetListRequest) (*remoteread.TargetList, error)
func (*MetricsBackend) RemoveTarget ¶ added in v0.8.2
func (m *MetricsBackend) RemoveTarget(ctx context.Context, request *remoteread.TargetRemoveRequest) (*emptypb.Empty, error)
func (*MetricsBackend) Start ¶ added in v0.8.2
func (m *MetricsBackend) Start(ctx context.Context, request *remoteread.StartReadRequest) (*emptypb.Empty, error)
func (*MetricsBackend) Status ¶
func (m *MetricsBackend) Status(_ context.Context, req *capabilityv1.StatusRequest) (*capabilityv1.NodeCapabilityStatus, error)
func (*MetricsBackend) Stop ¶ added in v0.8.2
func (m *MetricsBackend) Stop(ctx context.Context, request *remoteread.StopReadRequest) (*emptypb.Empty, error)
func (*MetricsBackend) Sync ¶
func (m *MetricsBackend) Sync(ctx context.Context, req *node.SyncRequest) (*node.SyncResponse, error)
func (*MetricsBackend) Uninstall ¶
func (m *MetricsBackend) Uninstall(ctx context.Context, req *capabilityv1.UninstallRequest) (*emptypb.Empty, error)
func (*MetricsBackend) UninstallCluster ¶
func (*MetricsBackend) UninstallStatus ¶
func (m *MetricsBackend) UninstallStatus(_ context.Context, cluster *corev1.Reference) (*corev1.TaskStatus, error)
type MetricsBackendConfig ¶
type MetricsBackendConfig struct { Logger *zap.SugaredLogger `validate:"required"` StorageBackend storage.Backend `validate:"required"` MgmtClient managementv1.ManagementClient `validate:"required"` NodeManagerClient capabilityv1.NodeManagerClient `validate:"required"` UninstallController *task.Controller `validate:"required"` ClusterDriver drivers.ClusterDriver `validate:"required"` Delegate streamext.StreamDelegate[remoteread.RemoteReadAgentClient] `validate:"required"` }
Click to show internal directories.
Click to hide internal directories.