(deviceId string, measurements []string, dataTypes []TSDataType, values []interface{}, timestamp int64)
| 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) |
| 708 | if err != nil { |
| 709 | return err |
| 710 | } |
| 711 | r, err := s.client.InsertRecord(context.Background(), request) |
| 712 | |
| 713 | if err != nil && r == nil { |
| 714 | if s.reconnect() { |
| 715 | request.SessionId = s.sessionId |
| 716 | r, err = s.client.InsertRecord(context.Background(), request) |
| 717 | } |
| 718 | } |
| 719 | |
| 720 | if err != nil { |
| 721 | return err |
| 722 | } |
| 723 | return VerifySuccess(r) |
| 724 | } |
| 725 | |
| 726 | func (s *Session) InsertAlignedRecord(deviceId string, measurements []string, dataTypes []TSDataType, values []interface{}, timestamp int64) error { |
| 727 | request, err := s.genTSInsertRecordReq(deviceId, timestamp, measurements, dataTypes, values, true) |
nothing calls this directly
no test coverage detected