heapsterk8s.io/heapster/common/influxdb Index | Files

package influxdb

import "k8s.io/heapster/common/influxdb"

Index

Variables

var Client = NewFakeInfluxDBClient()
var Config = InfluxdbConfig{
	User:        "root",
	Password:    "root",
	Host:        "localhost:8086",
	DbName:      "k8s",
	Secure:      false,
	Concurrency: 1,
}

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

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
	DisableCounterMetrics bool
	Concurrency           int
}

func BuildConfig

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

type PointSavedToInfluxdb

type PointSavedToInfluxdb struct {
	Ponit influxdb.Point
}

Source Files

dummy_influxdb.go influxdb.go

Version
v1.5.4 (latest)
Published
Jul 26, 2018
Platform
linux/amd64
Imports
8 packages
Last checked
6 hours ago

Tools for package owners.