-
Notifications
You must be signed in to change notification settings - Fork 16
Closed
Labels
enhancementNew feature or requestNew feature or request
Description
Is your feature request related to a problem? Please describe.
I want to check metrics between Netty Inboud handler and Frame Handler execution.
For example,
- Consumer started
- Message was published to the stream
- Broker sent message to the consumer
- StreamHandler.channelRead was called
- FrameHandler task was submitted to dispatchingExecutorService
- When the time comes, dispatchingExecutorService will execute the task.
In this situation, there are latency between 5 ~ 6 that refers to the time waiting for actual execution but couldn't check.
Describe the solution you'd like
- Move ExecutorServiceFactory from stream.impl package to stream package.
- Add ExecutorServiceFactory to the EnvironmentBuilder(StreamEnvironmentBuilder), then StreamEnvironmentBuilder.ClientParameters holds ExecutorServiceFactory reference.
- create ExecutorServiceFactory that can provide metrics. (This must be implemented by the library user)
- Add it to EnvironmentBuilder
Is this a possible scenario? Or is there another way to measure it?
Thank you.
Describe alternatives you've considered
No response
Additional context
No response
Metadata
Metadata
Assignees
Labels
enhancementNew feature or requestNew feature or request