influxdb

package

v0.23.1 Latest Latest Go to latest Published: Dec 18, 2018 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mstoykov/k6

Links

Open Source Insights

Documentation ¶

Index ¶

func MakeBatchConfig(conf Config) client.BatchPointsConfig
func MakeClient(conf Config) (client.Client, error)
type Collector
- func New(conf Config) (*Collector, error)
type Config
- func (c Config) Apply(cfg Config) Config

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func MakeBatchConfig ¶ added in v0.18.0

func MakeBatchConfig(conf Config) client.BatchPointsConfig

func MakeClient ¶ added in v0.18.0

func MakeClient(conf Config) (client.Client, error)

Types ¶

type Collector ¶

type Collector struct {
	Client    client.Client
	Config    Config
	BatchConf client.BatchPointsConfig
	// contains filtered or unexported fields
}

func New ¶

func New(conf Config) (*Collector, error)

func (*Collector) Collect ¶

func (c *Collector) Collect(scs []stats.SampleContainer)

func (*Collector) Format ¶ added in v0.21.0

func (c *Collector) Format(samples []stats.Sample) ([]string, error)

Format returns a string array of metrics in influx line-protocol

func (*Collector) GetRequiredSystemTags ¶ added in v0.20.0

func (c *Collector) GetRequiredSystemTags() lib.TagSet

GetRequiredSystemTags returns which sample tags are needed by this collector

func (*Collector) Init ¶ added in v0.12.2

func (c *Collector) Init() error

func (*Collector) Link ¶ added in v0.18.0

func (c *Collector) Link() string

func (*Collector) Run ¶

func (c *Collector) Run(ctx context.Context)

func (*Collector) SetRunStatus ¶ added in v0.21.1

func (c *Collector) SetRunStatus(status lib.RunStatus)

SetRunStatus does nothing in the InfluxDB collector

type Config ¶ added in v0.16.0

type Config struct {
	// Connection.
	Addr        null.String `json:"addr" envconfig:"INFLUXDB_ADDR"`
	Username    null.String `json:"username,omitempty" envconfig:"INFLUXDB_USERNAME"`
	Password    null.String `json:"password,omitempty" envconfig:"INFLUXDB_PASSWORD"`
	Insecure    null.Bool   `json:"insecure,omitempty" envconfig:"INFLUXDB_INSECURE"`
	PayloadSize null.Int    `json:"payloadSize,omitempty" envconfig:"INFLUXDB_PAYLOAD_SIZE"`

	// Samples.
	DB           null.String `json:"db" envconfig:"INFLUXDB_DB"`
	Precision    null.String `json:"precision,omitempty" envconfig:"INFLUXDB_PRECISION"`
	Retention    null.String `json:"retention,omitempty" envconfig:"INFLUXDB_RETENTION"`
	Consistency  null.String `json:"consistency,omitempty" envconfig:"INFLUXDB_CONSISTENCY"`
	TagsAsFields []string    `json:"tagsAsFields,omitempty" envconfig:"INFLUXDB_TAGS_AS_FIELDS"`
}

func NewConfig ¶ added in v0.21.0

func NewConfig() *Config

func ParseArg ¶ added in v0.21.0

func ParseArg(arg string) (Config, error)

ParseArg parses an argument string into a Config

func ParseMap ¶ added in v0.21.0

func ParseMap(m map[string]interface{}) (Config, error)

ParseMap parses a map[string]interface{} into a Config

func ParseURL ¶ added in v0.21.0

func ParseURL(text string) (Config, error)

func (Config) Apply ¶ added in v0.18.0

func (c Config) Apply(cfg Config) Config

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL