parser

Documentation

Index

• type JsonParser
  • func (parser *JsonParser) DecodeMeasurement(input []byte) (protocol.MeasureArgument, error)
  • func (parser *JsonParser) EncodeResponse(myResponse *protocol.Response) ([]byte, error)
• type Parser
• type TextParser
  • func (parser *TextParser) DecodeMeasurement(input []byte) (protocol.MeasureArgument, error)
  • func (parser *TextParser) EncodeResponse(myResponse *protocol.Response) ([]byte, error)

Types

type JsonParser

type JsonParser struct {
}

func (*JsonParser) DecodeMeasurement

func (parser *JsonParser) DecodeMeasurement(input []byte) (protocol.MeasureArgument, error)

func (*JsonParser) EncodeResponse

func (parser *JsonParser) EncodeResponse(myResponse *protocol.Response) ([]byte, error)

type Parser

type Parser interface {
	DecodeMeasurement(input []byte) (protocol.MeasureArgument, error)
	EncodeResponse(myResponse *protocol.Response) ([]byte, error)
}

type TextParser

type TextParser struct {
}

func (*TextParser) DecodeMeasurement

func (parser *TextParser) DecodeMeasurement(input []byte) (protocol.MeasureArgument, error)

In this function, it firstly transform the input byte stream into a map of string -> interface{}. If it manages so, it would extract the required variable as defined in the protocol. Otherwise it would return an un-empty error.

func (*TextParser) EncodeResponse

func (parser *TextParser) EncodeResponse(myResponse *protocol.Response) ([]byte, error)