Documentation ¶
Index ¶
- func Scheme(ctx context.Context) meta.Scheme
- type ConfigStorageAPIs
- type Plugin
- func (p *Plugin) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)
- func (p *Plugin) GetGraph(ctx context.Context, ref *corev1.Reference) (*representation.TopologyGraph, error)
- func (p *Plugin) RenderGraph(ctx context.Context, clusterRef *corev1.Reference) (*representation.DOTRepresentation, error)
- func (p *Plugin) StreamServers() []streamext.Server
- func (p *Plugin) UseKeyValueStore(client system.KeyValueStoreClient)
- func (p *Plugin) UseManagementAPI(client managementv1.ManagementClient)
- func (p *Plugin) UseNodeManagerClient(client capabilityv1.NodeManagerClient)
- type TopologyUninstallTaskRunner
- func (n *TopologyUninstallTaskRunner) OnTaskCompleted(ctx context.Context, ti task.ActiveTask, state task.State, args ...any)
- func (n *TopologyUninstallTaskRunner) OnTaskPending(ctx context.Context, ti task.ActiveTask) error
- func (n *TopologyUninstallTaskRunner) OnTaskRunning(ctx context.Context, ti task.ActiveTask) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConfigStorageAPIs ¶
type ConfigStorageAPIs struct { //FIXME: to rename if we find a use Placeholder storage.KeyValueStoreT[proto.Message] }
type Plugin ¶
type Plugin struct { representation.UnsafeTopologyRepresentationServer system.UnimplementedSystemPluginClient // contains filtered or unexported fields }
func (*Plugin) GetClusterStatus ¶
func (p *Plugin) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)
func (*Plugin) GetGraph ¶
func (p *Plugin) GetGraph(ctx context.Context, ref *corev1.Reference) (*representation.TopologyGraph, error)
func (*Plugin) RenderGraph ¶
func (p *Plugin) RenderGraph(ctx context.Context, clusterRef *corev1.Reference) (*representation.DOTRepresentation, error)
func (*Plugin) StreamServers ¶
func (*Plugin) UseKeyValueStore ¶
func (p *Plugin) UseKeyValueStore(client system.KeyValueStoreClient)
func (*Plugin) UseManagementAPI ¶
func (p *Plugin) UseManagementAPI(client managementv1.ManagementClient)
func (*Plugin) UseNodeManagerClient ¶
func (p *Plugin) UseNodeManagerClient(client capabilityv1.NodeManagerClient)
type TopologyUninstallTaskRunner ¶
type TopologyUninstallTaskRunner struct {
// contains filtered or unexported fields
}
func (*TopologyUninstallTaskRunner) OnTaskCompleted ¶
func (n *TopologyUninstallTaskRunner) OnTaskCompleted(ctx context.Context, ti task.ActiveTask, state task.State, args ...any)
func (*TopologyUninstallTaskRunner) OnTaskPending ¶
func (n *TopologyUninstallTaskRunner) OnTaskPending(ctx context.Context, ti task.ActiveTask) error
func (*TopologyUninstallTaskRunner) OnTaskRunning ¶
func (n *TopologyUninstallTaskRunner) OnTaskRunning(ctx context.Context, ti task.ActiveTask) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.