//line machine.go.rl:1
package protocol
import (
"errors"
"io"
)
var (
ErrNameParse = errors.New("expected measurement name")
ErrFieldParse = errors.New("expected field")
ErrTagParse = errors.New("expected tag")
ErrTimestampParse = errors.New("expected timestamp")
ErrParse = errors.New("parse error")
EOF = errors.New("EOF")
)
//line machine.go.rl:310
//line machine.go:25
const LineProtocol_start int = 47
const LineProtocol_first_final int = 47
const LineProtocol_error int = 0
const LineProtocol_en_main int = 47
const LineProtocol_en_discard_line int = 35
const LineProtocol_en_align int = 86
const LineProtocol_en_series int = 38
//line machine.go.rl:313
type Handler interface {
SetMeasurement(name []byte) error
AddTag(key []byte, value []byte) error
AddInt(key []byte, value []byte) error
AddUint(key []byte, value []byte) error
AddFloat(key []byte, value []byte) error
AddString(key []byte, value []byte) error
AddBool(key []byte, value []byte) error
SetTimestamp(tm []byte) error
}
type machine struct {
data []byte
cs int
p, pe, eof int
pb int
lineno int
sol int
handler Handler
initState int
key []byte
beginMetric bool
finishMetric bool
}
func NewMachine(handler Handler) *machine {
m := &machine{
handler: handler,
initState: LineProtocol_en_align,
}
//line machine.go.rl:346
//line machine.go.rl:347
//line machine.go.rl:348
//line machine.go.rl:349
//line machine.go.rl:350
//line machine.go.rl:351
//line machine.go:82
{
(m.cs) = LineProtocol_start
}
//line machine.go.rl:352
return m
}
func NewSeriesMachine(handler Handler) *machine {
m := &machine{
handler: handler,
initState: LineProtocol_en_series,
}
//line machine.go.rl:363
//line machine.go.rl:364
//line machine.go.rl:365
//line machine.go.rl:366
//line machine.go.rl:367
//line machine.go:109
{
(m.cs) = LineProtocol_start
}
//line machine.go.rl:368
return m
}
func (m *machine) SetData(data []byte) {
m.data = data
m.p = 0
m.pb = 0
m.lineno = 1
m.sol = 0
m.pe = len(data)
m.eof = len(data)
m.key = nil
m.beginMetric = false
m.finishMetric = false
//line machine.go:132
{
(m.cs) = LineProtocol_start
}
//line machine.go.rl:385
m.cs = m.initState
}
// Next parses the next metric line and returns nil if it was successfully
// processed. If the line contains a syntax error an error is returned,
// otherwise if the end of file is reached before finding a metric line then
// EOF is returned.
func (m *machine) Next() error {
if m.p == m.pe && m.pe == m.eof {
return EOF
}
m.key = nil
m.beginMetric = false
m.finishMetric = false
return m.exec()
}
func (m *machine) exec() error {
var err error
//line machine.go:160
{
if (m.p) == (m.pe) {
goto _test_eof
}
goto _resume
_again:
switch m.cs {
case 47:
goto st47
case 1:
goto st1
case 2:
goto st2
case 3:
goto st3
case 0:
goto st0
case 4:
goto st4
case 5:
goto st5
case 6:
goto st6
case 7:
goto st7
case 48:
goto st48
case 49:
goto st49
case 50:
goto st50
case 8:
goto st8
case 9:
goto st9
case 10:
goto st10
case 11:
goto st11
case 51:
goto st51
case 52:
goto st52
case 53:
goto st53
case 54:
goto st54
case 55:
goto st55
case 56:
goto st56
case 57:
goto st57
case 58:
goto st58
case 59:
goto st59
case 60:
goto st60
case 61:
goto st61
case 62:
goto st62
case 63:
goto st63
case 64:
goto st64
case 65:
goto st65
case 66:
goto st66
case 67:
goto st67
case 68:
goto st68
case 69:
goto st69
case 70:
goto st70
case 12:
goto st12
case 13:
goto st13
case 14:
goto st14
case 15:
goto st15
case 16:
goto st16
case 71:
goto st71
case 17:
goto st17
case 18:
goto st18
case 72:
goto st72
case 73:
goto st73
case 74:
goto st74
case 75:
goto st75
case 76:
goto st76
case 77:
goto st77
case 78:
goto st78
case 79:
goto st79
case 80:
goto st80
case 19:
goto st19
case 20:
goto st20
case 21:
goto st21
case 81:
goto st81
case 22:
goto st22
case 23:
goto st23
case 24:
goto st24
case 82:
goto st82
case 25:
goto st25
case 26:
goto st26
case 83:
goto st83
case 84:
goto st84
case 27:
goto st27
case 28:
goto st28
case 29:
goto st29
case 30:
goto st30
case 31:
goto st31
case 32:
goto st32
case 33:
goto st33
case 34:
goto st34
case 35:
goto st35
case 85:
goto st85
case 38:
goto st38
case 87:
goto st87
case 88:
goto st88
case 39:
goto st39
case 40:
goto st40
case 41:
goto st41
case 42:
goto st42
case 89:
goto st89
case 43:
goto st43
case 90:
goto st90
case 44:
goto st44
case 45:
goto st45
case 46:
goto st46
case 86:
goto st86
case 36:
goto st36
case 37:
goto st37
}
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof
}
_resume:
switch m.cs {
case 47:
goto st_case_47
case 1:
goto st_case_1
case 2:
goto st_case_2
case 3:
goto st_case_3
case 0:
goto st_case_0
case 4:
goto st_case_4
case 5:
goto st_case_5
case 6:
goto st_case_6
case 7:
goto st_case_7
case 48:
goto st_case_48
case 49:
goto st_case_49
case 50:
goto st_case_50
case 8:
goto st_case_8
case 9:
goto st_case_9
case 10:
goto st_case_10
case 11:
goto st_case_11
case 51:
goto st_case_51
case 52:
goto st_case_52
case 53:
goto st_case_53
case 54:
goto st_case_54
case 55:
goto st_case_55
case 56:
goto st_case_56
case 57:
goto st_case_57
case 58:
goto st_case_58
case 59:
goto st_case_59
case 60:
goto st_case_60
case 61:
goto st_case_61
case 62:
goto st_case_62
case 63:
goto st_case_63
case 64:
goto st_case_64
case 65:
goto st_case_65
case 66:
goto st_case_66
case 67:
goto st_case_67
case 68:
goto st_case_68
case 69:
goto st_case_69
case 70:
goto st_case_70
case 12:
goto st_case_12
case 13:
goto st_case_13
case 14:
goto st_case_14
case 15:
goto st_case_15
case 16:
goto st_case_16
case 71:
goto st_case_71
case 17:
goto st_case_17
case 18:
goto st_case_18
case 72:
goto st_case_72
case 73:
goto st_case_73
case 74:
goto st_case_74
case 75:
goto st_case_75
case 76:
goto st_case_76
case 77:
goto st_case_77
case 78:
goto st_case_78
case 79:
goto st_case_79
case 80:
goto st_case_80
case 19:
goto st_case_19
case 20:
goto st_case_20
case 21:
goto st_case_21
case 81:
goto st_case_81
case 22:
goto st_case_22
case 23:
goto st_case_23
case 24:
goto st_case_24
case 82:
goto st_case_82
case 25:
goto st_case_25
case 26:
goto st_case_26
case 83:
goto st_case_83
case 84:
goto st_case_84
case 27:
goto st_case_27
case 28:
goto st_case_28
case 29:
goto st_case_29
case 30:
goto st_case_30
case 31:
goto st_case_31
case 32:
goto st_case_32
case 33:
goto st_case_33
case 34:
goto st_case_34
case 35:
goto st_case_35
case 85:
goto st_case_85
case 38:
goto st_case_38
case 87:
goto st_case_87
case 88:
goto st_case_88
case 39:
goto st_case_39
case 40:
goto st_case_40
case 41:
goto st_case_41
case 42:
goto st_case_42
case 89:
goto st_case_89
case 43:
goto st_case_43
case 90:
goto st_case_90
case 44:
goto st_case_44
case 45:
goto st_case_45
case 46:
goto st_case_46
case 86:
goto st_case_86
case 36:
goto st_case_36
case 37:
goto st_case_37
}
goto st_out
st47:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof47
}
st_case_47:
switch (m.data)[(m.p)] {
case 10:
goto tr33
case 13:
goto tr33
case 32:
goto tr82
case 35:
goto tr33
case 44:
goto tr33
case 92:
goto tr83
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr82
}
goto tr81
tr31:
//line machine.go.rl:20
m.pb = m.p
goto st1
tr81:
//line machine.go.rl:74
m.beginMetric = true
//line machine.go.rl:20
m.pb = m.p
goto st1
st1:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof1
}
st_case_1:
//line machine.go:586
switch (m.data)[(m.p)] {
case 10:
goto tr2
case 13:
goto tr2
case 32:
goto tr1
case 44:
goto tr3
case 92:
goto st9
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr1
}
goto st1
tr1:
(m.cs) = 2
//line machine.go.rl:78
err = m.handler.SetMeasurement(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr58:
(m.cs) = 2
//line machine.go.rl:91
err = m.handler.AddTag(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st2:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof2
}
st_case_2:
//line machine.go:634
switch (m.data)[(m.p)] {
case 10:
goto tr7
case 13:
goto tr7
case 32:
goto st2
case 44:
goto tr7
case 61:
goto tr7
case 92:
goto tr8
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto st2
}
goto tr5
tr5:
//line machine.go.rl:20
m.pb = m.p
goto st3
st3:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof3
}
st_case_3:
//line machine.go:664
switch (m.data)[(m.p)] {
case 32:
goto tr7
case 44:
goto tr7
case 61:
goto tr10
case 92:
goto st13
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr7
}
goto st3
tr2:
(m.cs) = 0
//line machine.go.rl:38
err = ErrTagParse
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
goto _again
tr7:
(m.cs) = 0
//line machine.go.rl:31
err = ErrFieldParse
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
goto _again
tr33:
(m.cs) = 0
//line machine.go.rl:24
err = ErrNameParse
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
goto _again
tr37:
(m.cs) = 0
//line machine.go.rl:45
err = ErrTimestampParse
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
goto _again
tr84:
(m.cs) = 0
//line machine.go.rl:31
err = ErrFieldParse
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
//line machine.go.rl:45
err = ErrTimestampParse
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
goto _again
tr137:
//line machine.go.rl:65
(m.p)--
{
goto st47
}
goto st0
//line machine.go:750
st_case_0:
st0:
(m.cs) = 0
goto _out
tr10:
//line machine.go.rl:100
m.key = m.text()
goto st4
st4:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof4
}
st_case_4:
//line machine.go:766
switch (m.data)[(m.p)] {
case 34:
goto st5
case 45:
goto tr13
case 46:
goto tr14
case 48:
goto tr15
case 70:
goto tr17
case 84:
goto tr18
case 102:
goto tr19
case 116:
goto tr20
}
if 49 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto tr16
}
goto tr7
st5:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof5
}
st_case_5:
switch (m.data)[(m.p)] {
case 10:
goto tr22
case 12:
goto tr7
case 13:
goto tr23
case 34:
goto tr24
case 92:
goto tr25
}
goto tr21
tr21:
//line machine.go.rl:20
m.pb = m.p
goto st6
tr22:
//line machine.go.rl:20
m.pb = m.p
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto st6
tr27:
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto st6
st6:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof6
}
st_case_6:
//line machine.go:838
switch (m.data)[(m.p)] {
case 10:
goto tr27
case 12:
goto tr7
case 13:
goto st7
case 34:
goto tr29
case 92:
goto st14
}
goto st6
tr23:
//line machine.go.rl:20
m.pb = m.p
goto st7
st7:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof7
}
st_case_7:
//line machine.go:863
if (m.data)[(m.p)] == 10 {
goto tr27
}
goto tr7
tr24:
(m.cs) = 48
//line machine.go.rl:20
m.pb = m.p
//line machine.go.rl:140
err = m.handler.AddString(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr29:
(m.cs) = 48
//line machine.go.rl:140
err = m.handler.AddString(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st48:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof48
}
st_case_48:
//line machine.go:903
switch (m.data)[(m.p)] {
case 10:
goto tr36
case 13:
goto st10
case 32:
goto st49
case 44:
goto st12
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto st49
}
goto tr84
tr112:
(m.cs) = 49
//line machine.go.rl:122
err = m.handler.AddFloat(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr119:
(m.cs) = 49
//line machine.go.rl:104
err = m.handler.AddInt(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr124:
(m.cs) = 49
//line machine.go.rl:113
err = m.handler.AddUint(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr129:
(m.cs) = 49
//line machine.go.rl:131
err = m.handler.AddBool(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st49:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof49
}
st_case_49:
//line machine.go:975
switch (m.data)[(m.p)] {
case 10:
goto tr36
case 13:
goto st10
case 32:
goto st49
case 45:
goto tr88
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto tr89
}
case (m.data)[(m.p)] >= 9:
goto st49
}
goto tr37
tr36:
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto st50
tr91:
(m.cs) = 50
//line machine.go.rl:149
err = m.handler.SetTimestamp(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto _again
tr113:
(m.cs) = 50
//line machine.go.rl:122
err = m.handler.AddFloat(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto _again
tr120:
(m.cs) = 50
//line machine.go.rl:104
err = m.handler.AddInt(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto _again
tr125:
(m.cs) = 50
//line machine.go.rl:113
err = m.handler.AddUint(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto _again
tr130:
(m.cs) = 50
//line machine.go.rl:131
err = m.handler.AddBool(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto _again
st50:
//line machine.go.rl:164
m.finishMetric = true
(m.cs) = 86
{
(m.p)++
goto _out
}
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof50
}
st_case_50:
//line machine.go:1109
switch (m.data)[(m.p)] {
case 10:
goto tr33
case 13:
goto tr33
case 32:
goto st8
case 35:
goto tr33
case 44:
goto tr33
case 92:
goto tr34
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto st8
}
goto tr31
tr82:
//line machine.go.rl:74
m.beginMetric = true
goto st8
st8:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof8
}
st_case_8:
//line machine.go:1139
switch (m.data)[(m.p)] {
case 10:
goto tr33
case 13:
goto tr33
case 32:
goto st8
case 35:
goto tr33
case 44:
goto tr33
case 92:
goto tr34
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto st8
}
goto tr31
tr34:
//line machine.go.rl:20
m.pb = m.p
goto st9
tr83:
//line machine.go.rl:74
m.beginMetric = true
//line machine.go.rl:20
m.pb = m.p
goto st9
st9:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof9
}
st_case_9:
//line machine.go:1179
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto st0
}
goto st1
tr92:
(m.cs) = 10
//line machine.go.rl:149
err = m.handler.SetTimestamp(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr114:
(m.cs) = 10
//line machine.go.rl:122
err = m.handler.AddFloat(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr121:
(m.cs) = 10
//line machine.go.rl:104
err = m.handler.AddInt(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr126:
(m.cs) = 10
//line machine.go.rl:113
err = m.handler.AddUint(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr131:
(m.cs) = 10
//line machine.go.rl:131
err = m.handler.AddBool(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st10:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof10
}
st_case_10:
//line machine.go:1254
if (m.data)[(m.p)] == 10 {
goto tr36
}
goto st0
tr88:
//line machine.go.rl:20
m.pb = m.p
goto st11
st11:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof11
}
st_case_11:
//line machine.go:1270
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st51
}
goto tr37
tr89:
//line machine.go.rl:20
m.pb = m.p
goto st51
st51:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof51
}
st_case_51:
//line machine.go:1286
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st53
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
tr90:
(m.cs) = 52
//line machine.go.rl:149
err = m.handler.SetTimestamp(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st52:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof52
}
st_case_52:
//line machine.go:1322
switch (m.data)[(m.p)] {
case 10:
goto tr36
case 13:
goto st10
case 32:
goto st52
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto st52
}
goto st0
st53:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof53
}
st_case_53:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st54
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st54:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof54
}
st_case_54:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st55
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st55:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof55
}
st_case_55:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st56
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st56:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof56
}
st_case_56:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st57
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st57:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof57
}
st_case_57:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st58
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st58:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof58
}
st_case_58:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st59
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st59:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof59
}
st_case_59:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st60
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st60:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof60
}
st_case_60:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st61
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st61:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof61
}
st_case_61:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st62
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st62:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof62
}
st_case_62:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st63
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st63:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof63
}
st_case_63:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st64
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st64:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof64
}
st_case_64:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st65
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st65:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof65
}
st_case_65:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st66
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st66:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof66
}
st_case_66:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st67
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st67:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof67
}
st_case_67:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st68
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st68:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof68
}
st_case_68:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st69
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st69:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof69
}
st_case_69:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st70
}
case (m.data)[(m.p)] >= 9:
goto tr90
}
goto tr37
st70:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof70
}
st_case_70:
switch (m.data)[(m.p)] {
case 10:
goto tr91
case 13:
goto tr92
case 32:
goto tr90
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr90
}
goto tr37
tr115:
(m.cs) = 12
//line machine.go.rl:122
err = m.handler.AddFloat(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr122:
(m.cs) = 12
//line machine.go.rl:104
err = m.handler.AddInt(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr127:
(m.cs) = 12
//line machine.go.rl:113
err = m.handler.AddUint(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr132:
(m.cs) = 12
//line machine.go.rl:131
err = m.handler.AddBool(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st12:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof12
}
st_case_12:
//line machine.go:1783
switch (m.data)[(m.p)] {
case 32:
goto tr7
case 44:
goto tr7
case 61:
goto tr7
case 92:
goto tr8
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr7
}
goto tr5
tr8:
//line machine.go.rl:20
m.pb = m.p
goto st13
st13:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof13
}
st_case_13:
//line machine.go:1809
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr7
}
goto st3
tr25:
//line machine.go.rl:20
m.pb = m.p
goto st14
st14:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof14
}
st_case_14:
//line machine.go:1825
switch (m.data)[(m.p)] {
case 34:
goto st6
case 92:
goto st6
}
goto tr7
tr13:
//line machine.go.rl:20
m.pb = m.p
goto st15
st15:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof15
}
st_case_15:
//line machine.go:1844
switch (m.data)[(m.p)] {
case 46:
goto st16
case 48:
goto st73
}
if 49 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st76
}
goto tr7
tr14:
//line machine.go.rl:20
m.pb = m.p
goto st16
st16:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof16
}
st_case_16:
//line machine.go:1866
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st71
}
goto tr7
st71:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof71
}
st_case_71:
switch (m.data)[(m.p)] {
case 10:
goto tr113
case 13:
goto tr114
case 32:
goto tr112
case 44:
goto tr115
case 69:
goto st17
case 101:
goto st17
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st71
}
case (m.data)[(m.p)] >= 9:
goto tr112
}
goto tr84
st17:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof17
}
st_case_17:
switch (m.data)[(m.p)] {
case 34:
goto st18
case 43:
goto st18
case 45:
goto st18
}
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st72
}
goto tr7
st18:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof18
}
st_case_18:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st72
}
goto tr7
st72:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof72
}
st_case_72:
switch (m.data)[(m.p)] {
case 10:
goto tr113
case 13:
goto tr114
case 32:
goto tr112
case 44:
goto tr115
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st72
}
case (m.data)[(m.p)] >= 9:
goto tr112
}
goto tr84
st73:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof73
}
st_case_73:
switch (m.data)[(m.p)] {
case 10:
goto tr113
case 13:
goto tr114
case 32:
goto tr112
case 44:
goto tr115
case 46:
goto st71
case 69:
goto st17
case 101:
goto st17
case 105:
goto st75
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st74
}
case (m.data)[(m.p)] >= 9:
goto tr112
}
goto tr84
st74:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof74
}
st_case_74:
switch (m.data)[(m.p)] {
case 10:
goto tr113
case 13:
goto tr114
case 32:
goto tr112
case 44:
goto tr115
case 46:
goto st71
case 69:
goto st17
case 101:
goto st17
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st74
}
case (m.data)[(m.p)] >= 9:
goto tr112
}
goto tr84
st75:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof75
}
st_case_75:
switch (m.data)[(m.p)] {
case 10:
goto tr120
case 13:
goto tr121
case 32:
goto tr119
case 44:
goto tr122
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr119
}
goto tr84
st76:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof76
}
st_case_76:
switch (m.data)[(m.p)] {
case 10:
goto tr113
case 13:
goto tr114
case 32:
goto tr112
case 44:
goto tr115
case 46:
goto st71
case 69:
goto st17
case 101:
goto st17
case 105:
goto st75
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st76
}
case (m.data)[(m.p)] >= 9:
goto tr112
}
goto tr84
tr15:
//line machine.go.rl:20
m.pb = m.p
goto st77
st77:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof77
}
st_case_77:
//line machine.go:2073
switch (m.data)[(m.p)] {
case 10:
goto tr113
case 13:
goto tr114
case 32:
goto tr112
case 44:
goto tr115
case 46:
goto st71
case 69:
goto st17
case 101:
goto st17
case 105:
goto st75
case 117:
goto st78
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st74
}
case (m.data)[(m.p)] >= 9:
goto tr112
}
goto tr84
st78:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof78
}
st_case_78:
switch (m.data)[(m.p)] {
case 10:
goto tr125
case 13:
goto tr126
case 32:
goto tr124
case 44:
goto tr127
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr124
}
goto tr84
tr16:
//line machine.go.rl:20
m.pb = m.p
goto st79
st79:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof79
}
st_case_79:
//line machine.go:2133
switch (m.data)[(m.p)] {
case 10:
goto tr113
case 13:
goto tr114
case 32:
goto tr112
case 44:
goto tr115
case 46:
goto st71
case 69:
goto st17
case 101:
goto st17
case 105:
goto st75
case 117:
goto st78
}
switch {
case (m.data)[(m.p)] > 12:
if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
goto st79
}
case (m.data)[(m.p)] >= 9:
goto tr112
}
goto tr84
tr17:
//line machine.go.rl:20
m.pb = m.p
goto st80
st80:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof80
}
st_case_80:
//line machine.go:2174
switch (m.data)[(m.p)] {
case 10:
goto tr130
case 13:
goto tr131
case 32:
goto tr129
case 44:
goto tr132
case 65:
goto st19
case 97:
goto st22
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr129
}
goto tr84
st19:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof19
}
st_case_19:
if (m.data)[(m.p)] == 76 {
goto st20
}
goto tr7
st20:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof20
}
st_case_20:
if (m.data)[(m.p)] == 83 {
goto st21
}
goto tr7
st21:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof21
}
st_case_21:
if (m.data)[(m.p)] == 69 {
goto st81
}
goto tr7
st81:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof81
}
st_case_81:
switch (m.data)[(m.p)] {
case 10:
goto tr130
case 13:
goto tr131
case 32:
goto tr129
case 44:
goto tr132
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr129
}
goto tr84
st22:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof22
}
st_case_22:
if (m.data)[(m.p)] == 108 {
goto st23
}
goto tr7
st23:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof23
}
st_case_23:
if (m.data)[(m.p)] == 115 {
goto st24
}
goto tr7
st24:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof24
}
st_case_24:
if (m.data)[(m.p)] == 101 {
goto st81
}
goto tr7
tr18:
//line machine.go.rl:20
m.pb = m.p
goto st82
st82:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof82
}
st_case_82:
//line machine.go:2277
switch (m.data)[(m.p)] {
case 10:
goto tr130
case 13:
goto tr131
case 32:
goto tr129
case 44:
goto tr132
case 82:
goto st25
case 114:
goto st26
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr129
}
goto tr84
st25:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof25
}
st_case_25:
if (m.data)[(m.p)] == 85 {
goto st21
}
goto tr7
st26:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof26
}
st_case_26:
if (m.data)[(m.p)] == 117 {
goto st24
}
goto tr7
tr19:
//line machine.go.rl:20
m.pb = m.p
goto st83
st83:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof83
}
st_case_83:
//line machine.go:2325
switch (m.data)[(m.p)] {
case 10:
goto tr130
case 13:
goto tr131
case 32:
goto tr129
case 44:
goto tr132
case 97:
goto st22
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr129
}
goto tr84
tr20:
//line machine.go.rl:20
m.pb = m.p
goto st84
st84:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof84
}
st_case_84:
//line machine.go:2353
switch (m.data)[(m.p)] {
case 10:
goto tr130
case 13:
goto tr131
case 32:
goto tr129
case 44:
goto tr132
case 114:
goto st26
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr129
}
goto tr84
tr3:
(m.cs) = 27
//line machine.go.rl:78
err = m.handler.SetMeasurement(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr59:
(m.cs) = 27
//line machine.go.rl:91
err = m.handler.AddTag(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st27:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof27
}
st_case_27:
//line machine.go:2401
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr2
case 92:
goto tr51
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto tr50
tr50:
//line machine.go.rl:20
m.pb = m.p
goto st28
st28:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof28
}
st_case_28:
//line machine.go:2427
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr53
case 92:
goto st33
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st28
tr53:
//line machine.go.rl:87
m.key = m.text()
goto st29
st29:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof29
}
st_case_29:
//line machine.go:2453
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr2
case 92:
goto tr56
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto tr55
tr55:
//line machine.go.rl:20
m.pb = m.p
goto st30
st30:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof30
}
st_case_30:
//line machine.go:2479
switch (m.data)[(m.p)] {
case 10:
goto tr2
case 13:
goto tr2
case 32:
goto tr58
case 44:
goto tr59
case 61:
goto tr2
case 92:
goto st31
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr58
}
goto st30
tr56:
//line machine.go.rl:20
m.pb = m.p
goto st31
st31:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof31
}
st_case_31:
//line machine.go:2509
if (m.data)[(m.p)] == 92 {
goto st32
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st30
st32:
//line machine.go.rl:240
(m.p)--
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof32
}
st_case_32:
//line machine.go:2525
switch (m.data)[(m.p)] {
case 10:
goto tr2
case 13:
goto tr2
case 32:
goto tr58
case 44:
goto tr59
case 61:
goto tr2
case 92:
goto st31
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr58
}
goto st30
tr51:
//line machine.go.rl:20
m.pb = m.p
goto st33
st33:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof33
}
st_case_33:
//line machine.go:2555
if (m.data)[(m.p)] == 92 {
goto st34
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st28
st34:
//line machine.go.rl:240
(m.p)--
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof34
}
st_case_34:
//line machine.go:2571
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr53
case 92:
goto st33
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st28
st35:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof35
}
st_case_35:
if (m.data)[(m.p)] == 10 {
goto tr64
}
goto st35
tr64:
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
//line machine.go.rl:70
{
goto st86
}
goto st85
st85:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof85
}
st_case_85:
//line machine.go:2612
goto st0
st38:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof38
}
st_case_38:
switch (m.data)[(m.p)] {
case 32:
goto tr33
case 35:
goto tr33
case 44:
goto tr33
case 92:
goto tr68
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr33
}
goto tr67
tr67:
//line machine.go.rl:74
m.beginMetric = true
//line machine.go.rl:20
m.pb = m.p
goto st87
st87:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof87
}
st_case_87:
//line machine.go:2648
switch (m.data)[(m.p)] {
case 10:
goto tr140
case 13:
goto tr141
case 32:
goto tr2
case 44:
goto tr142
case 92:
goto st46
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr2
}
goto st87
tr69:
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto st88
tr140:
(m.cs) = 88
//line machine.go.rl:78
err = m.handler.SetMeasurement(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto _again
tr144:
(m.cs) = 88
//line machine.go.rl:91
err = m.handler.AddTag(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto _again
st88:
//line machine.go.rl:164
m.finishMetric = true
(m.cs) = 86
{
(m.p)++
goto _out
}
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof88
}
st_case_88:
//line machine.go:2722
goto st0
tr141:
(m.cs) = 39
//line machine.go.rl:78
err = m.handler.SetMeasurement(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr145:
(m.cs) = 39
//line machine.go.rl:91
err = m.handler.AddTag(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st39:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof39
}
st_case_39:
//line machine.go:2755
if (m.data)[(m.p)] == 10 {
goto tr69
}
goto st0
tr142:
(m.cs) = 40
//line machine.go.rl:78
err = m.handler.SetMeasurement(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
tr146:
(m.cs) = 40
//line machine.go.rl:91
err = m.handler.AddTag(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
goto _out
}
}
goto _again
st40:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof40
}
st_case_40:
//line machine.go:2791
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr2
case 92:
goto tr71
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto tr70
tr70:
//line machine.go.rl:20
m.pb = m.p
goto st41
st41:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof41
}
st_case_41:
//line machine.go:2817
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr73
case 92:
goto st44
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st41
tr73:
//line machine.go.rl:87
m.key = m.text()
goto st42
st42:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof42
}
st_case_42:
//line machine.go:2843
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr2
case 92:
goto tr76
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto tr75
tr75:
//line machine.go.rl:20
m.pb = m.p
goto st89
st89:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof89
}
st_case_89:
//line machine.go:2869
switch (m.data)[(m.p)] {
case 10:
goto tr144
case 13:
goto tr145
case 32:
goto tr2
case 44:
goto tr146
case 61:
goto tr2
case 92:
goto st43
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr2
}
goto st89
tr76:
//line machine.go.rl:20
m.pb = m.p
goto st43
st43:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof43
}
st_case_43:
//line machine.go:2899
if (m.data)[(m.p)] == 92 {
goto st90
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st89
st90:
//line machine.go.rl:240
(m.p)--
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof90
}
st_case_90:
//line machine.go:2915
switch (m.data)[(m.p)] {
case 10:
goto tr144
case 13:
goto tr145
case 32:
goto tr2
case 44:
goto tr146
case 61:
goto tr2
case 92:
goto st43
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto tr2
}
goto st89
tr71:
//line machine.go.rl:20
m.pb = m.p
goto st44
st44:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof44
}
st_case_44:
//line machine.go:2945
if (m.data)[(m.p)] == 92 {
goto st45
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st41
st45:
//line machine.go.rl:240
(m.p)--
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof45
}
st_case_45:
//line machine.go:2961
switch (m.data)[(m.p)] {
case 32:
goto tr2
case 44:
goto tr2
case 61:
goto tr73
case 92:
goto st44
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto tr2
}
goto st41
tr68:
//line machine.go.rl:74
m.beginMetric = true
//line machine.go.rl:20
m.pb = m.p
goto st46
st46:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof46
}
st_case_46:
//line machine.go:2991
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 13 {
goto st0
}
goto st87
tr65:
//line machine.go.rl:158
m.lineno++
m.sol = m.p
m.sol++ // next char will be the first column in the line
goto st86
st86:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof86
}
st_case_86:
//line machine.go:3009
switch (m.data)[(m.p)] {
case 10:
goto tr65
case 13:
goto st36
case 32:
goto st86
case 35:
goto st37
}
if 9 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 12 {
goto st86
}
goto tr137
st36:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof36
}
st_case_36:
if (m.data)[(m.p)] == 10 {
goto tr65
}
goto st0
st37:
if (m.p)++; (m.p) == (m.pe) {
goto _test_eof37
}
st_case_37:
if (m.data)[(m.p)] == 10 {
goto tr65
}
goto st37
st_out:
_test_eof47:
(m.cs) = 47
goto _test_eof
_test_eof1:
(m.cs) = 1
goto _test_eof
_test_eof2:
(m.cs) = 2
goto _test_eof
_test_eof3:
(m.cs) = 3
goto _test_eof
_test_eof4:
(m.cs) = 4
goto _test_eof
_test_eof5:
(m.cs) = 5
goto _test_eof
_test_eof6:
(m.cs) = 6
goto _test_eof
_test_eof7:
(m.cs) = 7
goto _test_eof
_test_eof48:
(m.cs) = 48
goto _test_eof
_test_eof49:
(m.cs) = 49
goto _test_eof
_test_eof50:
(m.cs) = 50
goto _test_eof
_test_eof8:
(m.cs) = 8
goto _test_eof
_test_eof9:
(m.cs) = 9
goto _test_eof
_test_eof10:
(m.cs) = 10
goto _test_eof
_test_eof11:
(m.cs) = 11
goto _test_eof
_test_eof51:
(m.cs) = 51
goto _test_eof
_test_eof52:
(m.cs) = 52
goto _test_eof
_test_eof53:
(m.cs) = 53
goto _test_eof
_test_eof54:
(m.cs) = 54
goto _test_eof
_test_eof55:
(m.cs) = 55
goto _test_eof
_test_eof56:
(m.cs) = 56
goto _test_eof
_test_eof57:
(m.cs) = 57
goto _test_eof
_test_eof58:
(m.cs) = 58
goto _test_eof
_test_eof59:
(m.cs) = 59
goto _test_eof
_test_eof60:
(m.cs) = 60
goto _test_eof
_test_eof61:
(m.cs) = 61
goto _test_eof
_test_eof62:
(m.cs) = 62
goto _test_eof
_test_eof63:
(m.cs) = 63
goto _test_eof
_test_eof64:
(m.cs) = 64
goto _test_eof
_test_eof65:
(m.cs) = 65
goto _test_eof
_test_eof66:
(m.cs) = 66
goto _test_eof
_test_eof67:
(m.cs) = 67
goto _test_eof
_test_eof68:
(m.cs) = 68
goto _test_eof
_test_eof69:
(m.cs) = 69
goto _test_eof
_test_eof70:
(m.cs) = 70
goto _test_eof
_test_eof12:
(m.cs) = 12
goto _test_eof
_test_eof13:
(m.cs) = 13
goto _test_eof
_test_eof14:
(m.cs) = 14
goto _test_eof
_test_eof15:
(m.cs) = 15
goto _test_eof
_test_eof16:
(m.cs) = 16
goto _test_eof
_test_eof71:
(m.cs) = 71
goto _test_eof
_test_eof17:
(m.cs) = 17
goto _test_eof
_test_eof18:
(m.cs) = 18
goto _test_eof
_test_eof72:
(m.cs) = 72
goto _test_eof
_test_eof73:
(m.cs) = 73
goto _test_eof
_test_eof74:
(m.cs) = 74
goto _test_eof
_test_eof75:
(m.cs) = 75
goto _test_eof
_test_eof76:
(m.cs) = 76
goto _test_eof
_test_eof77:
(m.cs) = 77
goto _test_eof
_test_eof78:
(m.cs) = 78
goto _test_eof
_test_eof79:
(m.cs) = 79
goto _test_eof
_test_eof80:
(m.cs) = 80
goto _test_eof
_test_eof19:
(m.cs) = 19
goto _test_eof
_test_eof20:
(m.cs) = 20
goto _test_eof
_test_eof21:
(m.cs) = 21
goto _test_eof
_test_eof81:
(m.cs) = 81
goto _test_eof
_test_eof22:
(m.cs) = 22
goto _test_eof
_test_eof23:
(m.cs) = 23
goto _test_eof
_test_eof24:
(m.cs) = 24
goto _test_eof
_test_eof82:
(m.cs) = 82
goto _test_eof
_test_eof25:
(m.cs) = 25
goto _test_eof
_test_eof26:
(m.cs) = 26
goto _test_eof
_test_eof83:
(m.cs) = 83
goto _test_eof
_test_eof84:
(m.cs) = 84
goto _test_eof
_test_eof27:
(m.cs) = 27
goto _test_eof
_test_eof28:
(m.cs) = 28
goto _test_eof
_test_eof29:
(m.cs) = 29
goto _test_eof
_test_eof30:
(m.cs) = 30
goto _test_eof
_test_eof31:
(m.cs) = 31
goto _test_eof
_test_eof32:
(m.cs) = 32
goto _test_eof
_test_eof33:
(m.cs) = 33
goto _test_eof
_test_eof34:
(m.cs) = 34
goto _test_eof
_test_eof35:
(m.cs) = 35
goto _test_eof
_test_eof85:
(m.cs) = 85
goto _test_eof
_test_eof38:
(m.cs) = 38
goto _test_eof
_test_eof87:
(m.cs) = 87
goto _test_eof
_test_eof88:
(m.cs) = 88
goto _test_eof
_test_eof39:
(m.cs) = 39
goto _test_eof
_test_eof40:
(m.cs) = 40
goto _test_eof
_test_eof41:
(m.cs) = 41
goto _test_eof
_test_eof42:
(m.cs) = 42
goto _test_eof
_test_eof89:
(m.cs) = 89
goto _test_eof
_test_eof43:
(m.cs) = 43
goto _test_eof
_test_eof90:
(m.cs) = 90
goto _test_eof
_test_eof44:
(m.cs) = 44
goto _test_eof
_test_eof45:
(m.cs) = 45
goto _test_eof
_test_eof46:
(m.cs) = 46
goto _test_eof
_test_eof86:
(m.cs) = 86
goto _test_eof
_test_eof36:
(m.cs) = 36
goto _test_eof
_test_eof37:
(m.cs) = 37
goto _test_eof
_test_eof:
{
}
if (m.p) == (m.eof) {
switch m.cs {
case 8, 38:
//line machine.go.rl:24
err = ErrNameParse
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
case 2, 3, 4, 5, 6, 7, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26:
//line machine.go.rl:31
err = ErrFieldParse
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
case 27, 28, 29, 31, 33, 34, 40, 41, 42, 43, 44, 45:
//line machine.go.rl:38
err = ErrTagParse
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
case 11:
//line machine.go.rl:45
err = ErrTimestampParse
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
case 87:
//line machine.go.rl:78
err = m.handler.SetMeasurement(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
case 89, 90:
//line machine.go.rl:91
err = m.handler.AddTag(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
case 48, 49, 50, 52:
//line machine.go.rl:170
m.finishMetric = true
case 47:
//line machine.go.rl:74
m.beginMetric = true
//line machine.go.rl:170
m.finishMetric = true
case 1:
//line machine.go.rl:78
err = m.handler.SetMeasurement(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
//line machine.go.rl:38
err = ErrTagParse
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
case 30, 32:
//line machine.go.rl:91
err = m.handler.AddTag(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
//line machine.go.rl:38
err = ErrTagParse
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
case 75:
//line machine.go.rl:104
err = m.handler.AddInt(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
//line machine.go.rl:170
m.finishMetric = true
case 78:
//line machine.go.rl:113
err = m.handler.AddUint(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
//line machine.go.rl:170
m.finishMetric = true
case 71, 72, 73, 74, 76, 77, 79:
//line machine.go.rl:122
err = m.handler.AddFloat(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
//line machine.go.rl:170
m.finishMetric = true
case 80, 81, 82, 83, 84:
//line machine.go.rl:131
err = m.handler.AddBool(m.key, m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
//line machine.go.rl:170
m.finishMetric = true
case 51, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70:
//line machine.go.rl:149
err = m.handler.SetTimestamp(m.text())
if err != nil {
(m.p)--
(m.cs) = 35
{
(m.p)++
(m.cs) = 0
goto _out
}
}
//line machine.go.rl:170
m.finishMetric = true
//line machine.go:3322
}
}
_out:
{
}
}
//line machine.go.rl:407
if err != nil {
return err
}
// This would indicate an error in the machine that was reported with a
// more specific error. We return a generic error but this should
// possibly be a panic.
if m.cs == 0 {
m.cs = LineProtocol_en_discard_line
return ErrParse
}
// If we haven't found a metric line yet and we reached the EOF, report it
// now. This happens when the data ends with a comment or whitespace.
//
// Otherwise we have successfully parsed a metric line, so if we are at
// the EOF we will report it the next call.
if !m.beginMetric && m.p == m.pe && m.pe == m.eof {
return EOF
}
return nil
}
// Position returns the current byte offset into the data.
func (m *machine) Position() int {
return m.p
}
// LineOffset returns the byte offset of the current line.
func (m *machine) LineOffset() int {
return m.sol
}
// LineNumber returns the current line number. Lines are counted based on the
// regular expression `\r?\n`.
func (m *machine) LineNumber() int {
return m.lineno
}
// Column returns the current column.
func (m *machine) Column() int {
lineOffset := m.p - m.sol
return lineOffset + 1
}
func (m *machine) text() []byte {
return m.data[m.pb:m.p]
}
type streamMachine struct {
machine *machine
reader io.Reader
}
func NewStreamMachine(r io.Reader, handler Handler) *streamMachine {
m := &streamMachine{
machine: NewMachine(handler),
reader: r,
}
m.machine.SetData(make([]byte, 1024))
m.machine.pe = 0
m.machine.eof = -1
return m
}
func (m *streamMachine) Next() error {
// Check if we are already at EOF, this should only happen if called again
// after already returning EOF.
if m.machine.p == m.machine.pe && m.machine.pe == m.machine.eof {
return EOF
}
copy(m.machine.data, m.machine.data[m.machine.p:])
m.machine.pe = m.machine.pe - m.machine.p
m.machine.sol = m.machine.sol - m.machine.p
m.machine.pb = 0
m.machine.p = 0
m.machine.eof = -1
m.machine.key = nil
m.machine.beginMetric = false
m.machine.finishMetric = false
for {
// Expand the buffer if it is full
if m.machine.pe == len(m.machine.data) {
expanded := make([]byte, 2*len(m.machine.data))
copy(expanded, m.machine.data)
m.machine.data = expanded
}
n, err := m.reader.Read(m.machine.data[m.machine.pe:])
if n == 0 && err == io.EOF {
m.machine.eof = m.machine.pe
} else if err != nil && err != io.EOF {
return err
}
m.machine.pe += n
err = m.machine.exec()
if err != nil {
return err
}
// If we have successfully parsed a full metric line break out
if m.machine.finishMetric {
break
}
}
return nil
}
// Position returns the current byte offset into the data.
func (m *streamMachine) Position() int {
return m.machine.Position()
}
// LineOffset returns the byte offset of the current line.
func (m *streamMachine) LineOffset() int {
return m.machine.LineOffset()
}
// LineNumber returns the current line number. Lines are counted based on the
// regular expression `\r?\n`.
func (m *streamMachine) LineNumber() int {
return m.machine.LineNumber()
}
// Column returns the current column.
func (m *streamMachine) Column() int {
return m.machine.Column()
}
// LineText returns the text of the current line that has been parsed so far.
func (m *streamMachine) LineText() string {
return string(m.machine.data[0:m.machine.p])
}