Andrii Shvaika
638ca0e1d1
Refactoring to multiple queues for rule engine
2020-04-06 18:35:43 +03:00
Igor Kulikov
7e8c90ec6d
Merge branch 'master' into develop/3.0
2020-04-01 09:48:16 +03:00
VoBa
d94cb9ca47
Added correct ts on alarm clear and ack actions ( #2550 )
2020-04-01 09:33:46 +03:00
Yevhen Bondarenko
b39328c989
[2.5]fix ConcurrentModificationException ( #2560 )
...
* fix ConcurrentModificationException
* kafka consumer improvements
* kafka consumer improvements
* refactored kafka consumer
* refactored kafka consumer
2020-03-31 16:47:43 +03:00
Yevhen Bondarenko
a6e090ef86
Develop/2.5 pubsub ( #2566 )
...
* created Aws Sqs Queue
* improvement AwsSqs providers
* created pubsub queue
* revert package-lock.json
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* Created pubsub queue
* aws improvements
* aws improvements
* aws improvements
* added visibility timeout to aws queue
* pub sub improvements
* pub sub improvements
* aws sqs improvements
* pub sub improvements
* added comment to transport.yml about ack deadline
2020-03-31 16:39:41 +03:00
Yevhen Bondarenko
2553cf6b6f
created Aws Sqs Queue ( #2534 )
...
* created Aws Sqs Queue
* improvement AwsSqs providers
* revert package-lock.json
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* aws improvements
* aws improvements
* aws improvements
* added visibility timeout to aws queue
2020-03-30 19:13:34 +03:00
Andrii Shvaika
c4269023dd
Fixed Conditional annotations
2020-03-28 02:30:37 +02:00
Andrii Shvaika
6fe25a2ee2
Refactoring to support TB-Rule-Engine service
2020-03-28 01:42:17 +02:00
Volodymyr Babak
f3aa410c17
Merge branch 'feature/edge' into develop/3.0-edge
2020-03-25 23:27:26 +02:00
Andrii Shvaika
7531a26e61
Implementation of RPC Call support
2020-03-25 22:11:47 +02:00
Andrii Shvaika
07bdcac0fe
Refactoring of Rule Engine API
2020-03-24 19:18:27 +02:00
Andrii Shvaika
2ccce3b6d9
Main Logic of RuleChainActor to handle queue messages
2020-03-24 14:08:21 +02:00
Volodymyr Babak
bfb25845e9
Merge branch 'develop/3.0' into develop/3.0-edge
2020-03-24 11:50:34 +02:00
Andrii Shvaika
99d322d449
Refactoring of the rule engine
2020-03-24 10:35:54 +02:00
Andrii Shvaika
ce6ec88983
Refactoring of the websocket and subscription services
2020-03-20 18:00:57 +02:00
Andrii Shvaika
e102b55bc1
Thread-safety usage of Kafka Consumer
2020-03-18 18:39:34 +02:00
Andrii Shvaika
7203e7aa19
Distributed Mode fixes
2020-03-18 18:07:24 +02:00
Volodymyr Babak
660b7fc62b
Merge branch 'feature/edge' into feature/edge-last-week
2020-03-17 18:56:46 +02:00
Volodymyr Babak
f5034b4dcd
Merge remote-tracking branch 'upstream/master' into feature/edge
2020-03-17 18:43:22 +02:00
Andrii Shvaika
94eb213716
Implementation
2020-03-17 18:38:09 +02:00
Andrii Shvaika
7de485f453
Kafka configuration
2020-03-17 14:26:44 +02:00
Andrii Shvaika
2a815058e7
Improvements and bugfix to QueueProviders
2020-03-17 12:38:28 +02:00
Andrii Shvaika
23c017567b
Implementation of Queue Interfaces
2020-03-16 19:24:56 +02:00
Andrii Shvaika
6f532fe189
Merge with develop
2020-03-13 20:34:04 +02:00
Andrii Shvaika
e50796d84e
Service Discovery improvements
2020-03-13 20:33:17 +02:00
Volodymyr Babak
69ba71be27
Added init service on edge connect
2020-03-13 19:16:36 +02:00
Yevhen Bondarenko
dc6081d820
Created kafka and in-memory queue providers
...
* Created kafka and in-memory queue providers
* Added header requestTime
* refactored
2020-03-13 17:31:58 +02:00
Andrii Shvaika
c4c53bfbd8
Transport Implementation
2020-03-12 14:37:38 +02:00
Andrii Shvaika
fa9194c1c1
Core consumer service implementation
2020-03-12 11:11:56 +02:00
Andrii Shvaika
52814d2bfc
Refactoring of Transport Communication to Queues
2020-03-12 09:36:48 +02:00
Andrii Shvaika
6e31c0ab15
Refactoring of configuration properties
2020-03-11 20:09:41 +02:00
YevhenBondarenko
4ad4fe11da
created in memory queue
2020-03-11 17:35:31 +02:00
Igor Kulikov
957a0c9e61
Merge with master
2020-03-11 14:14:46 +02:00
Andrii Shvaika
f8cc5b3cd2
Transport service refactoring
2020-03-10 17:47:16 +02:00
YevhenBondarenko
d68ef2333a
updated guava and protobuf versions
2020-03-10 16:14:01 +02:00
Andrii Shvaika
7b2bdeab23
Refactoring of Transport Interfaces
2020-03-10 14:03:06 +02:00
Andrii Shvaika
a39e8c3756
Queue Implementation
2020-03-10 12:34:05 +02:00
Andrii Shvaika
b7c652ab07
Refactoring of Queue Interfaces
2020-03-09 18:23:44 +02:00
Volodymyr Babak
6751c511f1
Added default edge root rule chain
2020-03-09 13:57:38 +02:00
Volodymyr Babak
451c158742
Added EDGE backend support
2020-03-03 12:25:44 +02:00
Igor Kulikov
bcbc089460
Merge Alarms fetch improvements
2020-02-21 16:31:03 +02:00
Igor Kulikov
96d3b245b0
Revert to version 3.0.0-SNAPSHOT
2020-02-20 12:35:01 +02:00
Igor Kulikov
e9b2c3107e
Merge with master
2020-02-20 12:33:36 +02:00
Igor Kulikov
3e2a87135f
Prepare for merge with master
2020-02-20 10:26:43 +02:00
blackstar-baba
0fa963be85
fix bug:Device reconnect abnormal when certificate authentication is turned on
2020-02-19 14:56:44 +02:00
Andrew Shvayka
03f5375a02
JSON support ( #2415 )
...
* Created JsonDataEntry and added DataType JSON
* Added json to ts and attributes, created sql schema-entities-hsql.sql (json_v varchar)
* refactored
* refactored
* added json array support
* Aggregation improvement
* Changed in JsonDataEntry value type from JsonNode to String
* fix AggregatePartitionsFunction
Co-authored-by: Yevhen Bondarenko <56396344+YevhenBondarenko@users.noreply.github.com>
2020-02-14 19:18:18 +02:00
ShvaykaD
3955600a9c
bug fixes & improvements / sql-timeseries ( #2382 )
...
* fixed the partion date extracting
* fix imports
* ts-keys dictionary for latest, hsqldb
* removed AbstractSimpleSqlTimeseriesDao class & fix beanCreationException in ThingsboardInstallService
* timescale-db upgrade added
* added postgreSQL upgrade
* fix logging
* refactoring timeseries-dao implementation
2020-02-07 15:39:04 +02:00
Volodymyr Babak
c409e2d9c1
Rule chains refactoring:
2020-02-06 19:29:49 +02:00
Dmytro Shvaika
41cbdd154e
fixed the partion date extracting
2020-01-30 14:55:50 +02:00
ShvaykaD
84cb471e0d
Sql timeseries improvements ( #2033 )
...
* init commit
* cleaned code and add test-properties
* cleaned code
* psql-update
* timescale-update
* code-refactoring
* fix typo
* renamed dao
* revert indents
* refactored code
* fix typo
* init-partitioning
* code updated
* cleaned code
* fixed license
* fix typo
* fixed code after review
* add annotation to repository
* update psql version for docker
* postgres-10
* postgres-10
* update docker compose config
* fixed partition saving
* change key_id to serial column definition
* upgrade psql added
* add separate upgrade service
* added upgrade script
* change image on k8s
* change logs
* resolve conflict after merge with master
* revert datasource url in yml
* fix typo
* license header fix
* remove old methods for the timeseries inserts
* clean up code
* fix saveOrUpdate for PostgreSQL
* refactoring & revert Timescale to use latest table
* added PsqlTsAnyDao
* duplicated code method removed
* remove unused invert dictionary map
* change the upgrade directory from 2.4.1 to 2.4.3
* refactor JpaPsqlTimeseriesDao
2020-01-29 17:06:51 +02:00