Documentation
¶
Index ¶
- Constants
- func NewClient(ctx context.Context, config cmap.CustomMap) (metricTY.Plugin, error)
- type Client
- func (c *Client) Close() error
- func (c *Client) Name() string
- func (c *Client) Ping() error
- func (c *Client) Query(queryConfig *metricTY.QueryConfig) (map[string][]metricTY.ResponseData, error)
- func (c *Client) Write(data *metricTY.InputData) error
- func (c *Client) WriteBlocking(data *metricTY.InputData) error
- type Config
- type LoggerConfig
Constants ¶
View Source
const ( PluginInfluxdbV2 = "influxdb" MeasurementBinary = "binary_data" MeasurementGaugeInteger = "gauge_int_data" MeasurementGaugeFloat = "gauge_float_data" MeasurementCounter = "counter_data" MeasurementString = "string_data" MeasurementGeo = "geo_data" QueryClientV1 = "v1" QueryClientV2 = "v2" DefaultMeasurementPrefix = "mc" )
global constants
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
Client influxdb2.Client
Config Config
// contains filtered or unexported fields
}
Client of the influxdb
func (*Client) Query ¶
func (c *Client) Query(queryConfig *metricTY.QueryConfig) (map[string][]metricTY.ResponseData, error)
Query func implementation
type Config ¶
type Config struct {
IsCloudInstance bool `yaml:"is_cloud_instance"`
OrganizationName string `yaml:"organization_name"`
BucketName string `yaml:"bucket_name"`
MeasurementPrefix string `yaml:"measurement_prefix"`
URI string `yaml:"uri"`
Token string `yaml:"token"`
Username string `yaml:"username"`
Password string `yaml:"password"`
Insecure bool `yaml:"insecure"`
QueryClientVersion string `yaml:"query_client_version"`
FlushInterval string `yaml:"flush_interval"`
ConnectTimeout string `yaml:"connect_timeout"`
}
Config of the influxdb_v2
Click to show internal directories.
Click to hide internal directories.