Documentation
¶
Index ¶
- Variables
- type KVClients
- type MetricsAgentClientSet
- 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(_ context.Context, cluster *corev1.Reference) (*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) GetTargetStatus(ctx context.Context, request *remoteread.TargetStatusRequest) (*remoteread.TargetStatus, error)
- func (m *MetricsBackend) Info(_ context.Context, _ *emptypb.Empty) (*v1.Details, error)
- func (m *MetricsBackend) Initialize(conf MetricsBackendConfig)
- func (m *MetricsBackend) Install(ctx context.Context, req *v1.InstallRequest) (*v1.InstallResponse, error)
- func (m *MetricsBackend) InstallerTemplate(context.Context, *emptypb.Empty) (*v1.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 *corev1.Reference) (*v1.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 *v1.UninstallRequest) (*emptypb.Empty, error)
- func (m *MetricsBackend) UninstallStatus(_ context.Context, cluster *corev1.Reference) (*corev1.TaskStatus, error)
- type MetricsBackendConfig
- type NodeServiceBackend
- func (m *NodeServiceBackend) GetDefaultNodeConfiguration(ctx context.Context, _ *emptypb.Empty) (*node.MetricsCapabilitySpec, error)
- func (m *NodeServiceBackend) GetNodeConfiguration(ctx context.Context, node *corev1.Reference) (*node.MetricsCapabilitySpec, error)
- func (m *NodeServiceBackend) SetDefaultNodeConfiguration(ctx context.Context, conf *node.MetricsCapabilitySpec) (*emptypb.Empty, error)
- func (m *NodeServiceBackend) SetNodeConfiguration(ctx context.Context, req *node.NodeConfigRequest) (*emptypb.Empty, error)
- type OpsServiceBackend
- func (m *OpsServiceBackend) ConfigurationHistory(ctx context.Context, req *driverutil.ConfigurationHistoryRequest) (*cortexops.ConfigurationHistoryResponse, error)
- func (m *OpsServiceBackend) DryRun(ctx context.Context, req *cortexops.DryRunRequest) (*cortexops.DryRunResponse, error)
- func (m *OpsServiceBackend) GetConfiguration(ctx context.Context, in *driverutil.GetRequest) (*cortexops.CapabilityBackendConfigSpec, error)
- func (m *OpsServiceBackend) GetDefaultConfiguration(ctx context.Context, in *driverutil.GetRequest) (*cortexops.CapabilityBackendConfigSpec, error)
- func (m *OpsServiceBackend) Install(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
- func (m *OpsServiceBackend) ListPresets(context.Context, *emptypb.Empty) (*cortexops.PresetList, error)
- func (m *OpsServiceBackend) ResetConfiguration(ctx context.Context, in *cortexops.ResetRequest) (*emptypb.Empty, error)
- func (m *OpsServiceBackend) ResetDefaultConfiguration(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
- func (m *OpsServiceBackend) SetConfiguration(ctx context.Context, in *cortexops.CapabilityBackendConfigSpec) (*emptypb.Empty, error)
- func (m *OpsServiceBackend) SetDefaultConfiguration(ctx context.Context, in *cortexops.CapabilityBackendConfigSpec) (*emptypb.Empty, error)
- func (m *OpsServiceBackend) Status(ctx context.Context, in *emptypb.Empty) (*driverutil.InstallStatus, error)
- func (m *OpsServiceBackend) Uninstall(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // The "default" default node spec. Exported for testing purposes. FallbackDefaultNodeSpec atomic.Pointer[node.MetricsCapabilitySpec] )
Functions ¶
This section is empty.
Types ¶
type KVClients ¶ added in v0.9.2
type KVClients struct { DefaultClusterConfigurationSpec storage.ValueStoreT[*cortexops.CapabilityBackendConfigSpec] DefaultCapabilitySpec storage.ValueStoreT[*node.MetricsCapabilitySpec] NodeCapabilitySpecs storage.KeyValueStoreT[*node.MetricsCapabilitySpec] }
type MetricsAgentClientSet ¶ added in v0.12.0
type MetricsAgentClientSet interface { agent.ClientSet remoteread.RemoteReadAgentClient }
type MetricsBackend ¶
type MetricsBackend struct { capabilityv1.UnsafeBackendServer node.UnsafeNodeMetricsCapabilityServer remoteread.UnsafeRemoteReadGatewayServer MetricsBackendConfig OpsBackend *OpsServiceBackend NodeBackend *NodeServiceBackend 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) 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) GetTargetStatus ¶ added in v0.8.2
func (m *MetricsBackend) GetTargetStatus(ctx context.Context, request *remoteread.TargetStatusRequest) (*remoteread.TargetStatus, error)
func (*MetricsBackend) Initialize ¶
func (m *MetricsBackend) Initialize(conf MetricsBackendConfig)
func (*MetricsBackend) Install ¶
func (m *MetricsBackend) Install(ctx context.Context, req *v1.InstallRequest) (*v1.InstallResponse, error)
func (*MetricsBackend) InstallerTemplate ¶
func (m *MetricsBackend) InstallerTemplate(context.Context, *emptypb.Empty) (*v1.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 *corev1.Reference) (*v1.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)
Implements node.NodeMetricsCapabilityServer
func (*MetricsBackend) Uninstall ¶
func (m *MetricsBackend) Uninstall(ctx context.Context, req *v1.UninstallRequest) (*emptypb.Empty, error)
func (*MetricsBackend) UninstallStatus ¶
func (m *MetricsBackend) UninstallStatus(_ context.Context, cluster *corev1.Reference) (*corev1.TaskStatus, error)
type MetricsBackendConfig ¶
type MetricsBackendConfig struct { Logger *slog.Logger `validate:"required"` StorageBackend storage.Backend `validate:"required"` MgmtClient managementv1.ManagementClient `validate:"required"` UninstallController *task.Controller `validate:"required"` ClusterDriver drivers.ClusterDriver `validate:"required"` Delegate streamext.StreamDelegate[MetricsAgentClientSet] `validate:"required"` KV *KVClients `validate:"required"` }
type NodeServiceBackend ¶ added in v0.12.0
type NodeServiceBackend struct { node.UnsafeNodeConfigurationServer *MetricsBackend }
func (*NodeServiceBackend) GetDefaultNodeConfiguration ¶ added in v0.12.0
func (m *NodeServiceBackend) GetDefaultNodeConfiguration(ctx context.Context, _ *emptypb.Empty) (*node.MetricsCapabilitySpec, error)
func (*NodeServiceBackend) GetNodeConfiguration ¶ added in v0.12.0
func (m *NodeServiceBackend) GetNodeConfiguration(ctx context.Context, node *corev1.Reference) (*node.MetricsCapabilitySpec, error)
func (*NodeServiceBackend) SetDefaultNodeConfiguration ¶ added in v0.12.0
func (m *NodeServiceBackend) SetDefaultNodeConfiguration(ctx context.Context, conf *node.MetricsCapabilitySpec) (*emptypb.Empty, error)
func (*NodeServiceBackend) SetNodeConfiguration ¶ added in v0.12.0
func (m *NodeServiceBackend) SetNodeConfiguration(ctx context.Context, req *node.NodeConfigRequest) (*emptypb.Empty, error)
type OpsServiceBackend ¶ added in v0.12.0
type OpsServiceBackend struct { cortexops.UnsafeCortexOpsServer *MetricsBackend }
func (*OpsServiceBackend) ConfigurationHistory ¶ added in v0.12.0
func (m *OpsServiceBackend) ConfigurationHistory(ctx context.Context, req *driverutil.ConfigurationHistoryRequest) (*cortexops.ConfigurationHistoryResponse, error)
func (*OpsServiceBackend) DryRun ¶ added in v0.12.0
func (m *OpsServiceBackend) DryRun(ctx context.Context, req *cortexops.DryRunRequest) (*cortexops.DryRunResponse, error)
func (*OpsServiceBackend) GetConfiguration ¶ added in v0.12.0
func (m *OpsServiceBackend) GetConfiguration(ctx context.Context, in *driverutil.GetRequest) (*cortexops.CapabilityBackendConfigSpec, error)
func (*OpsServiceBackend) GetDefaultConfiguration ¶ added in v0.12.0
func (m *OpsServiceBackend) GetDefaultConfiguration(ctx context.Context, in *driverutil.GetRequest) (*cortexops.CapabilityBackendConfigSpec, error)
func (*OpsServiceBackend) ListPresets ¶ added in v0.12.0
func (m *OpsServiceBackend) ListPresets(context.Context, *emptypb.Empty) (*cortexops.PresetList, error)
func (*OpsServiceBackend) ResetConfiguration ¶ added in v0.12.0
func (m *OpsServiceBackend) ResetConfiguration(ctx context.Context, in *cortexops.ResetRequest) (*emptypb.Empty, error)
func (*OpsServiceBackend) ResetDefaultConfiguration ¶ added in v0.12.0
func (*OpsServiceBackend) SetConfiguration ¶ added in v0.12.0
func (m *OpsServiceBackend) SetConfiguration(ctx context.Context, in *cortexops.CapabilityBackendConfigSpec) (*emptypb.Empty, error)
func (*OpsServiceBackend) SetDefaultConfiguration ¶ added in v0.12.0
func (m *OpsServiceBackend) SetDefaultConfiguration(ctx context.Context, in *cortexops.CapabilityBackendConfigSpec) (*emptypb.Empty, error)
func (*OpsServiceBackend) Status ¶ added in v0.12.0
func (m *OpsServiceBackend) Status(ctx context.Context, in *emptypb.Empty) (*driverutil.InstallStatus, error)
Click to show internal directories.
Click to hide internal directories.