How to use tags method of parser Package

Best Gauge code snippet using parser.tags

parser_test.go

Source:parser_test.go Github

copy

Full Screen

1package value2import (3 "testing"4 "github.com/stretchr/testify/assert"5)6func TestParseValidValues(t *testing.T) {7 parser := Parser{8 MetricName: "value_test",9 DataType: "integer",10 }11 metrics, err := parser.Parse([]byte("55"))12 assert.NoError(t, err)13 assert.Len(t, metrics, 1)14 assert.Equal(t, "value_test", metrics[0].Name())15 assert.Equal(t, map[string]interface{}{16 "value": int64(55),17 }, metrics[0].Fields())18 assert.Equal(t, map[string]string{}, metrics[0].Tags())19 parser = Parser{20 MetricName: "value_test",21 DataType: "float",22 }23 metrics, err = parser.Parse([]byte("64"))24 assert.NoError(t, err)25 assert.Len(t, metrics, 1)26 assert.Equal(t, "value_test", metrics[0].Name())27 assert.Equal(t, map[string]interface{}{28 "value": float64(64),29 }, metrics[0].Fields())30 assert.Equal(t, map[string]string{}, metrics[0].Tags())31 parser = Parser{32 MetricName: "value_test",33 DataType: "string",34 }35 metrics, err = parser.Parse([]byte("foobar"))36 assert.NoError(t, err)37 assert.Len(t, metrics, 1)38 assert.Equal(t, "value_test", metrics[0].Name())39 assert.Equal(t, map[string]interface{}{40 "value": "foobar",41 }, metrics[0].Fields())42 assert.Equal(t, map[string]string{}, metrics[0].Tags())43 parser = Parser{44 MetricName: "value_test",45 DataType: "boolean",46 }47 metrics, err = parser.Parse([]byte("true"))48 assert.NoError(t, err)49 assert.Len(t, metrics, 1)50 assert.Equal(t, "value_test", metrics[0].Name())51 assert.Equal(t, map[string]interface{}{52 "value": true,53 }, metrics[0].Fields())54 assert.Equal(t, map[string]string{}, metrics[0].Tags())55}56func TestParseMultipleValues(t *testing.T) {57 parser := Parser{58 MetricName: "value_test",59 DataType: "integer",60 }61 metrics, err := parser.Parse([]byte(`5562456322364126599966`))67 assert.NoError(t, err)68 assert.Len(t, metrics, 1)69 assert.Equal(t, "value_test", metrics[0].Name())70 assert.Equal(t, map[string]interface{}{71 "value": int64(999),72 }, metrics[0].Fields())73 assert.Equal(t, map[string]string{}, metrics[0].Tags())74}75func TestParseLineValidValues(t *testing.T) {76 parser := Parser{77 MetricName: "value_test",78 DataType: "integer",79 }80 metric, err := parser.ParseLine("55")81 assert.NoError(t, err)82 assert.Equal(t, "value_test", metric.Name())83 assert.Equal(t, map[string]interface{}{84 "value": int64(55),85 }, metric.Fields())86 assert.Equal(t, map[string]string{}, metric.Tags())87 parser = Parser{88 MetricName: "value_test",89 DataType: "float",90 }91 metric, err = parser.ParseLine("64")92 assert.NoError(t, err)93 assert.Equal(t, "value_test", metric.Name())94 assert.Equal(t, map[string]interface{}{95 "value": float64(64),96 }, metric.Fields())97 assert.Equal(t, map[string]string{}, metric.Tags())98 parser = Parser{99 MetricName: "value_test",100 DataType: "string",101 }102 metric, err = parser.ParseLine("foobar")103 assert.NoError(t, err)104 assert.Equal(t, "value_test", metric.Name())105 assert.Equal(t, map[string]interface{}{106 "value": "foobar",107 }, metric.Fields())108 assert.Equal(t, map[string]string{}, metric.Tags())109 parser = Parser{110 MetricName: "value_test",111 DataType: "boolean",112 }113 metric, err = parser.ParseLine("true")114 assert.NoError(t, err)115 assert.Equal(t, "value_test", metric.Name())116 assert.Equal(t, map[string]interface{}{117 "value": true,118 }, metric.Fields())119 assert.Equal(t, map[string]string{}, metric.Tags())120}121func TestParseInvalidValues(t *testing.T) {122 parser := Parser{123 MetricName: "value_test",124 DataType: "integer",125 }126 metrics, err := parser.Parse([]byte("55.0"))127 assert.Error(t, err)128 assert.Len(t, metrics, 0)129 parser = Parser{130 MetricName: "value_test",131 DataType: "float",132 }133 metrics, err = parser.Parse([]byte("foobar"))134 assert.Error(t, err)135 assert.Len(t, metrics, 0)136 parser = Parser{137 MetricName: "value_test",138 DataType: "boolean",139 }140 metrics, err = parser.Parse([]byte("213"))141 assert.Error(t, err)142 assert.Len(t, metrics, 0)143}144func TestParseLineInvalidValues(t *testing.T) {145 parser := Parser{146 MetricName: "value_test",147 DataType: "integer",148 }149 _, err := parser.ParseLine("55.0")150 assert.Error(t, err)151 parser = Parser{152 MetricName: "value_test",153 DataType: "float",154 }155 _, err = parser.ParseLine("foobar")156 assert.Error(t, err)157 parser = Parser{158 MetricName: "value_test",159 DataType: "boolean",160 }161 _, err = parser.ParseLine("213")162 assert.Error(t, err)163}164func TestParseValidValuesDefaultTags(t *testing.T) {165 parser := Parser{166 MetricName: "value_test",167 DataType: "integer",168 }169 parser.SetDefaultTags(map[string]string{"test": "tag"})170 metrics, err := parser.Parse([]byte("55"))171 assert.NoError(t, err)172 assert.Len(t, metrics, 1)173 assert.Equal(t, "value_test", metrics[0].Name())174 assert.Equal(t, map[string]interface{}{175 "value": int64(55),176 }, metrics[0].Fields())177 assert.Equal(t, map[string]string{"test": "tag"}, metrics[0].Tags())178 parser = Parser{179 MetricName: "value_test",180 DataType: "float",181 }182 parser.SetDefaultTags(map[string]string{"test": "tag"})183 metrics, err = parser.Parse([]byte("64"))184 assert.NoError(t, err)185 assert.Len(t, metrics, 1)186 assert.Equal(t, "value_test", metrics[0].Name())187 assert.Equal(t, map[string]interface{}{188 "value": float64(64),189 }, metrics[0].Fields())190 assert.Equal(t, map[string]string{"test": "tag"}, metrics[0].Tags())191 parser = Parser{192 MetricName: "value_test",193 DataType: "string",194 }195 parser.SetDefaultTags(map[string]string{"test": "tag"})196 metrics, err = parser.Parse([]byte("foobar"))197 assert.NoError(t, err)198 assert.Len(t, metrics, 1)199 assert.Equal(t, "value_test", metrics[0].Name())200 assert.Equal(t, map[string]interface{}{201 "value": "foobar",202 }, metrics[0].Fields())203 assert.Equal(t, map[string]string{"test": "tag"}, metrics[0].Tags())204 parser = Parser{205 MetricName: "value_test",206 DataType: "boolean",207 }208 parser.SetDefaultTags(map[string]string{"test": "tag"})209 metrics, err = parser.Parse([]byte("true"))210 assert.NoError(t, err)211 assert.Len(t, metrics, 1)212 assert.Equal(t, "value_test", metrics[0].Name())213 assert.Equal(t, map[string]interface{}{214 "value": true,215 }, metrics[0].Fields())216 assert.Equal(t, map[string]string{"test": "tag"}, metrics[0].Tags())217}218func TestParseValuesWithNullCharacter(t *testing.T) {219 parser := Parser{220 MetricName: "value_test",221 DataType: "integer",222 }223 metrics, err := parser.Parse([]byte("55\x00"))224 assert.NoError(t, err)225 assert.Len(t, metrics, 1)226 assert.Equal(t, "value_test", metrics[0].Name())227 assert.Equal(t, map[string]interface{}{228 "value": int64(55),229 }, metrics[0].Fields())230 assert.Equal(t, map[string]string{}, metrics[0].Tags())231}...

