influxdb_output

Documentation

Index

• type Config
• type InfluxDBOutput
  • func (i *InfluxDBOutput) Close() error
  • func (i *InfluxDBOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, ...) error
  • func (i *InfluxDBOutput) RegisterMetrics(reg *prometheus.Registry)
  • func (i *InfluxDBOutput) SetClusterName(name string)
  • func (i *InfluxDBOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger)
  • func (i *InfluxDBOutput) SetLogger(logger *log.Logger)
  • func (i *InfluxDBOutput) SetName(name string)
  • func (k *InfluxDBOutput) String() string
  • func (i *InfluxDBOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)
  • func (i *InfluxDBOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)

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"`
	EventProcessors   []string      `mapstructure:"event-processors,omitempty"`
	EnableMetrics     bool          `mapstructure:"enable-metrics,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, name string, cfg map[string]interface{}, opts ...outputs.Option) error

func (*InfluxDBOutput) RegisterMetrics

func (i *InfluxDBOutput) RegisterMetrics(reg *prometheus.Registry)

func (*InfluxDBOutput) SetClusterName

func (i *InfluxDBOutput) SetClusterName(name string)

func (*InfluxDBOutput) SetEventProcessors

func (i *InfluxDBOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger)

func (*InfluxDBOutput) SetLogger

func (i *InfluxDBOutput) SetLogger(logger *log.Logger)

func (*InfluxDBOutput) SetName

func (i *InfluxDBOutput) SetName(name string)

func (*InfluxDBOutput) String

func (k *InfluxDBOutput) String() string

func (*InfluxDBOutput) Write

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

func (*InfluxDBOutput) WriteEvent

func (i *InfluxDBOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)