influxdb

Documentation

Index

• Constants
• type InfluxDB
  • func NewInfluxDB(srv *server.Server) *InfluxDB
  • func (influxdb *InfluxDB) Init(cfg module.ModuleConfig) error
  • func (influxdb *InfluxDB) IsRunning() bool
  • func (influxdb *InfluxDB) PrerequisiteModules() []string
  • func (influxdb *InfluxDB) Start() error
  • func (influxdb *InfluxDB) Stop() error
• type InfluxDBMetrics
  • func NewInfluxDBMetrics(srv *server.Server) *InfluxDBMetrics
  • func (metrics *InfluxDBMetrics) GetGridEps(ctx context.Context) int
  • func (metrics *InfluxDBMetrics) Init(hostUrl string, token string, org string, bucket string, verifyCert bool, ...) error
  • func (metrics *InfluxDBMetrics) Stop()
  • func (metrics *InfluxDBMetrics) UpdateNodeMetrics(ctx context.Context, node *model.Node) bool

Constants

const DEFAULT_BUCKET = "telegraf"

const DEFAULT_CACHE_EXPIRATION_MS = 60000

const DEFAULT_MAX_METRIC_AGE_SECONDS = 1200

const DEFAULT_ORG = ""

Types

type InfluxDB

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

func NewInfluxDB

func NewInfluxDB(srv *server.Server) *InfluxDB

func (*InfluxDB) Init

func (influxdb *InfluxDB) Init(cfg module.ModuleConfig) error

func (*InfluxDB) IsRunning

func (influxdb *InfluxDB) IsRunning() bool

func (*InfluxDB) PrerequisiteModules

func (influxdb *InfluxDB) PrerequisiteModules() []string

func (*InfluxDB) Start

func (influxdb *InfluxDB) Start() error

func (*InfluxDB) Stop

func (influxdb *InfluxDB) Stop() error

type InfluxDBMetrics

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

func NewInfluxDBMetrics

func NewInfluxDBMetrics(srv *server.Server) *InfluxDBMetrics

func (*InfluxDBMetrics) GetGridEps

func (metrics *InfluxDBMetrics) GetGridEps(ctx context.Context) int

func (*InfluxDBMetrics) Init

func (metrics *InfluxDBMetrics) Init(hostUrl string,
	token string,
	org string,
	bucket string,
	verifyCert bool,
	cacheExpirationMs int,
	maxMetricAgeSeconds int) error

func (*InfluxDBMetrics) Stop

func (metrics *InfluxDBMetrics) Stop()

func (*InfluxDBMetrics) UpdateNodeMetrics

func (metrics *InfluxDBMetrics) UpdateNodeMetrics(ctx context.Context, node *model.Node) bool