(deviceId string, time int64,
measurements []string,
types []TSDataType,
values []interface{},
isAligned bool,
)
| 684 | } |
| 685 | |
| 686 | func (s *Session) genTSInsertRecordReq(deviceId string, time int64, |
| 687 | measurements []string, |
| 688 | types []TSDataType, |
| 689 | values []interface{}, |
| 690 | isAligned bool, |
| 691 | ) (*rpc.TSInsertRecordReq, error) { |
| 692 | request := &rpc.TSInsertRecordReq{} |
| 693 | request.SessionId = s.sessionId |
| 694 | request.PrefixPath = deviceId |
| 695 | request.Timestamp = time |
| 696 | request.Measurements = measurements |
| 697 | request.IsAligned = &isAligned |
| 698 | if bys, err := valuesToBytes(types, values, measurements); err == nil { |
| 699 | request.Values = bys |
| 700 | } else { |
| 701 | return nil, err |
| 702 | } |
| 703 | return request, nil |
| 704 | } |
| 705 | |
| 706 | func (s *Session) InsertRecord(deviceId string, measurements []string, dataTypes []TSDataType, values []interface{}, timestamp int64) error { |
| 707 | request, err := s.genTSInsertRecordReq(deviceId, timestamp, measurements, dataTypes, values, false) |
no test coverage detected