Documentation
¶
Index ¶
- type TopologyBackend
- func (t *TopologyBackend) CanInstall(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
- func (t *TopologyBackend) CancelUninstall(ctx context.Context, cluster *corev1.Reference) (*emptypb.Empty, error)
- func (t *TopologyBackend) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)
- func (t *TopologyBackend) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)
- func (t *TopologyBackend) Initialize(conf TopologyBackendConfig)
- func (t *TopologyBackend) Install(ctx context.Context, req *capabilityv1.InstallRequest) (*capabilityv1.InstallResponse, error)
- func (t *TopologyBackend) InstallerTemplate(_ context.Context, _ *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)
- func (t *TopologyBackend) Status(_ context.Context, req *corev1.Reference) (*capabilityv1.NodeCapabilityStatus, error)
- func (t *TopologyBackend) Sync(ctx context.Context, req *node.SyncRequest) (*node.SyncResponse, error)
- func (t *TopologyBackend) Uninstall(ctx context.Context, req *capabilityv1.UninstallRequest) (*emptypb.Empty, error)
- func (t *TopologyBackend) UninstallStatus(_ context.Context, cluster *corev1.Reference) (*corev1.TaskStatus, error)
- type TopologyBackendConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TopologyBackend ¶
type TopologyBackend struct { capabilityv1.UnsafeBackendServer node.UnsafeNodeTopologyCapabilityServer orchestrator.UnsafeTopologyOrchestratorServer TopologyBackendConfig util.Initializer // contains filtered or unexported fields }
func (*TopologyBackend) CanInstall ¶
func (*TopologyBackend) CancelUninstall ¶
func (*TopologyBackend) GetClusterStatus ¶
func (t *TopologyBackend) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)
func (*TopologyBackend) Info ¶
func (t *TopologyBackend) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)
func (*TopologyBackend) Initialize ¶
func (t *TopologyBackend) Initialize(conf TopologyBackendConfig)
func (*TopologyBackend) Install ¶
func (t *TopologyBackend) Install(ctx context.Context, req *capabilityv1.InstallRequest) (*capabilityv1.InstallResponse, error)
func (*TopologyBackend) InstallerTemplate ¶
func (t *TopologyBackend) InstallerTemplate(_ context.Context, _ *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)
! depecrated : agentv1 only
func (*TopologyBackend) Status ¶
func (t *TopologyBackend) Status(_ context.Context, req *corev1.Reference) (*capabilityv1.NodeCapabilityStatus, error)
func (*TopologyBackend) Sync ¶
func (t *TopologyBackend) Sync(ctx context.Context, req *node.SyncRequest) (*node.SyncResponse, error)
func (*TopologyBackend) Uninstall ¶
func (t *TopologyBackend) Uninstall(ctx context.Context, req *capabilityv1.UninstallRequest) (*emptypb.Empty, error)
func (*TopologyBackend) UninstallStatus ¶
func (t *TopologyBackend) UninstallStatus(_ context.Context, cluster *corev1.Reference) (*corev1.TaskStatus, error)
type TopologyBackendConfig ¶
type TopologyBackendConfig struct { Logger *slog.Logger `validate:"required"` StorageBackend storage.Backend `validate:"required"` MgmtClient managementv1.ManagementClient `validate:"required"` Delegate streamext.StreamDelegate[agent.ClientSet] `validate:"required"` UninstallController *task.Controller `validate:"required"` ClusterDriver drivers.ClusterDriver `validate:"required"` }
Click to show internal directories.
Click to hide internal directories.