monitor

Documentation

Index

• Variables
• func CreateConfigMap(fs utils.FileSystem, devices []appv1alpha1.SerialDevice2) (*corev1.ConfigMap, error)
• func CreateDaemonSet(fs utils.FileSystem) (*appsv1.DaemonSet, error)
• type Monitor
  • func NewMonitor(clientSet client.Interface, clientsetKubeserial versioned.Interface, ...) *Monitor
  • func (m *Monitor) RunUpdateLoop(ctx context.Context)
  • func (m *Monitor) UpdateDeviceState(ctx context.Context)

Variables

var DevicesMonitored = prometheus.NewGauge(prometheus.GaugeOpts{
	Name: "devices_monitored",
	Help: "Total number of devices monitored",
})

var ErrNoCondition = errors.New("can't find device condition")

Functions

func CreateConfigMap

func CreateConfigMap(fs utils.FileSystem, devices []appv1alpha1.SerialDevice2) (*corev1.ConfigMap, error)

func CreateDaemonSet

func CreateDaemonSet(fs utils.FileSystem) (*appsv1.DaemonSet, error)

Types

type Monitor

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

func NewMonitor

func NewMonitor(
	clientSet client.Interface,
	clientsetKubeserial versioned.Interface,
	namespace string,
	nodeName string,
	fs utils.FileSystem,
) *Monitor

func (*Monitor) RunUpdateLoop

func (m *Monitor) RunUpdateLoop(ctx context.Context)

func (*Monitor) UpdateDeviceState

func (m *Monitor) UpdateDeviceState(ctx context.Context)