influxdb

Documentation

Index

• func MakeBatchConfig(conf Config) client.BatchPointsConfig
• func MakeClient(conf Config) (client.Client, error)
• type Collector
  • func New(conf Config) (*Collector, error)
  • func (c *Collector) Collect(samples []stats.Sample)
  • func (c *Collector) Init() error
  • func (c *Collector) Link() string
  • func (c *Collector) Run(ctx context.Context)
• type Config
  • func (c Config) Apply(cfg Config) Config
  • func (c Config) MarshalJSON() ([]byte, error)
  • func (c *Config) UnmarshalJSON(data []byte) error
  • func (c *Config) UnmarshalText(text []byte) error
• type ConfigFields

Functions

func MakeBatchConfig

func MakeBatchConfig(conf Config) client.BatchPointsConfig

func MakeClient

func MakeClient(conf Config) (client.Client, error)

Types

type Collector

type Collector struct {
	Client    client.Client
	Config    Config
	BatchConf client.BatchPointsConfig
	// contains filtered or unexported fields
}

func New

func New(conf Config) (*Collector, error)

func (*Collector) Collect

func (c *Collector) Collect(samples []stats.Sample)

func (*Collector) Init

func (c *Collector) Init() error

func (*Collector) Link

func (c *Collector) Link() string

func (*Collector) Run

func (c *Collector) Run(ctx context.Context)

type Config

type Config ConfigFields

func (Config) Apply

func (c Config) Apply(cfg Config) Config

func (Config) MarshalJSON

func (c Config) MarshalJSON() ([]byte, error)

func (*Config) UnmarshalJSON

func (c *Config) UnmarshalJSON(data []byte) error

func (*Config) UnmarshalText

func (c *Config) UnmarshalText(text []byte) error

type ConfigFields

type ConfigFields struct {
	// Connection.
	Addr        string `json:"addr" envconfig:"INFLUXDB_ADDR"`
	Username    string `json:"username,omitempty" envconfig:"INFLUXDB_USERNAME"`
	Password    string `json:"password,omitempty" envconfig:"INFLUXDB_PASSWORD"`
	Insecure    bool   `json:"insecure,omitempty" envconfig:"INFLUXDB_INSECURE"`
	PayloadSize int    `json:"payload_size,omitempty" envconfig:"INFLUXDB_PAYLOAD_SIZE"`

	// Samples.
	DB          string `json:"db" envconfig:"INFLUXDB_DB"`
	Precision   string `json:"precision,omitempty" envconfig:"INFLUXDB_PRECISION"`
	Retention   string `json:"retention,omitempty" envconfig:"INFLUXDB_RETENTION"`
	Consistency string `json:"consistency,omitempty" envconfig:"INFLUXDB_CONSISTENCY"`
}