package influxdb
import "k8s.io/heapster/common/influxdb"
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
- type InfluxdbConfig
- type PointSavedToInfluxdb
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 (*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 DisableCounterMetrics bool Concurrency int }
func BuildConfig ¶
func BuildConfig(uri *url.URL) (*InfluxdbConfig, error)
type PointSavedToInfluxdb ¶
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.