public_git
/
unpoller_unpoller
mirror of https://github.com/unpoller/unpoller.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Allign all points.

This commit is contained in:
David Newhall II 2019-07-14 02:38:16 -07:00
parent 3e1b67808a
commit c847a5a8cc
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
integrations/inputunifi/unifipoller/config.go
View File

@ -42,6 +42,7 @@ type UnifiPoller struct {
// Metrics contains all the data from the controller and an influx endpoint to send it to. // Metrics contains all the data from the controller and an influx endpoint to send it to.
type Metrics struct { type Metrics struct {
TS time.Time
unifi.Sites unifi.Sites
unifi.IDSList unifi.IDSList
unifi.Clients unifi.Clients

4
integrations/inputunifi/unifipoller/unifi.go
View File

@ -78,7 +78,7 @@ func (u *UnifiPoller) CollectAndReport() error {
// CollectMetrics grabs all the measurements from a UniFi controller and returns them. // CollectMetrics grabs all the measurements from a UniFi controller and returns them.
// This also creates an InfluxDB writer, and returns an error if that fails. // This also creates an InfluxDB writer, and returns an error if that fails.
func (u *UnifiPoller) CollectMetrics() (*Metrics, error) { func (u *UnifiPoller) CollectMetrics() (*Metrics, error) {
m := &Metrics{} m := &Metrics{TS: time.Now()}
var err error var err error
// Get the sites we care about. // Get the sites we care about.
m.Sites, err = u.GetFilteredSites() m.Sites, err = u.GetFilteredSites()
@ -188,7 +188,7 @@ func (m *Metrics) processPoints(asset Asset) error {
if asset == nil { if asset == nil {
return nil return nil
} }
points, err := asset.Points() points, err := asset.PointsAt(m.TS)
if err != nil || points == nil { if err != nil || points == nil {
return err return err
} }