freeznet opened a new pull request #9246:
URL: https://github.com/apache/pulsar/pull/9246
Fixes #8089
### Motivation
#8089 addressed that making pulsar admin client api calls is conflict with
Jersey library. This PR expose `PulsarAdmin` client through `Function Context`,
so the function implementers can use PulsarAdmin to do whatever they want to do.
### Modifications
- add `getPulsarAdmin()` and `getPulsarAdmin(String clusterName)` in
function `Context`
- add implementation of above interface in `ContextImpl`
- add passing `pulsarWebServiceUrl` to function runtimes
- add passing `pulsarWebServiceUrl` to `LocalRunner` / `JavaInstanceStarter`
- add `"--web-service-url"` parameter to `LocalRunner` admin command
- add unit tests
- add integration tests [WIP]
### Verifying this change
- [ ] Make sure that the change passes the CI checks.
This change added tests and can be verified as follows:
- add unit tests to verify the args passing from process runtime / k8s
runtime to `JavaInstanceStarter`
- add unit tests to verify `getPulsarAdmin`
- add integration tests to verify if pulsar admin works well [WIP]
### Does this pull request potentially affect one of the following parts:
- The admin cli options: (yes)
### Documentation
- Does this pull request introduce a new feature? (**yes** / no)
- If yes, how is the feature documented? (not applicable / docs / JavaDocs
/ **not documented**)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
