drivers

Documentation

Index

• func LogNodeDriverFailure(name string, err error)
• func NewListenerFunc(ctx context.Context, fn func(cfg *node.TopologyCapabilityConfig)) chan<- *node.TopologyCapabilityConfig
• func RegisterNodeDriver(driver TopologyNodeDriver)
• func ResetNodeDrivers()
• type ExternalTopologyOperatorDriver
  • func NewExternalTopologyOperatorDriver(logger *zap.SugaredLogger, opts ...ExternalTopologyOperatorDriverOption) (*ExternalTopologyOperatorDriver, error)
  • func (t *ExternalTopologyOperatorDriver) ConfigureNode(conf *node.TopologyCapabilityConfig)
  • func (t *ExternalTopologyOperatorDriver) Name() string
• type ExternalTopologyOperatorDriverOption
  • func WithK8sClient(k8sClient client.Client) ExternalTopologyOperatorDriverOption
• type ExternalTopologyOperatorDriverOptions
• type TopologyNodeDriver
  • func GetNodeDriver(name string) (TopologyNodeDriver, error)

Functions

func LogNodeDriverFailure

func LogNodeDriverFailure(name string, err error)

func NewListenerFunc

func NewListenerFunc(ctx context.Context, fn func(cfg *node.TopologyCapabilityConfig)) chan<- *node.TopologyCapabilityConfig

func RegisterNodeDriver

func RegisterNodeDriver(driver TopologyNodeDriver)

func ResetNodeDrivers

func ResetNodeDrivers()

Types

type ExternalTopologyOperatorDriver

type ExternalTopologyOperatorDriver struct {
	ExternalTopologyOperatorDriverOptions
	// contains filtered or unexported fields
}

func NewExternalTopologyOperatorDriver

func NewExternalTopologyOperatorDriver(
	logger *zap.SugaredLogger,
	opts ...ExternalTopologyOperatorDriverOption,
) (*ExternalTopologyOperatorDriver, error)

func (*ExternalTopologyOperatorDriver) ConfigureNode

func (t *ExternalTopologyOperatorDriver) ConfigureNode(conf *node.TopologyCapabilityConfig)

func (*ExternalTopologyOperatorDriver) Name

func (t *ExternalTopologyOperatorDriver) Name() string

type ExternalTopologyOperatorDriverOption

type ExternalTopologyOperatorDriverOption func(*ExternalTopologyOperatorDriverOptions)

func WithK8sClient

func WithK8sClient(k8sClient client.Client) ExternalTopologyOperatorDriverOption

type ExternalTopologyOperatorDriverOptions

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

type TopologyNodeDriver

type TopologyNodeDriver interface {
	Name() string
	ConfigureNode(*node.TopologyCapabilityConfig)
}

func GetNodeDriver

func GetNodeDriver(name string) (TopologyNodeDriver, error)