influxdb

Documentation

Index

• Constants
• func Connect(configuration map[string]interface{}) (database.Connection, error)
• func GlobalStatsFields(stats *runtime.GlobalStats) map[string]interface{}
• type Config
  • func (c Config) Address() string
  • func (c Config) Database() string
  • func (c Config) Password() string
  • func (c Config) Tags() map[string]interface{}
  • func (c Config) Username() string
• type Connection
  • func (conn *Connection) Close()
  • func (conn *Connection) InsertGlobals(stats *runtime.GlobalStats, time time.Time, site string, domain string)
  • func (conn *Connection) InsertLink(link *runtime.Link, t time.Time)
  • func (conn *Connection) InsertNode(node *runtime.Node)
  • func (conn *Connection) PruneNodes(deleteAfter time.Duration)

Constants

const (
	MeasurementLink               = "link"        // Measurement for per-link statistics
	MeasurementNode               = "node"        // Measurement for per-node statistics
	MeasurementGlobal             = "global"      // Measurement for summarized global statistics
	CounterMeasurementFirmware    = "firmware"    // Measurement for firmware statistics
	CounterMeasurementModel       = "model"       // Measurement for model statistics
	CounterMeasurementAutoupdater = "autoupdater" // Measurement for autoupdater

)

Functions

func Connect

func Connect(configuration map[string]interface{}) (database.Connection, error)

func GlobalStatsFields

func GlobalStatsFields(stats *runtime.GlobalStats) map[string]interface{}

GlobalStatsFields returns fields for InfluxDB

Types

type Config

type Config map[string]interface{}

func (Config) Address

func (c Config) Address() string

func (Config) Database

func (c Config) Database() string

func (Config) Password

func (c Config) Password() string

func (Config) Tags

func (c Config) Tags() map[string]interface{}

func (Config) Username

func (c Config) Username() string

type Connection

type Connection struct {
	database.Connection
	// contains filtered or unexported fields
}

func (*Connection) Close

func (conn *Connection) Close()

Close all connection and clean up

func (*Connection) InsertGlobals

func (conn *Connection) InsertGlobals(stats *runtime.GlobalStats, time time.Time, site string, domain string)

InsertGlobals implementation of database

func (*Connection) InsertLink

func (conn *Connection) InsertLink(link *runtime.Link, t time.Time)

InsertLink adds a link data point

func (*Connection) InsertNode

func (conn *Connection) InsertNode(node *runtime.Node)

InsertNode stores statistics and neighbours in the database

func (*Connection) PruneNodes

func (conn *Connection) PruneNodes(deleteAfter time.Duration)

PruneNodes prunes historical per-node data