vmware-go-kcl-v2

luciano/vmware-go-kcl-v2

Fork 0

Commit graph

Select branches

Hide pull requests

clean-up-extra-err-check

fix-token-bucket-edge-cases

jc/testable-getRecords

main

spentakota/changeLogMessage

spentakota/handleDynamoConcurrency

spentakota/handleGetRecordsErrors

spentakota_AddLogs

spentakota_asyncLeaseRenewal

spentakota_callGetRecordsAPI

spentakota_catchNilErrorSyncLeases

spentakota_deleteMetricMillis

spentakota_fixCoolDownZero

spentakota_overdueShutdown

spentakota_passContext

spentakota_retLeaseErr

spentakota_updateReadMe

test-lease-renewal

#1

#10

#11

#13

#16

#17

#18

#19

#2

#20

#21

#22

#23

#24

#25

#27

#28

#29

#3

#30

#31

#32

#33

#34

#35

#36

#37

#38

#38

#41

#42

#43

#43

#44

#44

#45

#45

#47

#47

#48

#51

#51

#53

#54

#55

#55

#7

#8

#9

v1.0.0

e9c6d0021b fix credential usage Fabiano Graças 2022-01-07 01:54:45 +0100
c6d7cdd6d7 use cammel case Fabiano Graças 2022-01-04 20:11:02 +0100
c02b7a85d4 Update unit tests Tao Jiang 2021-12-22 22:16:06 -0600
86cc5a1a64 Update the libray reference path to new repo Tao Jiang 2021-12-21 13:49:47 -0600
aabb88c35b Update github workflow Tao Jiang 2021-12-20 21:43:57 -0600
52f6fa57e6

