| 54 | var kafkaReqNumber uint32 = 1 |
| 55 | |
| 56 | func decodeTimed(msg []byte) (senml.SenML, error) { |
| 57 | var s senml.SenML |
| 58 | var err error |
| 59 | |
| 60 | var format senml.Format = senml.JSON |
| 61 | switch { |
| 62 | case *doIJsonStreamPtr: |
| 63 | format = senml.JSON |
| 64 | case *doIJsonLinePtr: |
| 65 | format = senml.JSON |
| 66 | case *doICborPtr: |
| 67 | format = senml.CBOR |
| 68 | case *doIXmlPtr: |
| 69 | format = senml.XML |
| 70 | case *doIMpackPtr: |
| 71 | format = senml.MPACK |
| 72 | } |
| 73 | |
| 74 | s, err = senml.Decode(msg, format) // TODO |
| 75 | |
| 76 | return s, err |
| 77 | } |
| 78 | |
| 79 | func outputData(data []byte) error { |
| 80 | // print the output |