[db] Add meta back to client interface

- it is needed by generator in xephon-b

Author: at15

database/akumuli/client/pkg.go

@@ -1,10 +1,25 @@
 package client
 
 import (
+	"github.com/libtsdb/libtsdb-go/database"
+	"github.com/libtsdb/libtsdb-go/database/akumuli"
 	"github.com/libtsdb/libtsdb-go/database/akumuli/config"
 	"github.com/libtsdb/libtsdb-go/protocol"
 )
 
-func NewAkumuliClient(cfg config.AkumuliClientConfig) (*protocol.TCPClient, error) {
-	return protocol.NewTCPClient(NewAkumuliEncoder(), cfg.Addr, cfg.Timeout)
+type AkumuliClient struct {
+	*protocol.TCPClient
+	meta database.Meta
+}
+
+func (c *AkumuliClient) Meta() database.Meta {
+	return c.meta
+}
+
+func NewAkumuliClient(cfg config.AkumuliClientConfig) (*AkumuliClient, error) {
+	p, err := protocol.NewTCPClient(NewAkumuliEncoder(), cfg.Addr, cfg.Timeout)
+	if err != nil {
+		return nil, err
+	}
+	return &AkumuliClient{TCPClient: p, meta: akumuli.Meta()}, nil
 }

database/akumuli/meta.go

@@ -0,0 +1,30 @@
+package akumuli
+
+import (
+	"time"
+
+	"github.com/libtsdb/libtsdb-go/database"
+)
+
+const (
+	name      = "akumuli"
+	precision = time.Nanosecond
+)
+
+var meta = database.Meta{
+	Name:               name,
+	TimePrecision:      time.Nanosecond,
+	SupportTag:         true,
+	SupportInt:         true, // TODO: the protocol support int, but is it stored as float?
+	SupportDouble:      true,
+	SupportBatchSeries: true,
+	SupportBatchPoints: false,
+}
+
+func Meta() database.Meta {
+	return meta
+}
+
+func init() {
+	database.RegisterMeta(name, meta)
+}

database/client.go

@@ -9,6 +9,7 @@ import (
 
 // TSBClient returns meta of the database including its protocol, data type support
 type TSDBClient interface {
+	Meta() Meta
 	Close() error
 }
 

database/influxdb/client/pkg.go

@@ -5,11 +5,22 @@ import (
 	"net/url"
 
 	"github.com/dyweb/gommon/errors"
+	"github.com/libtsdb/libtsdb-go/database"
+	"github.com/libtsdb/libtsdb-go/database/influxdb"
 	"github.com/libtsdb/libtsdb-go/database/influxdb/config"
 	"github.com/libtsdb/libtsdb-go/protocol"
 )
 
-func NewInfluxDBClient(cfg config.InfluxdbClientConfig) (*protocol.HTTPClient, error) {
+type InfluxDBClient struct {
+	*protocol.HTTPClient
+	meta database.Meta
+}
+
+func (c *InfluxDBClient) Meta() database.Meta {
+	return c.meta
+}
+
+func NewInfluxDBClient(cfg config.InfluxdbClientConfig) (*InfluxDBClient, error) {
 	u, err := url.Parse(cfg.Addr)
 	if err != nil {
 		return nil, errors.Wrap(err, "can't parse server address")
@@ -23,5 +34,5 @@ func NewInfluxDBClient(cfg config.InfluxdbClientConfig) (*protocol.HTTPClient, e
 	baseReq.URL.RawQuery = params.Encode()
 	baseReq.Header.Set("User-Agent", "libtsdb")
 	c := protocol.NewHTTPClient(NewInfluxDBEncoder(), baseReq)
-	return c, nil
+	return &InfluxDBClient{HTTPClient: c, meta: influxdb.Meta()}, nil
 }

database/influxdb/meta.go

@@ -0,0 +1,30 @@
+package influxdb
+
+import (
+	"time"
+
+	"github.com/libtsdb/libtsdb-go/database"
+)
+
+const (
+	name      = "influxdb"
+	precision = time.Nanosecond
+)
+
+var meta = database.Meta{
+	Name:               name,
+	TimePrecision:      precision,
+	SupportTag:         true,
+	SupportInt:         true,
+	SupportDouble:      true,
+	SupportBatchSeries: true,
+	SupportBatchPoints: false,
+}
+
+func Meta() database.Meta {
+	return meta
+}
+
+func init() {
+	database.RegisterMeta(name, meta)
+}

database/kairosdb/client/pkg.go

@@ -5,11 +5,31 @@ import (
 	"net/url"
 
 	"github.com/dyweb/gommon/errors"
+	"github.com/libtsdb/libtsdb-go/database"
+	"github.com/libtsdb/libtsdb-go/database/kairosdb"
 	"github.com/libtsdb/libtsdb-go/database/kairosdb/config"
 	"github.com/libtsdb/libtsdb-go/protocol"
 )
 
-func NewKairosDBHTTPClient(cfg config.KairosdbClientConfig) (*protocol.HTTPClient, error) {
+type KairosDBHTTPClient struct {
+	*protocol.HTTPClient
+	meta database.Meta
+}
+
+func (c *KairosDBHTTPClient) Meta() database.Meta {
+	return c.meta
+}
+
+type KairosDBTCPCLient struct {
+	*protocol.TCPClient
+	meta database.Meta
+}
+
+func (c *KairosDBTCPCLient) Meta() database.Meta {
+	return c.meta
+}
+
+func NewKairosDBHTTPClient(cfg config.KairosdbClientConfig) (*KairosDBHTTPClient, error) {
 	u, err := url.Parse(cfg.Addr)
 	if err != nil {
 		return nil, errors.Wrap(err, "can't parse server address")
@@ -19,9 +39,13 @@ func NewKairosDBHTTPClient(cfg config.KairosdbClientConfig) (*protocol.HTTPClien
 		return nil, errors.Wrap(err, "can't create base query")
 	}
 	c := protocol.NewHTTPClient(NewKairosDBJSONEncoder(), baseReq)
-	return c, nil
+	return &KairosDBHTTPClient{HTTPClient: c, meta: kairosdb.Meta()}, nil
 }
 
-func NewKairosDBTCPClient(cfg config.KairosdbClientConfig) (*protocol.TCPClient, error) {
-	return protocol.NewTCPClient(NewKaiorsDBTelnetEncoder(), cfg.TelnetAddr, cfg.Timeout)
+func NewKairosDBTCPClient(cfg config.KairosdbClientConfig) (*KairosDBTCPCLient, error) {
+	p, err := protocol.NewTCPClient(NewKaiorsDBTelnetEncoder(), cfg.TelnetAddr, cfg.Timeout)
+	if err != nil {
+		return nil, err
+	}
+	return &KairosDBTCPCLient{TCPClient: p, meta: kairosdb.Meta()}, nil
 }

database/kairosdb/meta.go

@@ -0,0 +1,30 @@
+package kairosdb
+
+import (
+	"time"
+
+	"github.com/libtsdb/libtsdb-go/database"
+)
+
+const (
+	name      = "kairosdb"
+	precision = time.Millisecond
+)
+
+var meta = database.Meta{
+	Name:               name,
+	TimePrecision:      precision,
+	SupportTag:         true,
+	SupportInt:         true,
+	SupportDouble:      true,
+	SupportBatchSeries: true,
+	SupportBatchPoints: true,
+}
+
+func Meta() database.Meta {
+	return meta
+}
+
+func init() {
+	database.RegisterMeta(name, meta)
+}