daemon

Documentation

Index

• Constants
• Variables
• type Daemon
  • func New(nodeName string, client snclientset.Interface, ...) *Daemon
  • func (dn *Daemon) Run(stopCh <-chan struct{}, exitCh <-chan error) error
• type Message
• type NodeStateStatusWriter
  • func NewNodeStateStatusWriter(c snclientset.Interface, n string, f func(), devMode bool) *NodeStateStatusWriter
  • func (w *NodeStateStatusWriter) Run(stop <-chan struct{}, refresh <-chan Message, syncCh chan<- struct{}, ...) error
  • func (w *NodeStateStatusWriter) RunOnce(destDir string, platformType utils.PlatformType) error

Constants

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

Variables

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

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

Types

type Daemon

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

func New

func New(
	nodeName string,
	client snclientset.Interface,
	kubeClient *kubernetes.Clientset,
	mcClient *mcclientset.Clientset,
	exitCh chan<- error,
	stopCh <-chan struct{},
	syncCh <-chan struct{},
	refreshCh chan<- Message,
	platformType utils.PlatformType,
) *Daemon

func (*Daemon) Run

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

Run the config daemon

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, n string, f func(), devMode bool) *NodeStateStatusWriter

NewNodeStateStatusWriter Create a new NodeStateStatusWriter

func (*NodeStateStatusWriter) Run

func (w *NodeStateStatusWriter) Run(stop <-chan struct{}, refresh <-chan Message, syncCh chan<- struct{}, platformType utils.PlatformType) 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(destDir string, platformType utils.PlatformType) error

RunOnce initial the interface status for both baremetal and virtual environments