Nail/fission-src
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
1,926 Commits 3 Branches 68 Tags
b9bc62b65159f1f3a966fc0e322d99d4b8b5784a
Commit Graph
40 Commits
Author SHA1 Message Date
Sanket SudakeandGitHub 23fdf2de0f Add staticcheck fixes (#3221) 
* Add staticcheck fixes

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

* update golangci-lint version

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

---------

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2025-05-18 22:27:45 +05:30
Sanket SudakeandGitHub 4a6c8d9bc8 Remove github.com/pkg/errors with appropriate replacements (#3172) 
* errors.Wrap* removal

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

* remove errors.Errorf

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

* Remove remaining calls

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

* Few more errors

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

* Fix golint errors

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

---------

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2025-02-20 08:58:37 +05:30
soharab-icandGitHub fa014acafd Upgraded to Go latest version 1.23.1 (#3027) 
* Upgraded to latest go version 1.23.1
* Fix lint failure
* Fix lint failures
* Remove unnecessary formatting

---------

Signed-off-by: Md Soharab Ansari <soharab.ansari@infracloud.io>
 2024-09-30 19:33:10 +05:30
soharab-icandGitHub e8dc8dfeef Fixed mqtrigger scaling issue (#2986) 
* Fixed mqtrigger scaling issue

Signed-off-by: Md Soharab Ansari <soharab.ansari@infracloud.io>

* Resolve review comments

Signed-off-by: Md Soharab Ansari <soharab.ansari@infracloud.io>

* Set goreleaser version to v1
Remove armv7 references from goreleaser file

Signed-off-by: Md Soharab Ansari <soharab.ansari@infracloud.io>

---------

Signed-off-by: Md Soharab Ansari <soharab.ansari@infracloud.io>
 2024-08-09 11:58:44 +05:30
soharab-icandGitHub 8d14008eb3 Revert "Remove deprecated mqtrigger with kind fission (#2875)" (#2946) 
* Revert "Remove deprecated mqtrigger with kind fission (#2875)"

This reverts commit c47ff0e3e7.

* Upgrade sarama version to v1.43.2

Signed-off-by: Md Soharab Ansari <soharab.ansari@infracloud.io>

---------

Signed-off-by: Md Soharab Ansari <soharab.ansari@infracloud.io>
 2024-05-27 10:21:51 +05:30
Sanket SudakeandGitHub c47ff0e3e7 Remove deprecated mqtrigger with kind fission (#2875) 
* Remove deprecated mqtrigger with kind fission
* Remove unused deps

---------

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2023-11-21 17:52:37 +05:30
Sanket SudakeandGitHub 1fdf2e1e37 Update go deps across project (#2837) 
Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2023-09-24 11:14:43 +05:30
Sanket SudakeandGitHub 986a9c818a Optimize Kafka Client in Kafka Connector (#2630) 
Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2022-11-28 16:31:34 +05:30
Shubham BansalandGitHub 84eeda933a Add metric fission_mqt_message_lag for kafka mqt connector (#2544) 
These changes have specifically been made for Kafka connector. This will expose a new metric named `fission_mqt_message_lag`, which will show a number of messages lag per topic and partition.

We can use this metric in the auto-scaling of the pod for the new deploy type executor function. While creating a new deploy function we need to add hpa metrics of external type inside the function definition.
 2022-09-15 14:45:51 +05:30
Sanket SudakeandGitHub 809c9bec45 Reestablish kakfa consumer group session on disconnection (#2504) 
* Reestablish kakfa consumer group session on disconnection
* Add wait for the consumer
* Ignore empty message
* Update github.com/Shopify/sarama to v1.35.0

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2022-08-09 11:06:19 +05:30
Sanket SudakeandGitHub 0b2419c724 Remove deprecated Fission Azure Storage Queue connector (#2404) 
We are removing Fission deprecated Azure Storage Queue connector and
planning to adopt Keda going forward to have better
delegated functionality and more rich support.

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2022-04-06 15:13:56 +05:30
Sanket SudakeandGitHub 3495ea14a0 Remove deprecated Fission Nats connector (#2403) 
We are removing Fission deprecated Nats connector and
planning to adopt Keda going forward to have better
delegated functionality and more rich support.

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2022-04-06 13:41:38 +05:30
Ankit ChawlaGitHubSanket Sudake
 		d4f58bde5a Added metrics for fission mqtrigger and optimizations in trigger subscriptions (#2399) 
- Use mqtrigger watch instead of polling mqtrigger every 5 seconds
- Added metrics to monitor no of subscriptions, and no of messages per subscription
- Add standard go metrics exported by prometheus
- Enable prometheus discovery for mqtrigger pod
- Optimized mqtrigger manager cache
- Add unit tests for mqtrigger cache

Co-authored-by: Sanket Sudake <sanketsudake@gmail.com>
 2022-04-05 21:51:05 +05:30
Sanket SudakeandGitHub 30b764a220 MQT Kafka: Use Sarama Group Consumer instead of bsm/sarama-cluster library (#2286) 
Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2021-12-22 18:00:25 +05:30
Eng Zer JunandGitHub 7d904a9401 refactor: move from io/ioutil to io and os package (#2236) 
The io/ioutil package has been deprecated as of Go 1.16, see
https://golang.org/doc/go1.16#ioutil. This commit replaces the existing
io/ioutil functions with their new definitions in io and os packages.

Signed-off-by: Eng Zer Jun <engzerjun@gmail.com>
 2021-10-23 17:14:12 +05:30
Sanket SudakeandGitHub 7cd877698b Enable race detector for unit tests (#2085) 
Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2021-07-23 13:24:10 +05:30
Sanket SudakeandGitHub 59c950eeda Retrieve pod metrics only if metrics server is running and Go lint fixes (#2094) 
* Retrieve pod metrics only if metrics server is running

Currently we query pod metrics every 30 sec which floods executor logs,
added check which confirms if metrics server is running then only we start
querying pod metrics for identifying CPU utilization.

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

* Fixed couple of typos and misspells with Go CI

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>

* Remove unnecessary conversions with Go CI

Signed-off-by: Sanket Sudake <sanketsudake@gmail.com>
 2021-06-28 10:06:32 +05:30
Rahul BhatiGitHubVishalSanket Sudake
 		8283073c62 Added body in the error topic header (#1830) 
Signed-off-by: therahulbhati <rjbhati009@gmail.com>

Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com>
Co-authored-by: Sanket Sudake <sanketsudake@gmail.com>
 2021-06-07 22:28:11 +05:30
Gaurav GahlotGitHubSanket Sudake
 		2fb79e1355 do not use deprecated functions/methods (#2027) 
Signed-off-by: Gaurav Gahlot <gauravgahlot0107@gmail.com>

Co-authored-by: Sanket Sudake <sanketsudake@gmail.com>
 2021-05-21 13:53:28 +05:30
JacobGitHubVishalRahul Bhati
 		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 GahlotandGitHub 6758a04dbd Fixed golangci-lint issues: /fission/pkg (#1902) 2021-01-19 23:29:20 +05:30
Rahul BhatiandGitHub 9acf5b143f Added flag for insecureSkipVerfiy (#1829) 2020-10-13 21:03:19 +05:30
ankitjain235GitHubVishal
 		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
Alok BhanGitHubVishal
 		063739948f Fixing verify-staticcheck.sh (#1622) 
Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com>
 2020-06-04 15:16:09 +05:30
VishalGitHubShaun Cutts
 		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 ChenandGitHub baaeb321ff Add message queue service factory (#1537) 2020-02-20 23:30:39 +08:00
Ta-Ching ChenandGitHub 26a2889476 Update NATS-Streaming dependencies version (#1533) 2020-02-12 20:35:20 +08:00
Ta-Ching ChenandGitHub 81eb541442 Fix Git issue on case-insensitive OS (#1532) 2020-02-12 16:08:05 +08:00
Ta-Ching ChenandGitHub 72a7d490c6 Reorganize message queue trigger directory structure (#1531) 2020-02-12 15:40:00 +08:00
Ta-Ching ChenandGitHub 6379559c78 Follow kubernetes APIs directory structure (#1497) 2020-01-20 17:06:46 +08:00
Ta-Ching ChenandGitHub 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 ChenandGitHub 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 ChenandGitHub 3a1ad91658 Update staticcheck version and fix all warnings (#1381) 2019-11-05 18:09:12 +08:00
Vivek SinghandTa-Ching Chen 795c1f1e6d Calling the function that handles kafka messages, asynchronously (#1355) 2019-10-19 14:41:46 +08:00
Suraj BanakarandTa-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 BanakarandTa-Ching Chen 7cec1c2b55 Fix kafka producer and consumer logs show empty objects (#1281) 2019-09-29 23:47:05 +08:00
Suraj BanakarandTa-Ching Chen 161e084c8e Fix typo "consumer" => "producer" (#1278) 2019-08-20 19:45:56 +08:00
cocoifly10andTa-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 ChenandGitHub 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 ChenandGitHub ed4f8a4458 Move packages to proejct/pkg to follow go project folder structure convention (#1190) 2019-05-31 16:28:55 +08:00