daemon

Documentation

Index

• Constants
• Variables
• type Daemon
  • func New(client client.Client, sriovClient snclientset.Interface, ...) *Daemon
  • func (dn *Daemon) Run(stopCh <-chan struct{}, exitCh <-chan error) error
• type EventRecorder
  • func NewEventRecorder(c snclientset.Interface, kubeclient kubernetes.Interface) *EventRecorder
  • func (e *EventRecorder) SendEvent(eventType string, msg string)
  • func (e *EventRecorder) Shutdown()
• type Message
• type NodeStateStatusWriter
  • func NewNodeStateStatusWriter(c snclientset.Interface, f func(), er *EventRecorder, ...) *NodeStateStatusWriter
  • func (w *NodeStateStatusWriter) Run(stop <-chan struct{}, refresh <-chan Message, syncCh chan<- struct{}) error
  • func (w *NodeStateStatusWriter) RunOnce() error

Constants

const (
	CheckpointFileName = "sno-initial-node-state.json"
	Unknown            = "Unknown"
)

Variables

var (
	GenericPlugin     = genericplugin.NewGenericPlugin
	GenericPluginName = genericplugin.PluginName
	VirtualPlugin     = virtualplugin.NewVirtualPlugin
	VirtualPluginName = virtualplugin.PluginName
	K8sPlugin         = k8splugin.NewK8sPlugin
)

var VendorPluginMap = map[string]func(helpers helper.HostHelpersInterface) (plugin.VendorPlugin, error){
	"8086": intelplugin.NewIntelPlugin,
	"15b3": mellanoxplugin.NewMellanoxPlugin,
}

Types

type Daemon

type Daemon struct {
	HostHelpers helper.HostHelpersInterface
	// contains filtered or unexported fields
}

func New

func New(
	client client.Client,
	sriovClient snclientset.Interface,
	kubeClient kubernetes.Interface,
	hostHelpers helper.HostHelpersInterface,
	platformHelper platforms.Interface,
	exitCh chan<- error,
	stopCh <-chan struct{},
	syncCh <-chan struct{},
	refreshCh chan<- Message,
	er *EventRecorder,
	featureGates featuregate.FeatureGate,
	disabledPlugins []string,
) *Daemon

func (*Daemon) Run

func (dn *Daemon) Run(stopCh <-chan struct{}, exitCh <-chan error) error

Run the config daemon

type EventRecorder

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

func NewEventRecorder

func NewEventRecorder(c snclientset.Interface, kubeclient kubernetes.Interface) *EventRecorder

NewEventRecorder Create a new EventRecorder

func (*EventRecorder) SendEvent

func (e *EventRecorder) SendEvent(eventType string, msg string)

SendEvent Send an Event on the NodeState object

func (*EventRecorder) Shutdown

func (e *EventRecorder) Shutdown()

Shutdown Close the EventBroadcaster

type Message

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

type NodeStateStatusWriter

type NodeStateStatusWriter struct {
	OnHeartbeatFailure func()
	// contains filtered or unexported fields
}

func NewNodeStateStatusWriter

func NewNodeStateStatusWriter(c snclientset.Interface,
	f func(), er *EventRecorder,
	hostHelper helper.HostHelpersInterface,
	platformHelper platforms.Interface) *NodeStateStatusWriter

NewNodeStateStatusWriter Create a new NodeStateStatusWriter

func (*NodeStateStatusWriter) Run

func (w *NodeStateStatusWriter) Run(stop <-chan struct{}, refresh <-chan Message, syncCh chan<- struct{}) error

Run reads from the writer channel and sets the interface status. It will return if the stop channel is closed. Intended to be run via a goroutine.

func (*NodeStateStatusWriter) RunOnce

func (w *NodeStateStatusWriter) RunOnce() error

RunOnce initial the interface status for both baremetal and virtual environments