MetricsInflux

Documentation

Index

• func NewInflux(serviceName shared.ServiceName, config *InfluxConfig) (metrics.MetricsInterface, error)
• type Influx
  • func (i *Influx) Connect() error
  • func (i *Influx) LogPoint(point metrics.MetricPoint, values metrics.MetricValues)
• type InfluxConfig
  • func (c *InfluxConfig) GetAddress() string

Functions

func NewInflux

func NewInflux(serviceName shared.ServiceName, config *InfluxConfig) (metrics.MetricsInterface, error)

Types

type Influx

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

func (*Influx) Connect

func (i *Influx) Connect() error

func (*Influx) LogPoint

func (i *Influx) LogPoint(point metrics.MetricPoint, values metrics.MetricValues)

type InfluxConfig

type InfluxConfig struct {
	Host string `config:"INFLUXDB_HOST" default:"localhost"`
	Port int    `config:"INFLUXDB_PORT" default:"8086"`

	Token        shared.Secret `config:"INFLUXDB_TOKEN"`
	Organization string        `config:"INFLUXDB_ORG"`
	Bucket       string        `config:"INFLUXDB_BUCKET"`
}

func (*InfluxConfig) GetAddress

func (c *InfluxConfig) GetAddress() string