nicmonitor

Documentation

Index

• Constants
• Variables
• type Configuration
  • func ParseFlags() (*Configuration, error)
• type Exporter
  • func NewExporter(cfg *Configuration) *Exporter
  • func (e *Exporter) StartNicMetrics()
• type Monitor
  • func NewNicMonitor(cfg *Configuration) *Monitor
  • func (m *Monitor) StartNicMonitor()
• type NetlinkListener
  • func NewNetlinkListener() (*NetlinkListener, error)
  • func (l *NetlinkListener) ReadMsgs() ([]syscall.NetlinkMessage, error)

Constants

const (
	MONITOR_KEEPALIVE_FAIL  uint32 = 1 << 0
	MONITOR_LINKSTATUS_FAIL uint32 = 1 << 1
)

Variables

var KubeClient *kubernetes.Clientset

Types

type Configuration

type Configuration struct {
	ListenPort      int
	PullInterval    int
	MonitorInterval int
	StasInterval    int
	MetricsPath     string
	KubeConfigFile  string
}

Configuration contains parameters information.

func ParseFlags

func ParseFlags() (*Configuration, error)

ParseFlags get parameters information.

type Exporter

type Exporter struct {
	Hostname string
	// contains filtered or unexported fields
}

func NewExporter

func NewExporter(cfg *Configuration) *Exporter

NewExporter returns an initialized Exporter.

func (*Exporter) StartNicMetrics

func (e *Exporter) StartNicMetrics()

type Monitor

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

func NewNicMonitor

func NewNicMonitor(cfg *Configuration) *Monitor

func (*Monitor) StartNicMonitor

func (m *Monitor) StartNicMonitor()

type NetlinkListener

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

func NewNetlinkListener

func NewNetlinkListener() (*NetlinkListener, error)

func (*NetlinkListener) ReadMsgs

func (l *NetlinkListener) ReadMsgs() ([]syscall.NetlinkMessage, error)