Skip to content

opentelemetry(), threaded sources: add keep-alive()#832

Merged
alltilla merged 14 commits intoaxoflow:mainfrom
MrAnno:otel-src-keep-alive
Nov 4, 2025
Merged

opentelemetry(), threaded sources: add keep-alive()#832
alltilla merged 14 commits intoaxoflow:mainfrom
MrAnno:otel-src-keep-alive

Conversation

@MrAnno
Copy link
Contributor

@MrAnno MrAnno commented Oct 22, 2025

Depends on #831

TODO:

  • channel args, port, etc. into persist name
  • num_workers into persist_name (worker up/down-scaling can't be supported because of the server-shutdown->worker-shutdown dependency)

@github-actions
Copy link
Contributor

github-actions bot commented Oct 22, 2025

This Pull Request introduces config grammar changes

axoflow/dbce1fa120dd260978a2204300cee3b96c0f00cb -> MrAnno/otel-src-keep-alive

Details
--- a/source
+++ b/source

 axosyslog-otlp(
+    keep-alive(<yesno>)
 )

 opentelemetry(
+    keep-alive(<yesno>)
 )

 syslog-ng-otlp(
+    keep-alive(<yesno>)
 )

@MrAnno MrAnno force-pushed the otel-src-keep-alive branch from 30d34be to 4b2231f Compare October 22, 2025 22:22
@bazsi
Copy link
Member

bazsi commented Oct 27, 2025

I have reviewed with the core changes, but the Otel/grpc related C++ code reads Chinese to me.

@MrAnno MrAnno requested review from alltilla and sodomelle October 27, 2025 09:53
@MrAnno MrAnno force-pushed the otel-src-keep-alive branch from 4b2231f to 27245a5 Compare October 27, 2025 11:31
@MrAnno
Copy link
Contributor Author

MrAnno commented Oct 27, 2025

@bazsi Thank you.

MrAnno added a commit to MrAnno/axosyslog that referenced this pull request Oct 27, 2025
Signed-off-by: László Várady <[email protected]>
MrAnno added a commit to MrAnno/axosyslog that referenced this pull request Oct 27, 2025
Signed-off-by: László Várady <[email protected]>
@MrAnno MrAnno force-pushed the otel-src-keep-alive branch from 4742272 to bdd25c6 Compare October 27, 2025 13:33
MrAnno added 14 commits October 28, 2025 14:38
It is needed in derived classes during the implementation of the keep
alive mechanism.

Signed-off-by: László Várady <[email protected]>
Workers are scaled up or down depending on the new configuration.

Signed-off-by: László Várady <[email protected]>
The driver is accessible from the worker through
LogThreadedSourceWorker::control.

The more places we cache this reference, the more places we have to update
it during reload.

Signed-off-by: László Várady <[email protected]>
Signed-off-by: László Várady <[email protected]>
This is needed to stop the worker thread without shutting down
the server or completion queue.

Signed-off-by: László Várady <[email protected]>
Signed-off-by: László Várady <[email protected]>
Signed-off-by: László Várady <[email protected]>
@MrAnno MrAnno force-pushed the otel-src-keep-alive branch from bdd25c6 to ddd24a9 Compare October 28, 2025 13:39
Copy link
Contributor

@sodomelle sodomelle left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

As far as I can tell, it looks good.

Copy link
Member

@alltilla alltilla left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Haven't tried it out yet, if someone did, feel free to merge, otherwise I will do another round of review with trying it out.

@alltilla alltilla merged commit b53a2a7 into axoflow:main Nov 4, 2025
23 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants