influxdb

Documentation

Index

• type Config
• type CustomConfig
• type HTTPClient
  • func (p *HTTPClient) FluxDBHttpClose() (err error)
  • func (p *HTTPClient) FluxDBHttpWrite(bp client.BatchPoints) (err error)
• type Metrics
  • func NewMetrics(influxDBHttpClient *HTTPClient, conf *CustomConfig) (*Metrics, error)
  • func (mt *Metrics) AddPoint(metricsData *MetricsData) error
  • func (mt *Metrics) Write() error
• type MetricsData
• type Response

Types

type Config

type Config struct {
	Enable     bool   `yaml:"enable"`
	Address    string `yaml:"address"`
	Port       int    `yaml:"port"`
	UDPAddress string `yaml:"udp_address"`
	Database   string `yaml:"database"`
	// precision: n, u, ms, s, m or h
	Precision           string `yaml:"precision"`
	UserName            string `yaml:"username"`
	Password            string `yaml:"password"`
	MaxIdleConns        int    `yaml:"max-idle-conns"`
	MaxIdleConnsPerHost int    `yaml:"max-idle-conns-per-host"`
	IdleConnTimeout     int    `yaml:"idle-conn-timeout"`
}

type CustomConfig

type CustomConfig struct {
	Enabled    bool   `yaml:"enabled"`
	Address    string `yaml:"address"`
	Port       int    `yaml:"port"`
	UDPAddress string `yaml:"udp_address"`
	Database   string `yaml:"database"`
	// precision: n, u, ms, s, m or h
	Precision           string `yaml:"precision"`
	UserName            string `yaml:"username"`
	Password            string `yaml:"password"`
	ReadUserName        string `yaml:"read-username"`
	ReadPassword        string `yaml:"read-password"`
	MaxIdleConns        int    `yaml:"max-idle-conns"`
	MaxIdleConnsPerHost int    `yaml:"max-idle-conns-per-host"`
	IdleConnTimeout     int    `yaml:"idle-conn-timeout"`
	FlushSize           int    `yaml:"flush-size"`
	FlushTime           int    `yaml:"flush-time"`
}

CustomConfig Custom Configuration

type HTTPClient

type HTTPClient struct {
	Client            client.Client
	BatchPointsConfig client.BatchPointsConfig
}

HTTPClient HTTP Client

func (*HTTPClient) FluxDBHttpClose

func (p *HTTPClient) FluxDBHttpClose() (err error)

FluxDBHttpClose ...

func (*HTTPClient) FluxDBHttpWrite

func (p *HTTPClient) FluxDBHttpWrite(bp client.BatchPoints) (err error)

FluxDBHttpWrite ...

type Metrics

type Metrics struct {
	InfluxDBHttpClient *HTTPClient
	// contains filtered or unexported fields
}

Metrics ...

func NewMetrics

func NewMetrics(influxDBHttpClient *HTTPClient, conf *CustomConfig) (*Metrics, error)

NewMetrics ...

func (*Metrics) AddPoint

func (mt *Metrics) AddPoint(metricsData *MetricsData) error

func (*Metrics) Write

func (mt *Metrics) Write() error

type MetricsData

type MetricsData struct {
	Measurement string                 `json:"measurement"`
	Fields      map[string]interface{} `json:"fields"`
	Tags        map[string]string      `json:"tags"`
}

MetricsData ...

type Response

type Response struct {
	State int      `json:"state"`
	Data  struct{} `json:"data"`
	Msg   string   `json:"msg"`
}

Response ...