influxdb

Documentation

Index

• type Config
• type InfluxDB
  • func CreateFromConfig(ctx *context.Context) (*InfluxDB, error)
  • func (i *InfluxDB) CarChannel() chan<- state.CarState
  • func (i InfluxDB) Process()
  • func (i *InfluxDB) RaceChannel() chan<- state.CourseState

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 *context.Context) (*InfluxDB, error)

func (*InfluxDB) CarChannel

func (i *InfluxDB) CarChannel() chan<- state.CarState

func (InfluxDB) Process

func (i InfluxDB) Process()

func (*InfluxDB) RaceChannel

func (i *InfluxDB) RaceChannel() chan<- state.CourseState