Merge pull request #1 from vmware/upgrade/aws-sdk-to-v2 Tao Jiang 2021-12-20 21:26:17 -0600
dd8ec33982 add build badge Fabiano Graças 2021-11-12 02:03:10 +0100
eaf26900ef add security scan Fabiano Graças 2021-11-12 02:02:50 +0100
0906af7baf improve lint Fabiano Graças 2021-11-12 01:07:08 +0100
fdbaa68af7 fix format Fabiano Graças 2021-11-11 23:33:44 +0100
7b0c198c0f setup go 1.17 Fabiano Graças 2021-11-11 23:31:05 +0100
b20dd33ae2 upgrade packages Fabiano Graças 2021-11-11 23:30:28 +0100
7abd86ac6e add more branches Fabiano Graças 2021-11-11 23:24:51 +0100
f9ced84cbd improve gofmt Fabiano Graças 2021-11-11 23:11:30 +0100
6f0fbfe4c7 improve ci (remove hypermake, add makefile and github pipeline) Fabiano Graças 2021-11-11 23:08:59 +0100
7538535bff remove debug code Fabiano Graças 2021-11-08 22:36:18 +0100
2bf65b4386 update after tidy Fabiano Graças 2021-11-08 18:39:27 +0100
a44513ef08 add parameters names in order to serve as suggestions and ignore explicitly bellow to avoid lint msgs. Fabiano Graças 2021-11-08 16:28:32 +0100
97c6633ea0 migrate to aws-sdk-go-v2 Fabiano Graças 2021-11-08 16:27:29 +0100
b537305690 add deaggregator v2 code straightly to the repo since it's seems they will not merge the PR soon. Fabiano Graças 2021-11-08 15:17:48 +0100
0c204685a9 improve comments Fabiano Graças 2021-11-08 15:00:48 +0100
6372087bc3 removed due the new error handling https://github.com/aws/aws-sdk-go-v2/blob/main/CHANGELOG.md#error-handling Fabiano Graças 2021-11-08 14:38:23 +0100
7af9290557 Upgrade golang 1.17 (#98) Fabiano Arruda 2021-10-22 03:28:41 +0200
18546df781 Added RS Zerolog logging adapter (#96) Máté Lang 2021-10-15 15:21:53 +0300
5de70c0542 Rebuild and publish toolchain (#95) Tao Jiang 2021-08-23 21:34:46 -0500
0094ef5a69 improve log event (#93) Luca Rinaldi 2021-07-23 14:03:31 +0200
7de4607b71 Add support for lease stealing (#78) Connor McKelvey 2021-06-01 17:18:26 -0600
4a642bfa2f Use application name as default enhanced fan-out consumer name (#91) Ilia Cimpoes 2021-04-29 05:19:12 +0300
ddcc2d0f95 Support enhanced fan-out feature (#90) Ilia Cimpoes 2021-04-27 18:51:26 +0300
909d1774a3 Add context to ErrLeaseNotAcquired (#87) Aurélien Rainone 2021-01-26 05:30:10 +0100
adb264717b Fix naming convention (#85) Tao Jiang 2020-12-23 13:22:01 -0600
1044485392 Support Kinesis aggregation format (#84) Tao Jiang 2020-12-23 09:47:47 -0600
6ff3cd1b15 Fix retry logic for dynamodb (#83) Tao Jiang 2020-12-19 17:44:40 -0600
f1982602ff Fix data race during checkpointing (#82) Tao Jiang 2020-12-18 22:11:10 -0600
499e9cf1be Update aws go sdk and tests (#81) Tao Jiang 2020-12-18 16:52:04 -0600
10d6b28edf Use FieldLogger interface to represent logrus logger (#75) Mike Pye 2020-06-05 03:25:06 +0100
384482169c Refactor getShardIDs (#70) wgerges-discovery 2020-03-10 12:00:57 -0400
5dd53bf731 Add nil check before shutdown (#68) Tao Jiang 2020-01-30 20:06:03 -0600
8f0d7bc8d8 Reduce log noise from found shards in worker event loop (#66) Kevin Burns 2020-01-22 03:26:22 -0800
f1935bc0ff Fix potentially delayed shutdown on shard sync (#64) Aurélien Rainone 2019-12-09 16:21:20 +0100
df60778d89 Re-org code for adding jittered delay for syncShard (#63) Tao Jiang 2019-11-29 14:27:05 -0600
43a936cab3 Issue 61/add shard sync jitter (#62) Aurélien Rainone 2019-11-29 19:59:35 +0100
a35f4960a8 Make Worker.Shutdown() synchronous (#58) dferstay 2019-11-14 19:53:34 -0800
6c9e594751 Make the lease refresh period configurable (#56) Aurélien Rainone 2019-11-14 00:15:33 +0100
9ca9d901ca Fix error in puslishing cloud watch metrics (#55) Tao Jiang 2019-11-11 14:11:44 -0600
c9793728a3 Fix 'get records time' metric (#53) Aurélien Rainone 2019-11-09 20:27:20 +0100
eb56e3b1d7 Fix broken tests (#50) Tao Jiang 2019-11-06 08:35:08 -0600
21980a54e3 Expose monitoring service (#49) Aurélien Rainone 2019-11-06 14:53:21 +0100
d6369e48c2 Fix the broken integrationt test (#48) Tao Jiang 2019-11-04 11:39:50 -0600
8a8f9e6339 logger: move zap into its own package (#47) Aurélien Rainone 2019-11-04 18:22:29 +0100
971d748195 Fix missing init position with AT_TIMESTAMP (#44) Tao Jiang 2019-11-01 08:42:04 -0500
0d91fbd443 Add generic logger support (#43) Tao Jiang 2019-10-28 07:08:18 -0500
c8a5aa1891 Fix possible deadlock with getRecords in eventLoop (#42) Aurélien Rainone 2019-10-27 16:43:21 +0100
4f79203f44 Get rid of unused skipTableCheck (#39) Tao Jiang 2019-10-03 20:45:34 -0500
46fea317de Release shard lease after shutdown (#31) Tao Jiang 2019-07-09 21:24:11 -0500
ac8d341cb1 Revert "Remove shard info in checkpointer (#29)" (#30) Tao Jiang 2019-07-08 20:40:57 -0500
8369884952 Remove shard info in checkpointer (#29) Tao Jiang 2019-07-08 18:04:37 -0500
fa0bbc42fe Update worker to let it inject checkpointer and kinesis (#28) Tao Jiang 2019-07-08 17:20:33 -0500
250bb2e9ff Use AWS built-in retry logic and refactor tests (#24) Tao Jiang 2019-06-27 21:56:44 -0700
6df520b343 Remove signal handling from event loop (#20) Tao Jiang 2019-05-20 08:57:32 -0500
2ca82c25ca Add support for providing custom checkpointer (#17) Tao Jiang 2019-04-22 15:55:39 -0500
c634c75ebc Add credential configuration for resources (#14) Tao Jiang 2019-03-16 08:11:09 -0500
5140058e8b Update dependency steps Tao Jiang 2019-02-21 21:34:12 -0600
13aa9632cd Upgrade to use go1.11 and switch to use go mod Tao Jiang 2019-02-21 18:44:36 -0600
cd343cca09 Add configuration options for AWS service endpoints (#5) Tim Studd 2019-02-09 08:23:54 -0800
03685b2b19 Fix type conversion error Tao Jiang 2018-11-22 11:43:45 -0600
6a1a7b7da6 Fix the exponential backoff Tao Jiang 2018-10-30 12:41:45 -0700
2d5d506659 Add DCO text VMware GitHub Bot 2018-09-11 23:03:25 -0500
691082e284 Add DCO text VMware GitHub Bot 2018-09-11 23:02:06 -0500
d6b5196b55 Update import path when switching github Tao Jiang 2018-09-08 09:46:02 -0700
d13f8588a9 KCL: Update readme Tao Jiang 2018-09-07 08:44:37 -0700
10e8ebb3ff KCL: Fix KCL stops processing when Kinesis Internal Error Tao Jiang 2018-09-04 20:32:45 -0700
3163d31f28 KCL: KCL should ignore deleted parent shard Tao Jiang 2018-09-04 14:40:46 -0700
9addbb57f0 KCL: Fix random number generator Tao Jiang 2018-09-04 09:09:06 -0700
22de13ef8a Go-KCL: Update security scan Tao Jiang 2018-08-27 12:23:20 -0700
47daa9d5f0 KCL: Update copyright and permission Tao Jiang 2018-08-17 06:03:25 -0700
e2a945d824 KCL: Stuck on processing after kinesis shard splitting Tao Jiang 2018-08-06 20:49:15 -0700
48fd4dd51c KCL: remove panic in shard consumer Tao Jiang 2018-05-31 05:26:49 -0700
3120d89ae8 KCL: remove unused item Tao Jiang 2018-05-21 19:34:37 -0700
85c04db6b4 KCL: Fix the way in returning error Tao Jiang 2018-05-21 19:14:18 -0700
2b9301cd47 Flatten directory structure Long Zhou 2018-04-24 10:07:57 -0700
2542ea1416 KCL: Remove lease entry in dynamoDB table when shard no longer exists Tao Jiang 2018-04-23 12:40:39 -0700
6384d89748 KCL: Organize the folder structure Tao Jiang 2018-04-22 07:09:16 -0700
5ef4338a22 KCL: Update shard sync to remove not existed shard Tao Jiang 2018-04-21 19:58:51 -0700
e1071abc80 KCL: Fix cloudwatch metrics Tao Jiang 2018-04-20 21:07:11 -0700
2fea884212 KCL: Enable Metrics Tao Jiang 2018-04-20 08:30:24 -0700
9d1993547f KCL: Ignore Lint error on const Tao Jiang 2018-04-19 11:53:12 -0700
869a8e4275 KCL: Add support for handling shard split Tao Jiang 2018-04-18 20:09:52 -0700
c05bfb7ac8 KCL: Fixing checkpoint operation Tao Jiang 2018-04-18 15:50:15 -0700
a323d2fd51 KCL: Implement Worker Tao Jiang 2018-04-17 09:25:41 -0700
1969713863 KCL: Fix unit test Tao Jiang 2018-04-13 14:26:56 -0700
425daf70ce KCL: Implement Shard Lease (part 1/2) Tao Jiang 2018-04-12 21:02:30 -0700
702335374c [WIP] KCL: create configuration and interface for kinesis client library Tao Jiang 2018-04-10 20:50:18 -0700
7b35571d9e CKL: Initial version for starting repository Tao Jiang 2018-04-08 13:55:48 -0700
f7763e6d8b Initial empty repository Tao Jiang 2018-04-06 07:46:07 -0700
157c2a8b3e Add CONTRIBUTING template VMware GitHub Bot 2018-09-06 14:28:56 -0500
2afd07ed52 Adding .gitignore template VMware GitHub Bot 2021-11-30 23:05:17 +0800
65c4e3fc0b Add Code of Conduct template VMware GitHub Bot 2021-11-30 23:05:17 +0800
5de8e31499 Add CONTRIBUTING template VMware GitHub Bot 2021-11-30 23:05:16 +0800
7ad2bfc721 Add README template VMware GitHub Bot 2021-11-30 23:05:15 +0800