compatibility.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435
  1. // Copyright 2020-2021 InfluxData, Inc. All rights reserved.
  2. // Use of this source code is governed by MIT
  3. // license that can be found in the LICENSE file.
  4. package influxdb2
  5. import (
  6. "github.com/influxdata/influxdb-client-go/v2/api"
  7. "github.com/influxdata/influxdb-client-go/v2/api/write"
  8. "github.com/influxdata/influxdb-client-go/v2/domain"
  9. "time"
  10. )
  11. // Proxy methods for backward compatibility
  12. // NewPointWithMeasurement creates a empty Point
  13. // Use AddTag and AddField to fill point with data
  14. func NewPointWithMeasurement(measurement string) *write.Point {
  15. return write.NewPointWithMeasurement(measurement)
  16. }
  17. // NewPoint creates a Point from measurement name, tags, fields and a timestamp.
  18. func NewPoint(
  19. measurement string,
  20. tags map[string]string,
  21. fields map[string]interface{},
  22. ts time.Time,
  23. ) *write.Point {
  24. return write.NewPoint(measurement, tags, fields, ts)
  25. }
  26. // DefaultDialect return flux query Dialect with full annotations (datatype, group, default), header and comma char as a delimiter
  27. func DefaultDialect() *domain.Dialect {
  28. return api.DefaultDialect()
  29. }