golang-github-influxdb-influxdb-dev 1.1.1+dfsg1-4 / usr / share / gocode / src / github.com / influxdata / influxdb / stress / v2 / stress_client / reporting.go

package stressClient

import (
	"log"
	"strconv"
	"time"

	influx "github.com/influxdata/influxdb/client/v2"
)

// reporting.go contains functions to emit tags and points from various parts of stressClient
// These points are then written to the ("_%v", sf.TestName) database

// These are the tags that stressClient adds to any response points
func (sc *stressClient) tags(statementID string) map[string]string {
	tags := map[string]string{
		"number_targets": fmtInt(len(sc.addresses)),
		"precision":      sc.precision,
		"writers":        fmtInt(sc.wconc),
		"readers":        fmtInt(sc.qconc),
		"test_id":        sc.testID,
		"statement_id":   statementID,
		"write_interval": sc.wdelay,
		"query_interval": sc.qdelay,
	}
	return tags
}

// These are the tags that the StressTest adds to any response points
func (st *StressTest) tags() map[string]string {
	tags := map[string]string{
		"precision":  st.Precision,
		"batch_size": fmtInt(st.BatchSize),
	}
	return tags
}

// This function makes a *client.Point for reporting on writes
func (sc *stressClient) writePoint(retries int, statementID string, statusCode int, responseTime time.Duration, addedTags map[string]string, writeBytes int) *influx.Point {

	tags := sumTags(sc.tags(statementID), addedTags)

	fields := map[string]interface{}{
		"status_code":      statusCode,
		"response_time_ns": responseTime.Nanoseconds(),
		"num_bytes":        writeBytes,
	}

	point, err := influx.NewPoint("write", tags, fields, time.Now())

	if err != nil {
		log.Fatalf("Error creating write results point\n  error: %v\n", err)
	}

	return point
}

// This function makes a *client.Point for reporting on queries
func (sc *stressClient) queryPoint(statementID string, body []byte, statusCode int, responseTime time.Duration, addedTags map[string]string) *influx.Point {

	tags := sumTags(sc.tags(statementID), addedTags)

	fields := map[string]interface{}{
		"status_code":      statusCode,
		"num_bytes":        len(body),
		"response_time_ns": responseTime.Nanoseconds(),
	}

	point, err := influx.NewPoint("query", tags, fields, time.Now())

	if err != nil {
		log.Fatalf("Error creating query results point\n  error: %v\n", err)
	}

	return point
}

// Adds two map[string]string together
func sumTags(tags1, tags2 map[string]string) map[string]string {
	tags := make(map[string]string)
	// Add all tags from first map to return map
	for k, v := range tags1 {
		tags[k] = v
	}
	// Add all tags from second map to return map
	for k, v := range tags2 {
		tags[k] = v
	}
	return tags
}

// Turns an int into a string
func fmtInt(i int) string {
	return strconv.FormatInt(int64(i), 10)
}