influx

Documentation

Index

• type Config
• type InfluxClient
  • func NewClient(cfg Config) InfluxClient
  • func (c InfluxClient) Write(ctx context.Context, measurement Measurement) error
• type Measurement

Types

type Config

type Config struct {
	Token  string `envconfig:"INFLUX_TOKEN" required:"true"`
	URL    string `envconfig:"INFLUX_URL" required:"true"`
	Org    string `envconfig:"INFLUX_ORG" required:"true"`
	Bucket string `envconfig:"INFLUX_BUCKET" required:"true"`
}

type InfluxClient

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

func NewClient

func NewClient(cfg Config) InfluxClient

func (InfluxClient) Write

func (c InfluxClient) Write(ctx context.Context, measurement Measurement) error

type Measurement

type Measurement struct {
	Name      string
	Type      string
	Value     float64
	Timestamp time.Time
	Tags      map[string]string
}