influxdb_output

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 22, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	URL               string        `mapstructure:"url,omitempty"`
	Org               string        `mapstructure:"org,omitempty"`
	Bucket            string        `mapstructure:"bucket,omitempty"`
	Token             string        `mapstructure:"token,omitempty"`
	BatchSize         uint          `mapstructure:"batch_size,omitempty"`
	FlushTimer        time.Duration `mapstructure:"flush_timer,omitempty"`
	UseGzip           bool          `mapstructure:"use_gzip,omitempty"`
	EnableTLS         bool          `mapstructure:"enable_tls,omitempty"`
	HealthCheckPeriod time.Duration `mapstructure:"health_check_period,omitempty"`
	Debug             bool          `mapstructure:"debug,omitempty"`
}

type InfluxDBOutput

type InfluxDBOutput struct {
	Cfg *Config
	// contains filtered or unexported fields
}

func (*InfluxDBOutput) Close

func (i *InfluxDBOutput) Close() error

func (*InfluxDBOutput) Init

func (i *InfluxDBOutput) Init(ctx context.Context, cfg map[string]interface{}, logger *log.Logger) error

func (*InfluxDBOutput) Metrics

func (i *InfluxDBOutput) Metrics() []prometheus.Collector

func (*InfluxDBOutput) String

func (k *InfluxDBOutput) String() string

func (*InfluxDBOutput) Write

func (i *InfluxDBOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL