influxdb

Documentation

Index

• Constants
• type Config
  • func NewConfig() Config
  • func (c Config) Validate() error
• type Service
  • func NewService(c Config, hostname string, l *log.Logger) *Service
  • func (s *Service) Addr() string
  • func (s *Service) Close() error
  • func (s *Service) NewClient() (c *client.Client, err error)
  • func (s *Service) Open() error

Constants

const (
	// Maximum time to try and connect to InfluxDB during startup.
	DefaultStartUpTimeout = time.Minute * 5
)

Types

type Config

type Config struct {
	Enabled               bool                `toml:"enabled"`
	URLs                  []string            `toml:"urls"`
	Username              string              `toml:"username"`
	Password              string              `toml:"password"`
	Timeout               toml.Duration       `toml:"timeout"`
	Subscriptions         map[string][]string `toml:"subscriptions"`
	ExcludedSubscriptions map[string][]string `toml:"excluded-subscriptions"`
	UDPBuffer             int                 `toml:"udp-buffer"`
	UDPReadBuffer         int                 `toml:"udp-read-buffer"`
	StartUpTimeout        toml.Duration       `toml:"startup-timeout"`
}

func NewConfig

func NewConfig() Config

func (Config) Validate

func (c Config) Validate() error

type Service

type Service struct {
	PointsWriter interface {
		WritePoints(p *cluster.WritePointsRequest) error
	}
	LogService interface {
		NewLogger(string, int) *log.Logger
	}
	// contains filtered or unexported fields
}

Handles requests to write or read from an InfluxDB cluster

func NewService

func NewService(c Config, hostname string, l *log.Logger) *Service

func (*Service) Addr

func (s *Service) Addr() string

func (*Service) Close

func (s *Service) Close() error

func (*Service) NewClient

func (s *Service) NewClient() (c *client.Client, err error)

func (*Service) Open

func (s *Service) Open() error