Documentation ¶
Index ¶
- func ModelTagsToLabelPairs(tags models.Tags) []*remote.LabelPair
- func ReadRequestToInfluxStorageRequest(req *remote.ReadRequest, db, rp string) (*datatypes.ReadFilterRequest, error)
- func RemoveInfluxSystemTags(tags models.Tags) models.Tags
- func TagsToLabelPairs(tags map[string]string) []*remote.LabelPair
- func WriteRequestToPoints(req *remote.WriteRequest) ([]models.Point, error)
- type DroppedValuesError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ModelTagsToLabelPairs ¶
ModelTagsToLabelPairs converts models.Tags to a slice of Prometheus label pairs
func ReadRequestToInfluxStorageRequest ¶
func ReadRequestToInfluxStorageRequest(req *remote.ReadRequest, db, rp string) (*datatypes.ReadFilterRequest, error)
ReadRequestToInfluxStorageRequest converts a Prometheus remote read request into one using the new storage API that IFQL uses.
func RemoveInfluxSystemTags ¶
RemoveInfluxSystemTags will remove tags that are Influx internal (_measurement and _field)
func TagsToLabelPairs ¶
TagsToLabelPairs converts a map of Influx tags into a slice of Prometheus label pairs
func WriteRequestToPoints ¶
func WriteRequestToPoints(req *remote.WriteRequest) ([]models.Point, error)
WriteRequestToPoints converts a Prometheus remote write request of time series and their samples into Points that can be written into Influx
Types ¶
type DroppedValuesError ¶
type DroppedValuesError struct {
// contains filtered or unexported fields
}
A DroppedValuesError is returned when the prometheus write request contains unsupported float64 values.
func (DroppedValuesError) Error ¶
func (e DroppedValuesError) Error() string
Error returns a descriptive error of the values dropped.