influxdb

Documentation

Index

• Variables
• type FakeInfluxDBClient
  • func NewFakeInfluxDBClient() *FakeInfluxDBClient
  • func (client *FakeInfluxDBClient) Ping() (time.Duration, string, error)
  • func (client *FakeInfluxDBClient) Query(q influxdb.Query) (*influxdb.Response, error)
  • func (client *FakeInfluxDBClient) Write(bps influxdb.BatchPoints) (*influxdb.Response, error)
• type InfluxdbClient
  • func NewClient(c InfluxdbConfig) (InfluxdbClient, error)
• type InfluxdbConfig
  • func BuildConfig(uri *url.URL) (*InfluxdbConfig, error)
• type PointSavedToInfluxdb

Variables

var Client = NewFakeInfluxDBClient()

var Config = InfluxdbConfig{
	User:     "root",
	Password: "root",
	Host:     "localhost:8086",
	DbName:   "k8s",
	Secure:   false,
}

Types

type FakeInfluxDBClient

type FakeInfluxDBClient struct {
	Pnts []PointSavedToInfluxdb
}

func NewFakeInfluxDBClient

func NewFakeInfluxDBClient() *FakeInfluxDBClient

func (*FakeInfluxDBClient) Ping

func (client *FakeInfluxDBClient) Ping() (time.Duration, string, error)

func (*FakeInfluxDBClient) Query

func (client *FakeInfluxDBClient) Query(q influxdb.Query) (*influxdb.Response, error)

func (*FakeInfluxDBClient) Write

func (client *FakeInfluxDBClient) Write(bps influxdb.BatchPoints) (*influxdb.Response, error)

type InfluxdbClient

type InfluxdbClient interface {
	Write(influxdb.BatchPoints) (*influxdb.Response, error)
	Query(influxdb.Query) (*influxdb.Response, error)
	Ping() (time.Duration, string, error)
}

func NewClient

func NewClient(c InfluxdbConfig) (InfluxdbClient, error)

type InfluxdbConfig

type InfluxdbConfig struct {
	User            string
	Password        string
	Secure          bool
	Host            string
	DbName          string
	WithFields      bool
	InsecureSsl     bool
	RetentionPolicy string
	ClusterName     string
}

func BuildConfig

func BuildConfig(uri *url.URL) (*InfluxdbConfig, error)

type PointSavedToInfluxdb

type PointSavedToInfluxdb struct {
	Ponit influxdb.Point
}