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(ctx context.Context, empty *emptypb.Empty) (*orchestrator.InstallStatus, error)
  • func (t *TopologyBackend) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.InfoResponse, error)
  • func (t *TopologyBackend) Initialize(conf TopologyBackendConfig)
  • func (t *TopologyBackend) Install(ctx context.Context, req *capabilityv1.InstallRequest) (*capabilityv1.InstallResponse, error)
  • func (t *TopologyBackend) InstallerTemplate(ctx context.Context, empty *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)
  • func (t *TopologyBackend) Status(ctx context.Context, req *capabilityv1.StatusRequest) (*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(ctx 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(ctx context.Context, empty *emptypb.Empty) (*orchestrator.InstallStatus, error)

func (*TopologyBackend) Info

func (t *TopologyBackend) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.InfoResponse, 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(ctx context.Context, empty *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)

! depecrated : agentv1 only

func (*TopologyBackend) Status

func (t *TopologyBackend) Status(ctx context.Context, req *capabilityv1.StatusRequest) (*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(ctx context.Context, cluster *corev1.Reference) (*corev1.TaskStatus, error)

type TopologyBackendConfig

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