885 Commits

Author SHA1 Message Date
Andrii Shvaika
3cdc933b67 Merge improvements 2025-02-18 13:02:48 +02:00
ViacheslavKlimov
6dd08276f8 Merge branch 'rc' of github.com:thingsboard/thingsboard 2025-02-14 13:45:35 +02:00
ViacheslavKlimov
bb7ea08e59 EDQS: refactoring, OOM handling, healthcheck 2025-02-14 12:08:05 +02:00
ViacheslavKlimov
f342bd989e Minor improvements 2025-02-13 15:31:09 +02:00
ViacheslavKlimov
677385e8ba CF states restore from Kafka 2025-02-13 13:01:17 +02:00
Andrii Shvaika
d75bc3ac28 Minor improvements 2025-02-11 12:47:37 +02:00
Volodymyr Babak
1b4930ebaf Introduced separate count for edge consumers 2025-02-10 18:51:13 +02:00
Volodymyr Babak
3860d79613 Improved Edge handling in case connect/disconnect. Speed up initial setup 2025-02-10 18:42:25 +02:00
Andrii Shvaika
5efb94dc7a Refactoring 2025-02-10 15:58:01 +02:00
Andrii Landiak
b54e0cd59c Rename tbEdgeEventNotificationsTopic 2025-02-07 16:12:53 +02:00
Andrii Landiak
8de861f897 Improve customization for edge-event topic 2025-02-07 16:11:33 +02:00
Andrii Shvaika
407511be52 Cache implementation 2025-02-05 12:51:50 +02:00
dashevchenko
b2bf5b9f65 configurable edqs sync batch sizes 2025-02-05 12:20:23 +02:00
Andrii Landiak
e3a72fec09 Refactor TopicService. Change ymls to be able to configure notification topic names 2025-02-04 12:39:06 +02:00
dashevchenko
0e9d0b3ba3 fixed EntityServiceTest 2025-02-03 18:27:36 +02:00
ViacheslavKlimov
c8db304ce6 Optimized postgres sync (#3208)
* optimized postgres sync

* Fix consumer stopping when stopWhenRead enabled

* Fix NPE on EDQS repartitioning

* fixed EntityServiceTest

* Fix EDQS yml props

---------

Co-authored-by: ViacheslavKlimov <viacheslavklimov11@gmail.com>
2025-01-30 12:43:14 +02:00
IrynaMatveieva
71bb1c0250 merge with upstream 2025-01-28 09:51:30 +02:00
Viacheslav Klimov
86b5378d59 EDQS (#3196)
* Experiments with CSV

* CSV Loader v1

* EDQ tests

* Volatile variables instead of final

* Improvements

* updated loader with new entities

* Fix double memory usage issue

* Basic data structures and load

* Minor improvements

* Snappy + Large String reuse

* added EntityFields classes for each entity

* Basic implementation

* Minor improvements to KeyFilters

* implemented RepositoryUtils.checkKeyFilters

* Generic query implementation

* New structure

* Refactoring and few processors implementation

* extended DeviceData with shared/client attributes and device profile

* Minor refactoring of attribute scopes

* DeviceTypeFilter support

* Strong types of fields for each entity data class

* DeviceType and AssetType filters

* EntityView and Edge queries

* Relations Query

* Relation Query Implementation

* Update EDQS module version

* Sync with EDQS via Kafka

* EDQS: major refactoring

* EDQS API requests via Kafka

* EDQS: full sync with the database

* Refactoring for EDQS sync

* EDQS: major refactoring and new features

* EDQS refactoring, count query support, fix tests

* EDQS: refactoring for query processors

* Fix EDQS pom version

* Cleanup edqs.yml

* EDQS: tenant partitioning strategy; refactoring

* EDQS: latest events queue

* EDQS: support for monolith setup; RocksDB; other improvements

* EDQS: merge sync and events topics, introduce state topic

* EDQS: dynamic repartitioning

* implemented entity data query filters for edqs

* EdqsEntityQueryControllerTest - use in-memory queue

* edqs-filter fixes, added test

* EDQS: blob entity support

* EdqsEntityQueryControllerTest - use in-memory queue

* Use DummyEdqsService when disabled

* Fixes for EDQS

* Refactoring for EDQS tests

* Fix edqs requests partitioning

* EDQS: Fix for attributes handling

* Fix attributes saving in EntityServiceTest

* EDQS: refactoring, fixes

* Minor refactoring for query processor

* added ownerName/ownerType support

* fixed relation query processor

* fixed EntityServiceTest

* refactoring

* added support for parentId for relation query result

* Get rid of EntityNameFetcher

* Add fixme for relation query processor

* db restore with select all edqs fields

* fixed entity deletion

* fixed FieldUtils with new EntityFields

* dao method renamed

* EDQS: instance groups with same partitions; automatic sync; multiple fixes

* Refactoring for EDQS sync

* EDQS: refactoring

* Fix startup with Kafka

* fixed EntityQueryControllerTest

* fixed EdqsEntityServiceTest

* Separate queue admin for EDQS request template

* Implement new EDQS partitioning strategy

* EDQS: multiple fixes and refactoring

* Add mock EdqsRocksDb beans to tests

* added edqs stats for inmemory/grafana

* fixed filter tests

* Update todos

* Refactoring for QueueConfig

* Improvements and refactoring for EDQS consumers

* implemented TODOs

* test fixes

* Consume state topic up to end offsets

* edqs stats refactoring

* EDQS: cleanup on partitions removal; refactoring

* EDQS: minor refactoring

* EDQS: remove CSV loader

---------

Co-authored-by: Andrii Shvaika <ashvayka@thingsboard.io>
Co-authored-by: dashevchenko <dshevchenko@thingsboard.io>
2025-01-27 17:41:12 +02:00
Andrii Shvaika
d3278f05bb WIP: Cluster mode refactoring 2025-01-27 17:34:35 +02:00
IrynaMatveieva
0e1cd69e34 updated cf consumer 2025-01-27 15:55:40 +02:00
IrynaMatveieva
5641626443 added processNotification impl 2025-01-24 10:53:13 +02:00
IrynaMatveieva
69dc8b4b5d merge with upstream 2025-01-23 15:56:25 +02:00
IrynaMatveieva
2cc0d6f513 added implementations for consumer/producer methods 2025-01-23 15:49:31 +02:00
Andrii Shvaika
4c71b9d5f6 WIP: Cluster mode implementation 2025-01-23 13:56:44 +02:00
Andrii Shvaika
069725a2b9 WIP Refactoring of the cluster mode 2025-01-23 10:43:26 +02:00
Andrii Shvaika
6b9d374a5f Tmp commit for merge 2025-01-22 12:23:42 +02:00
YevhenBondarenko
933d1447d2 refactoring due to comments (removed serviceId duplications in ToUsageStatsServiceMsgPack) 2025-01-14 12:08:53 +01:00
YevhenBondarenko
87f0483019 merge with master 2025-01-13 19:27:17 +01:00
ViacheslavKlimov
d4d3240f78 Merge branch 'master' of github.com:thingsboard/thingsboard into develop/4.0 2024-12-23 11:15:16 +02:00
ViacheslavKlimov
1ea5fdf7fe Merge branch 'master' of github.com:thingsboard/thingsboard into feature/tbmsg-refactoring 2024-12-23 10:51:11 +02:00
YevhenBondarenko
e0fd611c76 used TbMsgProto instead of ByteString 2024-12-13 14:35:02 +01:00
ViacheslavKlimov
e4cc2b4f9f Introduce TbMsgTransformer 2024-12-13 13:23:15 +02:00
YevhenBondarenko
dcf4eb2793 refactored due to comments 2024-12-10 16:04:11 +01:00
ViacheslavKlimov
e920525456 Merge branch 'master' of github.com:thingsboard/thingsboard into develop/4.0 2024-12-05 11:26:34 +02:00
YevhenBondarenko
eaafdf1f87 implemented sending api usages in pack 2024-12-04 17:05:37 +01:00
Igor Kulikov
77d2826f96 Version set to 4.0.0-SNAPSHOT 2024-12-04 16:53:19 +02:00
Igor Kulikov
190bba72f9 Temp Version set to 3.9.0-RC 2024-12-04 16:52:14 +02:00
Igor Kulikov
8ac0468edd Version set to 4.0.0-SNAPSHOT 2024-12-04 16:51:03 +02:00
Igor Kulikov
cca4ac3629 Version set to 3.9.0-RC 2024-12-04 16:44:31 +02:00
Dmytro Skarzhynets
68aaf3c918 Merge branch 'master' into safe-scheduler
# Conflicts:
#	common/util/src/main/java/org/thingsboard/common/util/ThingsBoardExecutors.java
2024-12-02 17:43:07 +02:00
Andrii Landiak
988dfce500 Refactor KafkaEdgeTopicsCleanUpService to properly clean up both deleted edges and expired topics 2024-11-29 15:18:27 +02:00
Andrii Landiak
63b53a4a45 Final improvement after review 2024-11-28 16:51:55 +02:00
Andrii Landiak
76bed44705 Minor improvement 2024-11-28 15:16:20 +02:00
Andrii Landiak
b796355554 Merge remote-tracking branch 'upstream/master' into feature/edge-kafka-events 2024-11-26 09:42:31 +02:00
Andrii Landiak
c388034d01 Delete EdgeGrpcSession interface: use abstract instead 2024-11-22 10:26:06 +02:00
Andrii Landiak
b981281205 Fix tests 2024-11-01 11:37:11 +02:00
Andrii Landiak
50a55d15a9 Add poll properties for edge-event kafka poll 2024-10-31 18:12:16 +02:00
Andrii Landiak
38eeada8ec Implement clean up service to clear empty edge topics 2024-10-30 12:29:07 +02:00
ViacheslavKlimov
12ca1739d4 Remove all queue types except Kafka 2024-10-23 15:30:07 +03:00
Andrii Landiak
3ecbd3258e Introduce kafka approach to work with edge-event instead of postgres 2024-10-22 12:38:57 +03:00