influxdb

Documentation

Index

• type Config
• type InfluxDB
  • func CreateFromConfig(ctx *application.Context) (*InfluxDB, error)
  • func (i *InfluxDB) Configure(observable rxgo.Observable)
  • func (i InfluxDB) Process()

Types

type Config

type Config struct {
	Postprocessors struct {
		InfluxDB struct {
			Url          string `mapstructure:"url"`
			BatchSize    uint   `mapstructure:"batch-size"`
			AuthToken    string `mapstructure:"auth-token"`
			Organization string `mapstructure:"organization"`
			Bucket       string `mapstructure:"bucket"`
		} `mapstructure:"influxdb"`
	} `mapstructure:"postprocessors"`
}

type InfluxDB

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

func CreateFromConfig

func CreateFromConfig(ctx *application.Context) (*InfluxDB, error)

func (*InfluxDB) Configure

func (i *InfluxDB) Configure(observable rxgo.Observable)

func (InfluxDB) Process

func (i InfluxDB) Process()