gateway

Documentation

Index

• func Scheme(ctx context.Context) meta.Scheme
• type ConfigStorageAPIs
• type Plugin
  • func NewPlugin(ctx context.Context) *Plugin
  • func (p *Plugin) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)
  • func (p *Plugin) GetGraph(_ context.Context, _ *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) UseStreamClient(cc grpc.ClientConnInterface)
• type TopologyUninstallTaskRunner
  • func (n *TopologyUninstallTaskRunner) OnTaskCompleted(ctx context.Context, ti task.ActiveTask, state task.State, args ...any)
  • func (n *TopologyUninstallTaskRunner) OnTaskPending(_ context.Context, _ task.ActiveTask) error
  • func (n *TopologyUninstallTaskRunner) OnTaskRunning(ctx context.Context, ti task.ActiveTask) error

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

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 NewPlugin

func NewPlugin(ctx context.Context) *Plugin

func (*Plugin) GetClusterStatus

func (p *Plugin) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)

func (*Plugin) GetGraph

func (p *Plugin) GetGraph(_ context.Context, _ *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 (p *Plugin) StreamServers() []streamext.Server

func (*Plugin) UseKeyValueStore

func (p *Plugin) UseKeyValueStore(client system.KeyValueStoreClient)

func (*Plugin) UseManagementAPI

func (p *Plugin) UseManagementAPI(client managementv1.ManagementClient)

func (*Plugin) UseStreamClient

func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)

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(_ context.Context, _ task.ActiveTask) error

func (*TopologyUninstallTaskRunner) OnTaskRunning

func (n *TopologyUninstallTaskRunner) OnTaskRunning(ctx context.Context, ti task.ActiveTask) error