summaryrefslogtreecommitdiffstats
path: root/src/go/collectors/go.d.plugin/modules/isc_dhcpd/init.go
blob: 2261adab1b219c4276a603b8588e3e4aa19dddc1 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
// SPDX-License-Identifier: GPL-3.0-or-later

package isc_dhcpd

import (
	"errors"
	"fmt"

	"github.com/netdata/netdata/go/go.d.plugin/agent/module"
	"github.com/netdata/netdata/go/go.d.plugin/pkg/iprange"
)

type ipPool struct {
	name      string
	addresses iprange.Pool
}

func (d *DHCPd) validateConfig() error {
	if d.Config.LeasesPath == "" {
		return errors.New("'lease_path' parameter not set")
	}
	if len(d.Config.Pools) == 0 {
		return errors.New("'pools' parameter not set")
	}
	for i, cfg := range d.Config.Pools {
		if cfg.Name == "" {
			return fmt.Errorf("'pools[%d]->pool.name' parameter not set", i+1)
		}
		if cfg.Networks == "" {
			return fmt.Errorf("'pools[%d]->pool.networks' parameter not set", i+1)
		}
	}
	return nil
}

func (d *DHCPd) initPools() ([]ipPool, error) {
	var pools []ipPool
	for i, cfg := range d.Pools {
		rs, err := iprange.ParseRanges(cfg.Networks)
		if err != nil {
			return nil, fmt.Errorf("parse pools[%d]->pool.networks '%s' ('%s'): %v", i+1, cfg.Name, cfg.Networks, err)
		}
		if len(rs) != 0 {
			pools = append(pools, ipPool{
				name:      cfg.Name,
				addresses: rs,
			})
		}
	}
	return pools, nil
}

func (d *DHCPd) initCharts(pools []ipPool) (*module.Charts, error) {
	charts := &module.Charts{}

	if err := charts.Add(activeLeasesTotalChart.Copy()); err != nil {
		return nil, err
	}

	chart := poolActiveLeasesChart.Copy()
	if err := charts.Add(chart); err != nil {
		return nil, err
	}
	for _, pool := range pools {
		dim := &module.Dim{
			ID:   "pool_" + pool.name + "_active_leases",
			Name: pool.name,
		}
		if err := chart.AddDim(dim); err != nil {
			return nil, err
		}
	}

	chart = poolUtilizationChart.Copy()
	if err := charts.Add(chart); err != nil {
		return nil, err
	}
	for _, pool := range pools {
		dim := &module.Dim{
			ID:   "pool_" + pool.name + "_utilization",
			Name: pool.name,
			Div:  precision,
		}
		if err := chart.AddDim(dim); err != nil {
			return nil, err
		}
	}

	return charts, nil
}