monitor

package

v0.2.1 Latest Latest Go to latest Published: Feb 12, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/harvester/node-manager

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func InitServiceMonitor(template *Template, monitorName string) interface{}
func StartsAllMonitors(monitors []interface{})
type CloudInitMonitor
- func NewCloudInitMonitor(ctx context.Context, monitorName, nodeName string, ...) *CloudInitMonitor
type ConfigFileMonitor
- func NewConfigFileMonitor(ctx context.Context, nodecfg ctlv1.NodeConfigController, ...) *ConfigFileMonitor
type Monitor
- func NewCommonMonitor(ctx context.Context, name string) *Monitor
type NTPMessage
type NTPMonitor
- func NewNTPMonitor(ctx context.Context, mtx *sync.Mutex, nodecfg ctlv1.NodeConfigController, ...) *NTPMonitor
type NTPStatusAnnotation
type Template
- func NewMonitorTemplate(ctx context.Context, mtx *sync.Mutex, nodecfg ctlv1.NodeConfigController, ...) *Template

Constants ¶

View Source

const (
	AnnotationNTP = "harvesterhci.io/ntp-service"
	Disabled      = "disabled"
	Unsynced      = "unsynced"
	Synced        = "synced"
	Unknown       = "unknown"
)

View Source

const (
	HarvesterNS = "harvester-system"
)

Variables ¶

View Source

var DefaultNTPCheckInterval = 15 * time.Minute

View Source

var MAXNTPCheckInterval = 24 * 365 * time.Hour

View Source

var NTPSyncTimeout = 45 * time.Minute

NTPSyncTimeout is 45 minutes because the NTPUpdate should be triggered around 30 minutes

Functions ¶

func InitServiceMonitor ¶

func InitServiceMonitor(template *Template, monitorName string) interface{}

func StartsAllMonitors ¶

func StartsAllMonitors(monitors []interface{})

Types ¶

type CloudInitMonitor ¶ added in v0.1.9

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

func NewCloudInitMonitor ¶ added in v0.1.9

func NewCloudInitMonitor(ctx context.Context, monitorName, nodeName string, cloudinits ctrlv1.CloudInitController, nodeCache ctlnodev1.NodeCache) *CloudInitMonitor

type ConfigFileMonitor ¶

type ConfigFileMonitor struct {
	Context        context.Context
	MonitorName    string
	NodeName       string
	MonitorTargets []string

	NodeConfigCtl ctlv1.NodeConfigController
}

func NewConfigFileMonitor ¶

func NewConfigFileMonitor(ctx context.Context, nodecfg ctlv1.NodeConfigController, nodeName, monitorName string) *ConfigFileMonitor

type Monitor ¶

type Monitor struct {
	Context     context.Context
	MonitorName string
}

func NewCommonMonitor ¶

func NewCommonMonitor(ctx context.Context, name string) *Monitor

type NTPMessage ¶

type NTPMessage struct {
	Leap                 uint32
	Version              uint32
	Mode                 uint32
	Stratum              uint32
	Precision            int32
	RootDelay            uint64
	RootDispersion       uint64
	Reference            interface{}
	OriginateTimestamp   uint64
	ReceiveTimestamp     uint64
	TransmitTimestamp    uint64
	DestinationTimestamp uint64
	Ignored              bool
	PacketCount          uint64
	Jitter               uint64
}

type NTPMonitor ¶

type NTPMonitor struct {
	Context           context.Context
	MonitorName       string
	NodeName          string
	NodeNTPAnnotation *NTPStatusAnnotation

	NodeClient    ctlnode.NodeClient
	NodeConfigCtl ctlv1.NodeConfigController
	// contains filtered or unexported fields
}

func NewNTPMonitor ¶

func NewNTPMonitor(ctx context.Context, mtx *sync.Mutex, nodecfg ctlv1.NodeConfigController, nodes ctlnode.NodeController, nodeName, monitorName string) *NTPMonitor

type NTPStatusAnnotation ¶

type NTPStatusAnnotation utils.NTPStatusAnnotation

type Template ¶

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

func NewMonitorTemplate ¶

func NewMonitorTemplate(ctx context.Context, mtx *sync.Mutex, nodecfg ctlv1.NodeConfigController, nodes ctlnode.NodeController, cloudinits ctlv1.CloudInitController, nodeName string) *Template

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL