drivers

Documentation

Index

• func LogClusterDriverFailure(name string, err error)
• func RegisterClusterDriver(driver ClusterDriver)
• func ResetClusterDrivers()
• type ClusterDriver
  • func GetClusterDriver(name string) (ClusterDriver, error)
• type NoopClusterDriver
  • func (d *NoopClusterDriver) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)
  • func (d *NoopClusterDriver) Name() string
  • func (d *NoopClusterDriver) ShouldDisableNode(*corev1.Reference) error
• type TopologyManager
  • func NewTopologyManagerClusterDriver(opts ...TopologyManagerClusterDriverOption) (*TopologyManager, error)
  • func (t *TopologyManager) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)
  • func (t *TopologyManager) Name() string
  • func (t *TopologyManager) ShouldDisableNode(_ *corev1.Reference) error
• type TopologyManagerClusterDriverOption
  • func WithK8sClient(k8sClient client.Client) TopologyManagerClusterDriverOption
• type TopologyManagerClusterDriverOptions

Functions

func LogClusterDriverFailure

func LogClusterDriverFailure(name string, err error)

func RegisterClusterDriver

func RegisterClusterDriver(driver ClusterDriver)

func ResetClusterDrivers

func ResetClusterDrivers()

Types

type ClusterDriver

type ClusterDriver interface {
	orchestrator.TopologyOrchestratorServer
	// Unique name of the driver
	Name() string
	// ShouldDisableNode is called during node sync for nodes which otherwise
	// have this capability enabled. If this function returns an error, the
	// node will be set to disabled instead, and the error will be logged.
	ShouldDisableNode(*corev1.Reference) error
}

func GetClusterDriver

func GetClusterDriver(name string) (ClusterDriver, error)

type NoopClusterDriver

type NoopClusterDriver struct {
	orchestrator.UnsafeTopologyOrchestratorServer
}

func (*NoopClusterDriver) GetClusterStatus

func (d *NoopClusterDriver) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)

func (*NoopClusterDriver) Name

func (d *NoopClusterDriver) Name() string

func (*NoopClusterDriver) ShouldDisableNode

func (d *NoopClusterDriver) ShouldDisableNode(*corev1.Reference) error

type TopologyManager

type TopologyManager struct {
	*TopologyManagerClusterDriverOptions
	orchestrator.UnsafeTopologyOrchestratorServer
}

func NewTopologyManagerClusterDriver

func NewTopologyManagerClusterDriver(opts ...TopologyManagerClusterDriverOption) (*TopologyManager, error)

func (*TopologyManager) GetClusterStatus

func (t *TopologyManager) GetClusterStatus(_ context.Context, _ *emptypb.Empty) (*orchestrator.InstallStatus, error)

func (*TopologyManager) Name

func (t *TopologyManager) Name() string

func (*TopologyManager) ShouldDisableNode

func (t *TopologyManager) ShouldDisableNode(_ *corev1.Reference) error

type TopologyManagerClusterDriverOption

type TopologyManagerClusterDriverOption func(*TopologyManagerClusterDriverOptions)

func WithK8sClient

func WithK8sClient(k8sClient client.Client) TopologyManagerClusterDriverOption

type TopologyManagerClusterDriverOptions

type TopologyManagerClusterDriverOptions struct {
	// contains filtered or unexported fields
}