backend

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

Types

type TopologyBackend

type TopologyBackend struct {
	capabilityv1.UnsafeBackendServer
	node.UnsafeNodeTopologyCapabilityServer
	orchestrator.UnsafeTopologyOrchestratorServer
	TopologyBackendConfig

	util.Initializer
	// contains filtered or unexported fields
}

func (*TopologyBackend) CanInstall

func (t *TopologyBackend) CanInstall(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*TopologyBackend) CancelUninstall

func (t *TopologyBackend) CancelUninstall(ctx context.Context, cluster *corev1.Reference) (*emptypb.Empty, error)

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"`
}