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"` }
Config of the influxdb_v2
Click to show internal directories.
Click to hide internal directories.