Skip to content

Instantly share code, notes, and snippets.

@warmuuh
Created November 27, 2020 10:13
Show Gist options
  • Save warmuuh/7aca6261afe369025ca4b488b060f176 to your computer and use it in GitHub Desktop.
Save warmuuh/7aca6261afe369025ca4b488b060f176 to your computer and use it in GitHub Desktop.
factory.addServerCustomizers(httpServer -> httpServer.tcpConfiguration(
tcpServer -> tcpServer.bootstrap(serverBootstrap -> {
serverBootstrap.config().childGroup().forEach(eventExecutor -> {
if (SingleThreadEventExecutor.class.isAssignableFrom(eventExecutor.getClass())) {
SingleThreadEventExecutor singleThreadEventExecutor = (SingleThreadEventExecutor) eventExecutor;
Gauge.builder(SERVER_PENDING_TASK_METRIC, singleThreadEventExecutor::pendingTasks)
.description("Pending Tasks")
.tag(SERVER_THREAD_NAME, singleThreadEventExecutor.threadProperties().name())
.tag(SERVER_THREAD_STATE, singleThreadEventExecutor.threadProperties().state().name())
.register(registry);
}
});
return serverBootstrap;
}
)));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment