db

Documentation

Index

• type Influx
  • func NewInflux(config *InfluxConfig) *Influx
  • func (i *Influx) WritePoint(nodeID, nodeDesc string, point data.Point) error
• type InfluxConfig
  • func NodeToInfluxConfig(node data.NodeEdge) (*InfluxConfig, error)

Types

type Influx

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

Influx represents and influxdb that we can write points to

func NewInflux

func NewInflux(config *InfluxConfig) *Influx

NewInflux creates an influx helper client

func (*Influx) WritePoint

func (i *Influx) WritePoint(nodeID, nodeDesc string, point data.Point) error

WritePoint to influxdb

type InfluxConfig

type InfluxConfig struct {
	URL    string
	Token  string
	Org    string
	Bucket string
}

InfluxConfig represents an influxdb config

func NodeToInfluxConfig

func NodeToInfluxConfig(node data.NodeEdge) (*InfluxConfig, error)

NodeToInfluxConfig converts a node to an influx config