* *create multiple time series *params *paths: []string, complete time series paths (starts from root) *dataTypes: []int32, data types for time series *encodings: []int32, encodings for time series *compressors: []int32, compressing types for time series *return *error: correctness of operat
(paths []string, dataTypes []TSDataType, encodings []TSEncoding, compressors []TSCompressionType)
| 370 | *error: correctness of operation |
| 371 | */ |
| 372 | func (s *Session) CreateMultiTimeseries(paths []string, dataTypes []TSDataType, encodings []TSEncoding, compressors []TSCompressionType) error { |
| 373 | destTypes := make([]int32, len(dataTypes)) |
| 374 | for i, t := range dataTypes { |
| 375 | destTypes[i] = int32(t) |
| 376 | } |
| 377 | |
| 378 | destEncodings := make([]int32, len(encodings)) |
| 379 | for i, e := range encodings { |
| 380 | destEncodings[i] = int32(e) |
| 381 | } |
| 382 | |
| 383 | destCompressions := make([]int32, len(compressors)) |
| 384 | for i, e := range compressors { |
| 385 | destCompressions[i] = int32(e) |
| 386 | } |
| 387 | |
| 388 | request := rpc.TSCreateMultiTimeseriesReq{ |
| 389 | SessionId: s.sessionId, Paths: paths, DataTypes: destTypes, |
| 390 | Encodings: destEncodings, Compressors: destCompressions, |
| 391 | } |
| 392 | r, err := s.client.CreateMultiTimeseries(context.Background(), &request) |
| 393 | |
| 394 | if err != nil && r == nil { |
| 395 | if s.reconnect() { |
| 396 | request.SessionId = s.sessionId |
| 397 | r, err = s.client.CreateMultiTimeseries(context.Background(), &request) |
| 398 | } |
| 399 | } |
| 400 | |
| 401 | if err != nil { |
| 402 | return err |
| 403 | } |
| 404 | return VerifySuccess(r) |
| 405 | } |
| 406 | |
| 407 | /* |
| 408 | *delete multiple time series, including data and schema |
nothing calls this directly
no test coverage detected