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

Mono Color

• cd42b85c6d
  Merge 66fdfbb817 into f6e79f1a2d Ryan Geary 2024-09-26 19:56:16 +0000
• 66fdfbb817 steal multiple shards per eventLoop Ryan Geary 2024-09-26 15:31:02 -0400
• 4ed5585359 steal multiple shards per eventLoop Ryan Geary 2024-09-26 15:31:02 -0400
• 8df326e926
  Merge 486651702f into f6e79f1a2d vmwjc 2024-06-20 04:08:02 +0000
• dc708cab0f
  Merge 877c716d3d into f6e79f1a2d Kris O'Mealy 2024-06-12 20:44:52 +0000
• b3de7c82a9
  Merge 0c630b3628 into f6e79f1a2d Caleb Stewart 2024-03-31 00:11:27 +0000
• f6e79f1a2d
  Merge pull request #53 from YakkovHow/main main v1.0.0 spentakota 2024-03-04 18:07:06 -0800
• 3676eb410a fix: support go 1.21 & upgrade dependencies Yakkov Leng 2024-03-04 17:54:44 -0800
• 7e0fbbefbd
  Merge a54ae17cd0 into b12921da23 Caleb Stewart 2023-09-04 20:17:29 +0000
• a54ae17cd0 Added dogstatsd monitoring service Caleb Stewart 2023-09-04 16:03:41 -0400
• 0066d09f11 changes from upstream merged. Also, removed in-library patch because we will add it to the shutdown method magiusdarrigo 2023-06-17 19:01:15 -0400
• 9ee6f81815
  Merge 75d4ce9cc7 into b12921da23 ravikiran-zoman 2023-05-04 05:38:03 +0000
• 75d4ce9cc7 fix ravikiran-s 2023-05-03 20:46:13 +0530
• adb9ee1183 milliseconds behind latest fix ravikiran-s 2023-05-03 19:50:21 +0530
• ba3fde7e34 length check fixes ravikiran-s 2023-05-03 16:29:43 +0530
• 3c07ee37ac fix ravikiran-s 2023-05-03 14:15:06 +0530
• 6dec232363 nil checks ravikiran-s 2023-05-03 13:56:49 +0530
• f5b9d21ffb package cahnges ravikiran-s 2023-05-03 12:54:34 +0530
• 1babcd292f more logs ravikiran-s 2023-05-03 12:19:33 +0530
• a372c4e9d0 dynamodbstreams adapter client with kcl library ravikiran-s 2023-05-02 11:30:57 +0530
• d558d77cb4
  Merge f314f764aa into b12921da23 Kris O'Mealy 2023-04-22 15:59:51 +0000
• f314f764aa
  Info level is too chatty for this sleep message, debug is good along with new metrics komealy 2023-04-20 08:05:10 -0700