Full Screen

Full Screen

parser.go

Source:parser.go Github

copy

Full Screen

...107 return nil, err108 }109 return metrics, nil110}111func (p *Parser) SetDefaultTags(tags map[string]string) {112 p.defaultTags = tags113}114func (p *PointParser) convertPointToAgentMetric(points []Point) ([]cua.Metric, error) {115 metrics := make([]cua.Metric, 0)116 for _, point := range points {117 tags := make(map[string]string)118 for k, v := range point.Tags {119 tags[k] = v120 }121 // apply default tags after parsed tags122 for k, v := range p.parent.defaultTags {123 tags[k] = v124 }125 // single field for value126 fields := make(map[string]interface{})127 v, err := strconv.ParseFloat(point.Value, 64)128 if err != nil {129 return nil, fmt.Errorf("parse float (%s): %w", point.Value, err)130 }131 fields["value"] = v132 m, err := metric.New(point.Name, tags, fields, time.Unix(point.Timestamp, 0))133 if err != nil {134 return nil, fmt.Errorf("metric new: %w", err)135 }136 metrics = append(metrics, m)137 }138 return metrics, nil139}140// scan returns the next token from the underlying scanner.141// If a token has been unscanned then read that from the internal buffer instead.142func (p *PointParser) scan() (Token, string) {143 // If we have a token on the buffer, then return it.144 if p.buf.n != 0 {145 idx := p.buf.n % MaxBufferSize146 tok, lit := p.buf.tok[idx], p.buf.lit[idx]...

Full Screen

Full Screen

registry.go

Source:registry.go Github

copy

Full Screen

...23 // ParseLine takes a single string metric24 // ie, "cpu.usage.idle 90"25 // and parses it into a telegraf metric.26 ParseLine(line string) (telegraf.Metric, error)27 // SetDefaultTags tells the parser to add all of the given tags28 // to each parsed metric.29 // NOTE: do _not_ modify the map after you've passed it here!!30 SetDefaultTags(tags map[string]string)31}32// Config is a struct that covers the data types needed for all parser types,33// and can be used to instantiate _any_ of the parsers.34type Config struct {35 // Dataformat can be one of: json, influx, graphite, value, nagios36 DataFormat string37 // Separator only applied to Graphite data.38 Separator string39 // Templates only apply to Graphite data.40 Templates []string41 // TagKeys only apply to JSON data42 TagKeys []string43 // MetricName applies to JSON & value. This will be the name of the measurement.44 MetricName string45 // DataType only applies to value, this will be the type to parse value to46 DataType string47 // DefaultTags are the default tags that will be added to all parsed metrics.48 DefaultTags map[string]string49}50// NewParser returns a Parser interface based on the given config.51func NewParser(config *Config) (Parser, error) {52 var err error53 var parser Parser54 switch config.DataFormat {55 case "json":56 parser, err = NewJSONParser(config.MetricName,57 config.TagKeys, config.DefaultTags)58 case "value":59 parser, err = NewValueParser(config.MetricName,60 config.DataType, config.DefaultTags)61 case "influx":...

Full Screen

Full Screen

tags

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 response, err := http.Get(url)4 if err != nil {5 log.Fatal(err)6 }7 defer response.Body.Close()8 doc, err := htmlquery.Parse(response.Body)9 if err != nil {10 log.Fatal(err)11 }12 for _, node := range nodes {13 fmt.Println(htmlquery.InnerText(node))14 }15}

Full Screen

Full Screen

tags

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 xlFile, err := xlsx.OpenFile("/home/ashish/Desktop/ashish.xlsx")4 if err != nil {5 fmt.Println("Error opening file:", err)6 }7 for _, row := range sheet.Rows {8 for _, cell := range row.Cells {9 fmt.Printf("%s\t", cell.Value)10 }11 fmt.Println()12 }13}

Full Screen

Full Screen

tags

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 doc.Find("a").Each(func(index int, item *goquery.Selection) {4 title, _ := item.Attr("title")5 fmt.Println(title)6 })7}

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Gauge automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful