influxdb

Documentation

Index

• Constants
• func Connect(configuration map[string]interface{}) (database.Connection, error)
• type Config
  • func (c Config) Address() string
  • func (c Config) Bucket(measurement string) string
  • func (c Config) Organization() string
  • func (c Config) Tags() map[string]string
  • func (c Config) Token() 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
	MeasurementDHCP               = "dhcp"        // Measurement for DHCP server 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)

Types

type Config

type Config map[string]interface{}

func (Config) Address

func (c Config) Address() string

func (Config) Bucket

func (c Config) Bucket(measurement string) string

func (Config) Organization

func (c Config) Organization() string

func (Config) Tags

func (c Config) Tags() map[string]string

func (Config) Token

func (c Config) Token() 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 - not nessasary, juse configurate your influxdb2