• 0c630b3628 Add basic example implementation Caleb Stewart 2023-04-21 16:04:58 -0400
• 877c716d3d
  chore: create DeleteMetricMillisBehindLatest to satisfy worker_test implementation error (#3) Kris O'Mealy 2023-04-21 06:23:14 -0700
• 97599ea83f
  Info level is too chatty for this sleep message, debug is good Signed-off-by: Kris O'Mealy <komealy@hotmail.com> komealy 2023-04-20 07:50:57 -0700
• 9553ec43e2
  Info level is too chatty for this sleep message, debug is good. Signed-off-by: Kris O'Mealy <komealy@hotmail.com> Kris O'Mealy 2023-04-20 06:44:34 -0700
• 486651702f fix: Move getRecords stop condition checking to top of loop test-lease-renewal John Calixto 2023-04-08 11:24:33 -0700
• ec7c0b6f61 chore: Add test for renewLease John Calixto 2023-04-07 17:43:33 -0700
• b12921da23
  Merge pull request #37 from vmware/spentakota_passContext spentakota 2023-04-06 18:09:16 -0700
• 4482696d95 fix: pass in ctx with cancel for renewLease spentakota_passContext Shiva Pentakota 2023-04-06 17:41:46 -0700
• 16c5c53a30
  Merge pull request #13 from calebstewart/fix/issue-5-empty-kinesisendpoint vmwjc 2023-04-04 14:40:26 -0700
• f97ba4e3b2
  Merge pull request #36 from vmware/clean-up-extra-err-check vmwjc 2023-04-04 14:21:24 -0700
• c1f6b270ab chore: Remove extraneous err check clean-up-extra-err-check John Calixto 2023-04-04 14:13:54 -0700
• 6120c11333
  Merge pull request #10 from mrmonaghan/fix-infinite-worker-loop vmwjc 2023-04-04 14:08:59 -0700
• 8ecb5b40a2
  Merge pull request #35 from vmware/spentakota_retLeaseErr spentakota 2023-04-04 11:21:14 -0700
• 86d70940e6 fix: return err log in case of ErrLeaseNotAcquired spentakota_retLeaseErr Shiva Pentakota 2023-04-04 11:17:22 -0700
• 6516287f6d
  Merge pull request #34 from vmware/spentakota_asyncLeaseRenewal spentakota 2023-04-03 15:02:28 -0700
• 4aebaf1ae0 feat: make lease renewal async spentakota_asyncLeaseRenewal Shiva Pentakota 2023-04-03 14:58:04 -0700
• 5be0422f33
  Merge pull request #32 from vmware/spentakota_overdueShutdown spentakota 2023-03-30 12:51:49 -0700
• a7ea84dee3 fix: add checpoint error cases Shiva Pentakota 2023-03-28 14:48:52 -0700
• 02d4b44ff6 fix: add shutdown and leaseExpired error cases for checkpoint function spentakota_overdueShutdown Shiva Pentakota 2023-03-28 11:46:55 -0700
• 44f1558847
  Merge pull request #31 from vmware/dependabot/go_modules/golang.org/x/sys-0.1.0 cmckelvey-vmware 2023-03-28 10:59:31 -0600
• 982c468bef
  Merge pull request #30 from vmware/dependabot/go_modules/github.com/prometheus/client_golang-1.11.1 cmckelvey-vmware 2023-03-28 10:58:45 -0600
• 09f0889f28
  Bump golang.org/x/sys from 0.0.0-20211216021012-1d35b9e2eb4e to 0.1.0 dependabot[bot] 2023-03-28 16:57:32 +0000
• 236412324f
  Bump github.com/prometheus/client_golang from 1.11.0 to 1.11.1 dependabot[bot] 2023-03-28 16:56:55 +0000
• 61a027efef
  Merge pull request #29 from vmware/fix-token-bucket-edge-cases spentakota 2023-03-23 12:46:42 -0700
• 987fada9d3 fix: Check token bucket corner cases correctly. fix-token-bucket-edge-cases John Calixto 2023-03-23 10:59:58 -0700
• 5c3fc2e477 fix: check for non-zero cooldown period spentakota_fixCoolDownZero Shiva Pentakota 2023-03-22 20:46:24 -0700
• 711b72932a
  Merge pull request #27 from vmware/spentakota_AddLogs spentakota 2023-03-22 14:43:58 -0700
• a7c063b99c chore: add info logs in sleep case for kinesis backoff errors spentakota_AddLogs Shiva Pentakota 2023-03-22 12:22:26 -0700
• 53b02bcdd8 chore: update ReadMe to contain some notes regarding setting kclConfig values spentakota_updateReadMe Shiva Pentakota 2023-03-03 16:35:08 -0800
• bce4dd3f42
  Merge pull request #24 from vmware/spentakota_fixNanoBug spentakota 2023-02-14 10:30:14 -0800
• df16ef451c fix: use nanosecond precision in lease comparisons Shiva Pentakota 2023-02-13 17:56:11 -0800
• c89ce3608b
  ResetShardIterator added to rp interface (#2) Matteo Agius 2023-02-07 20:25:45 -0500
• fb17ec8bc6
  Merge pull request #23 from vmware/spentakota_filNilError spentakota 2023-02-01 08:10:38 -0800
• 04c5062ace fix: add check for GetRecords error within callGetRecordsAPI Shiva Pentakota 2023-02-01 08:00:49 -0800
• c43491f922
  Merge pull request #22 from vmware/spentakota/changeLogMessage spentakota 2023-01-31 10:21:31 -0800
• f879712f9d chore: log RemoveLeaseOwner errors with debug instead of error spentakota/changeLogMessage Shiva Pentakota 2023-01-31 10:18:15 -0800
• 15ecd714f8 fix: add missing ClaimRequest logic spentakota/handleDynamoConcurrency Shiva Pentakota 2023-01-27 17:23:18 -0800
• 42881449ce
  Merge pull request #21 from vmware/spentakota_callGetRecordsAPI spentakota 2023-01-24 17:12:39 -0800
• 7d6b1c33d0 fix: add maxBytes per second getRecord check spentakota_callGetRecordsAPI Shiva Pentakota 2023-01-24 16:28:22 -0800
• b5515931d1 fix: add hard cap maxRetries for getRecord errors Shiva Pentakota 2023-01-24 11:59:32 -0800
• 66006caf89 fix: add getRecords TPS rate limiting Shiva Pentakota 2023-01-24 11:56:29 -0800
• 706e803d27 fix: add case for setting lastCheckTime in first iteration callGetRecordsAPI spentakota/handleGetRecordsErrors Shiva Pentakota 2023-01-24 09:18:55 -0800
• ae3763e478 fix: added callGetRecordsAPI tests Shiva Pentakota 2023-01-23 20:50:53 -0800
• adcff0b7bb fix: created seperate rate limit check method callGetRecordsAPI Shiva Pentakota 2023-01-23 16:03:34 -0800
• cd1f34e489 fix: max bytes per second getRecords check Shiva Pentakota 2023-01-23 13:49:25 -0800
• b49cbdf4fc fix: rate limiting getRecords tps Shiva Pentakota 2023-01-23 13:44:14 -0800
• 9fcd1a8293 fix: adding MaxRetryCount for capped num of retries Shiva Pentakota 2023-01-23 13:37:42 -0800
• 981dc2df11
  Merge pull request #20 from vmware/jc/testable-getRecords spentakota 2023-01-23 18:52:10 -0800
• 3be57e8a74 Refactor in prep for testing rate limiting improvements jc/testable-getRecords John Calixto 2023-01-23 17:32:27 -0800
• 5e7aca6ab2
  Merge pull request #18 from vmware/spentakota_deleteMetricMillis spentakota 2023-01-20 13:29:25 -0800
• 599aa06ecd fix: add DeleteMetricMillisBehindLatest for error case spentakota_deleteMetricMillis Shiva Pentakota 2023-01-20 13:23:02 -0800
• c5bc6c4ded
  Merge pull request #17 from vmware/spentakota/sendLeaseRenewedMetric spentakota 2023-01-12 11:56:21 -0800
• e1425047a7 feat: Sending renewed lease metric Shiva Pentakota 2023-01-12 11:31:16 -0800
• 4afa8fec3e
  Merge pull request #16 from vmware/spentakota_catchNilErrorSyncLeases spentakota 2022-12-19 08:34:02 -0800
• 09cc5896e9 chore: Adding periods to copyright comment to satisfy gofmt spentakota_catchNilErrorSyncLeases Shiva Pentakota 2022-12-16 19:03:29 -0500
• 08b7fd9447 fix: catch DynamoDB Scan error when trying to scan nonexistent table/index in syncLeases() Shiva Pentakota 2022-12-16 18:07:22 -0500
• 72d3b6f328
  Merge pull request #1 from magiusdarrigo/fix-shard-shutdown-lease-release Matteo Agius 2022-11-25 17:11:03 -0600
• 75831cfec5 call checkpointer nil in order to let workers know shard is expired magiusdarrigo 2022-11-25 17:07:01 -0600
• 09815b6898 changed back to magiudarrigo mod path magiusdarrigo 2022-10-27 13:04:44 -0500
• 66f1821f1b Revert "Revert "changed mod file path to my clone repo"" magiusdarrigo 2022-10-27 12:58:37 -0500
• d51f7a4d17 trying the go mod replace command with a v0.0.1 for my forked repo magiusdarrigo 2022-10-27 12:56:14 -0500
• aa0a11286d Revert "changed mod file path to my clone repo" magiusdarrigo 2022-10-27 12:49:02 -0500
• b602dfa20f changed mod file path to my clone repo magiusdarrigo 2022-10-27 12:36:54 -0500
• e2a45c53c3 Automatically resolve default KinesisEndpoint Caleb Stewart 2022-10-13 13:37:51 -0400
• b4d40ddfe1 Fix DynamoDB checkpointer scan error handling Anton Kolesnikov 2022-09-30 19:32:56 +0200
• aab08b9050 fixing infinite worker loop Mike Monaghan 2022-09-13 15:31:16 -0600
• f448ec8a56 fixing infinite loop Mike Monaghan 2022-09-13 15:24:44 -0600
• 3be592ec8d fixing infinite worker loop\nSigned-off-by: Mike Monaghan <mike_monaghan@live.ca> Mike Monaghan 2022-09-13 15:20:07 -0600
• 1b4b193ae6 fixing issue with unkillable worker process Mike Monaghan 2022-09-13 15:13:36 -0600
• c862165130
  Update README.md Tao Jiang 2022-01-06 20:24:58 -0600
• 99e9fe5759 fix build badge path Fabiano Graças 2022-01-07 03:22:22 +0100
• c19ae1d605
  Feature/fabiano commits (#2) Fabiano Arruda 2022-01-07 03:13:32 +0100
• 7bb2d9dc74 fix format Fabiano Graças 2022-01-07 02:39:16 +0100
• f284ef978d since deaggregation package was upgraded to sdk v2 makes sense to use it. Fabiano Graças 2022-01-07 02:27:18 +0100
• 562f0f0e6b fix cammel case usage Fabiano Graças 2022-01-04 20:51:59 +0100
• 10787dedaf remove calls to deprecated functions. Fabiano Graças 2022-01-07 02:05:26 +0100
• 725fef3ab1 upgrade versions Fabiano Graças 2022-01-04 20:35:13 +0100
• 9bdb1ad35c apply lint against MD file Fabiano Graças 2022-01-07 01:55:09 +0100