452b1e332d
Migrating to keda2.0 ( #1868 )
...
Co-authored-by: Rahul Bhati <rjbhati009@gmail.com >
Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com >
2021-02-05 10:28:54 +05:30
f1ce32e9d3
Put message to error topic when exceed max retries in kafka mqt ( #1885 )
...
Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com >
Co-authored-by: Rahul Bhati <rjbhati009@gmail.com >
2021-02-02 23:20:40 +05:30
Gaurav Gahlot and GitHub
6758a04dbd
Fixed golangci-lint issues: /fission/pkg ( #1902 )
2021-01-19 23:29:20 +05:30
Tosone and GitHub
5155dc72ad
Remove unnecessary import package. ( #1897 )
2020-12-28 18:48:02 +05:30
Rahul Bhati and GitHub
9acf5b143f
Added flag for insecureSkipVerfiy ( #1829 )
2020-10-13 21:03:19 +05:30
0c6f86b6cc
Add headers to Kafka MQT error topics ( #1701 )
...
Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com >
2020-09-07 19:13:36 +05:30
Rahul Bhati and GitHub
c6b7145080
Removed code related to mqtrigger ( #1680 )
2020-08-06 20:59:08 +05:30
Rahul Bhati and GitHub
a01cf1e3d5
Fission MQT integration with keda ( #1657 )
...
Fission MQT integration based on Keda with Kafka connector
2020-07-14 21:35:48 +05:30
063739948f
Fixing verify-staticcheck.sh ( #1622 )
...
Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com >
2020-06-04 15:16:09 +05:30
9a4efa3f1e
External nats streaming ( #1576 )
...
Support for external NATS streaming instead of the one deployed with Fission
Co-authored-by: Shaun Cutts <shaunc@factfiber.com >
2020-04-19 21:53:27 +05:30
Ta-Ching Chen and GitHub
baaeb321ff
Add message queue service factory ( #1537 )
2020-02-20 23:30:39 +08:00
Ta-Ching Chen and GitHub
26a2889476
Update NATS-Streaming dependencies version ( #1533 )
2020-02-12 20:35:20 +08:00
Ta-Ching Chen and GitHub
81eb541442
Fix Git issue on case-insensitive OS ( #1532 )
2020-02-12 16:08:05 +08:00
Ta-Ching Chen and GitHub
72a7d490c6
Reorganize message queue trigger directory structure ( #1531 )
2020-02-12 15:40:00 +08:00
Ta-Ching Chen and GitHub
6379559c78
Follow kubernetes APIs directory structure ( #1497 )
2020-01-20 17:06:46 +08:00
Ta-Ching Chen and GitHub
301fe0b249
Codebase cleanup & optimization ( #1493 )
...
Remove old v1 types that are no longer used and move fetcher structs to fetcher directory.
2020-01-16 16:47:32 +08:00
Ta-Ching Chen and GitHub
308ba054a9
Use code-generator to generate clientset/informer/lister ( #1492 )
...
To reduce maintenance effort and avoid writing duplicate informer code,
use code-generator to generate clientset/informer/lister code.
2020-01-16 15:18:38 +08:00
Ta-Ching Chen and GitHub
3a1ad91658
Update staticcheck version and fix all warnings ( #1381 )
2019-11-05 18:09:12 +08:00
Vivek Singh and Ta-Ching Chen
795c1f1e6d
Calling the function that handles kafka messages, asynchronously ( #1355 )
2019-10-19 14:41:46 +08:00
Suraj Banakar and Ta-Ching Chen
48df99eacf
Implement TLS authentication for kafka mqt ( #1300 )
...
* use secrets to store keys and certificates
2019-10-10 00:18:57 +08:00
Suraj Banakar and Ta-Ching Chen
7cec1c2b55
Fix kafka producer and consumer logs show empty objects ( #1281 )
2019-09-29 23:47:05 +08:00
Suraj Banakar and Ta-Ching Chen
161e084c8e
Fix typo "consumer" => "producer" ( #1278 )
2019-08-20 19:45:56 +08:00
cocoifly10 and Ta-Ching Chen
c69782b842
Fix Kafka message queue trigger panic problem caused by err.Error() ( #1271 )
...
fix bug: panic: runtime error: invalid memory address or nil pointer dereference
2019-08-14 17:07:29 +08:00
Ta-Ching Chen and GitHub
09df6c8e3e
Change log-level for better performance and less annoying logs ( #1231 )
...
This PR removes not so useful logs and changes most of Info level
log to Debug/Error level in hot path while preserving some of them
that is helpful for troubleshooting.
2019-07-19 12:38:36 +08:00
Ta-Ching Chen and GitHub
ed4f8a4458
Move packages to proejct/pkg to follow go project folder structure convention ( #1190 )
2019-05-31 16:28:55 +08:00
