influxdb

type Config struct {
	Enabled  bool     `toml:"enabled"`
	Name     string   `toml:"name"`
	Default  bool     `toml:"default"`
	URLs     []string `toml:"urls"`
	Username string   `toml:"username"`
	Password string   `toml:"password"`
	// Path to CA file
	SSLCA string `toml:"ssl-ca"`
	// Path to host cert file
	SSLCert string `toml:"ssl-cert"`
	// Path to cert key file
	SSLKey string `toml:"ssl-key"`
	// Use SSL but skip chain & host verification
	InsecureSkipVerify bool `toml:"insecure-skip-verify"`

	Timeout                  toml.Duration       `toml:"timeout"`
	DisableSubscriptions     bool                `toml:"disable-subscriptions"`
	SubscriptionProtocol     string              `toml:"subscription-protocol"`
	Subscriptions            map[string][]string `toml:"subscriptions"`
	ExcludedSubscriptions    map[string][]string `toml:"excluded-subscriptions"`
	UDPBind                  string              `toml:"udp-bind"`
	UDPBuffer                int                 `toml:"udp-buffer"`
	UDPReadBuffer            int                 `toml:"udp-read-buffer"`
	StartUpTimeout           toml.Duration       `toml:"startup-timeout"`
	SubscriptionSyncInterval toml.Duration       `toml:"subscriptions-sync-interval"`
}

type Service struct {
	PointsWriter interface {
		WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, points []models.Point) error
	}
	LogService interface {
		NewLogger(string, int) *log.Logger
	}
	HTTPDService interface {
		AddRoutes([]httpd.Route) error
		DelRoutes([]httpd.Route)
	}
	ClientCreator interface {
		Create(influxdb.HTTPConfig) (influxdb.Client, error)
	}
	AuthService interface {
		GrantSubscriptionAccess(token, db, rp string) error
		ListSubscriptionTokens() ([]string, error)
		RevokeSubscriptionAccess(token string) error
	}
	RandReader io.Reader
	// contains filtered or unexported fields
}