Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

MF-1278 - Add kuiper rules engine source and sink #1445

Closed
wants to merge 77 commits into from
Closed

MF-1278 - Add kuiper rules engine source and sink #1445

wants to merge 77 commits into from

Conversation

drasko
Copy link
Contributor

@drasko drasko commented Aug 12, 2021

Pull request title should be MF-XXX - description or NOISSUE - description where XXX is ID of issue that this PR relate to.
Please review the CONTRIBUTING.md file for detailed contributing guidelines.

What does this do?

Adds kuiper rules engine plugins compatible with mainflux message format. The PR adds one source and one sink.

image

Which issue(s) does this PR fix/relate to?

Resolves absmach/magistrala#13

@darkodraskovic
Add kuiper rules engine source and sink
af9c8cc 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add re gokit service skeleton
f359a52 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add create stream endpoint
e14efbd 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Refactor Ping endpoint to Info endpoint
490453b 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add view streams endpoint
a9bf52d 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add view stream endpoint
0d61154 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add update stream request
068394f 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add DATASOURCE topic use to source
0eb4ce8 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add suffix -stream to generic stream related obj names
d6e7642 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Split create and update stream in two methods
06b892e 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Compose sql stream def
aa0c3a3 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add delete stream endpoint
3e491aa 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Replace + string compose with Sprintf
7a8d23f 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add auth and logger to service
1d22019 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add sdk to service struct for get chans and prepend stream name with …
f5bd706 
…chan id

Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add create rule endpoint
de689de 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add list rules and show rule endpoints
d6fee8f 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Merge Update and Create methods for streams and rules
89aca1e 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Merge delete methods for streams and rules
98e092d 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add get rule status endpoint
099187b 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add rule start, stop, restart endpoint
f7e81ec 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Refactor urls to use literal constant part
db4c290 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Merge delete stream and delete rules endpoints
8486e2f 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add env var for kuiper path
5f51bd7 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Fix create/update result leaking internal name
6968480 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add plugins dir to re
741db41 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Update go.mod
7df462e 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Sync vendor
bcf31a6 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add subtopic to source
ee875eb 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Encode source host info in topic
eeb284a 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Move test service constructor to mocks and add commons for endpoint t…
16869af 
…ests

Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add stream creation endpoint tests
ac5c306 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add endpoint tests for rule creation
c8927f6 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add endpoint tests for stream and rule update
f1b2859 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add endpoint tests for stream and rule list
c42af96 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add endpoint tests for view stream, view rule, and rule status
c5c04bc 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add endpoint tests for rule control
0c3fe34 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add first paragraph to README.md
3384095 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Fix README.md file
72fe99e 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add openapi skeleton for rules
6b2aee2 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add docker-compose file
44a4fc2 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Remove hardcoded kuiper protocol
d12f193 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Refactor kuiper to use env var set plugin host and url
e7943a9 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Fix tests
e909c5d 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add Dockerfile to build kuiper and mainflux plugins
d2e8f30 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add complete openapi spec
3b2e2a2 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add +build kuiper tag
a6c8b54 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add vars to .env
10116a5 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Fix linter errors
e23b50f 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add actions and results string dict
6a4b193 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Add newlines and remove unused helper funcs
9c7a0d2 
Signed-off-by: Darko Draskovic <[email protected]>
@darkodraskovic
Remove format string Actions and update Dockerfile
04bb0b2 
Signed-off-by: Darko Draskovic <[email protected]>
@drasko drasko requested a review from a team as a code owner August 12, 2021 17:33
@drasko drasko mentioned this pull request Aug 12, 2021
Closed
@manuio
Copy link
Contributor

manuio commented May 31, 2022

@drasko @dusanb94 Do we have a plan for this PR?

@dborovcanin
Copy link
Collaborator

@drasko @dusanb94 Do we have a plan for this PR?
@manuio I think not. It would take too much effort to continue work on this PR, so I think it's best to close it.

@dborovcanin
Copy link
Collaborator

Since there has been no activity and it would take too much effort to continue work on this PR, I'm closing it.

@dborovcanin dborovcanin deleted the re branch March 13, 2023 12:38
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees

@darkodraskovic darkodraskovic

Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

Magistrala Rules engine
4 participants
@drasko @manuio @dborovcanin @darkodraskovic