backend

package
v0.12.1-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 10, 2023 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

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 (m *MetricsBackend) CanInstall(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*MetricsBackend) CancelUninstall 

func (m *MetricsBackend) CancelUninstall(_ context.Context, cluster *corev1.Reference) (*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) 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) (*v1.Details, 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) Install added in v0.12.0 

func (m *OpsServiceBackend) Install(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, 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 (m *OpsServiceBackend) ResetDefaultConfiguration(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)

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)

func (*OpsServiceBackend) Uninstall added in v0.12.0 

func (m *OpsServiceBackend) Uninstall(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.