Documentation ¶
Overview ¶
Package opentsdb provides a service for InfluxDB to ingest data via the opentsdb protocol.
Index ¶
Constants ¶
const ( // DefaultBindAddress is the default address that the service binds to. DefaultBindAddress = ":4242" // DefaultDatabase is the default database used for writes. DefaultDatabase = "opentsdb" // DefaultRetentionPolicy is the default retention policy used for writes. DefaultRetentionPolicy = "" // DefaultConsistencyLevel is the default write consistency level. DefaultConsistencyLevel = "one" // DefaultBatchSize is the default OpenTSDB batch size. DefaultBatchSize = 1000 // DefaultBatchTimeout is the default OpenTSDB batch timeout. DefaultBatchTimeout = time.Second // DefaultBatchPending is the default number of batches that can be in the queue. DefaultBatchPending = 5 // DefaultCertificate is the default location of the certificate used when TLS is enabled. DefaultCertificate = "/etc/ssl/influxdb.pem" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Enabled bool `toml:"enabled"` BindAddress string `toml:"bind-address"` Database string `toml:"database"` RetentionPolicy string `toml:"retention-policy"` ConsistencyLevel string `toml:"consistency-level"` TLSEnabled bool `toml:"tls-enabled"` Certificate string `toml:"certificate"` BatchSize int `toml:"batch-size"` BatchPending int `toml:"batch-pending"` BatchTimeout toml.Duration `toml:"batch-timeout"` LogPointErrors bool `toml:"log-point-errors"` TLS *tls.Config `toml:"-"` }
Config represents the configuration of the OpenTSDB service.
func (*Config) WithDefaults ¶
WithDefaults takes the given config and returns a new config with any required default values set.
type Configs ¶ added in v1.3.0
type Configs []Config
Configs wraps a slice of Config to aggregate diagnostics.
func (Configs) Diagnostics ¶ added in v1.3.0
func (c Configs) Diagnostics() (*diagnostics.Diagnostics, error)
Diagnostics returns one set of diagnostics for all of the Configs.
type Handler ¶
type Handler struct { Database string RetentionPolicy string PointsWriter interface { WritePointsPrivileged(ctx tsdb.WriteContext, database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, points []models.Point) error } Logger *zap.Logger // contains filtered or unexported fields }
Handler is an http.Handler for the OpenTSDB service.
type Service ¶
type Service struct { BindAddress string Database string RetentionPolicy string PointsWriter interface { WritePointsPrivileged(ctx tsdb.WriteContext, database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, points []models.Point) error } MetaClient interface { CreateDatabase(name string) (*meta.DatabaseInfo, error) } LogPointErrors bool Logger *zap.Logger // contains filtered or unexported fields }
Service manages the listener and handler for an HTTP endpoint.
func NewService ¶
NewService returns a new instance of Service.
func (*Service) Statistics ¶ added in v1.0.0
Statistics returns statistics for periodic monitoring.
func (*Service) WithLogger ¶ added in v1.2.0
WithLogger sets the logger for the service.
type Statistics ¶ added in v1.0.0
type Statistics struct { HTTPConnectionsHandled int64 ActiveTelnetConnections int64 HandledTelnetConnections int64 TelnetPointsReceived int64 TelnetBytesReceived int64 TelnetReadError int64 TelnetBadLine int64 TelnetBadTime int64 TelnetBadTag int64 TelnetBadFloat int64 BatchesTransmitted int64 PointsTransmitted int64 BatchesTransmitFail int64 ActiveConnections int64 HandledConnections int64 InvalidDroppedPoints int64 }
Statistics maintains statistics for the subscriber service.