This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 562b2e7 [tiered-storage] Allow AWS credentials to be refreshed (#9387)
add 0469dfe [fix #8089] expose PulsarAdmin client through Function
Context (#9246)
No new revisions were added by this update.
Summary of changes:
conf/functions_worker.yml | 2 +
pom.xml | 2 +
.../broker/loadbalance/LoadBalancerTest.java | 3 +-
.../.gitignore | 0
.../pom.xml | 38 +++--
.../org/apache/pulsar/client/admin/Bookies.java | 0
.../apache/pulsar/client/admin/BrokerStats.java | 0
.../org/apache/pulsar/client/admin/Brokers.java | 0
.../org/apache/pulsar/client/admin/Clusters.java | 0
.../org/apache/pulsar/client/admin/Functions.java | 0
.../client/admin/LongRunningProcessStatus.java | 0
.../org/apache/pulsar/client/admin/Lookup.java | 0
.../org/apache/pulsar/client/admin/Namespaces.java | 0
.../pulsar/client/admin/NonPersistentTopics.java | 0
.../pulsar/client/admin/OffloadProcessStatus.java | 0
.../org/apache/pulsar/client/admin/Packages.java | 0
.../org/apache/pulsar/client/admin/Properties.java | 0
.../org/apache/pulsar/client/admin/ProxyStats.java | 0
.../apache/pulsar/client/admin/PulsarAdmin.java | 166 +++++++++++++++++++++
.../pulsar/client/admin/PulsarAdminBuilder.java | 0
.../pulsar/client/admin/PulsarAdminException.java | 0
.../apache/pulsar/client/admin/ResourceQuotas.java | 0
.../org/apache/pulsar/client/admin/Schemas.java | 0
.../java/org/apache/pulsar/client/admin/Sink.java | 0
.../java/org/apache/pulsar/client/admin/Sinks.java | 0
.../org/apache/pulsar/client/admin/Source.java | 0
.../org/apache/pulsar/client/admin/Sources.java | 0
.../org/apache/pulsar/client/admin/Tenants.java | 0
.../org/apache/pulsar/client/admin/Topics.java | 0
.../org/apache/pulsar/client/admin/Worker.java | 0
.../apache/pulsar/client/admin/package-info.java | 0
.../client/admin/utils/DefaultImplementation.java | 27 ++--
.../client/admin/utils}/ReflectionUtils.java | 2 +-
.../pulsar/client/admin/utils}/package-info.java | 2 +-
pulsar-client-admin/pom.xml | 6 +
.../admin/internal/PulsarAdminBuilderImpl.java | 10 +-
.../PulsarAdminImpl.java} | 75 +++++-----
.../admin/internal/http/AsyncHttpConnector.java | 4 +-
.../org/apache/pulsar/admin/cli/CmdFunctions.java | 2 +
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 3 +-
.../common/functions/ExternalPulsarConfig.java | 1 +
.../pulsar/common/functions/FunctionConfig.java | 2 +
pulsar-functions/api-java/pom.xml | 7 +
.../org/apache/pulsar/functions/api/Context.java | 19 ++-
pulsar-functions/instance/pom.xml | 6 +
.../pulsar/functions/instance/ContextImpl.java | 35 ++++-
.../pulsar/functions/instance/InstanceConfig.java | 4 +
.../pulsar/functions/instance/InstanceUtils.java | 24 +++
.../functions/instance/JavaInstanceRunnable.java | 7 +-
.../pulsar/functions/instance/PulsarCluster.java | 7 +-
.../pulsar/functions/instance/ContextImplTest.java | 32 +++-
.../instance/JavaInstanceRunnableTest.java | 2 +-
pulsar-functions/java-examples/pom.xml | 5 +
.../api/examples/CursorManagementFunction.java | 48 ++++++
.../org/apache/pulsar/functions/LocalRunner.java | 20 ++-
.../functions/runtime/JavaInstanceStarter.java | 10 +-
.../pulsar/functions/runtime/RuntimeUtils.java | 18 ++-
.../runtime/kubernetes/KubernetesRuntime.java | 3 +-
.../functions/runtime/process/ProcessRuntime.java | 6 +-
.../runtime/process/ProcessRuntimeFactory.java | 10 +-
.../functions/runtime/thread/ThreadRuntime.java | 6 +
.../runtime/thread/ThreadRuntimeFactory.java | 23 ++-
.../pulsar/functions/worker/WorkerConfig.java | 6 +
.../runtime/kubernetes/KubernetesRuntimeTest.java | 32 ++++
.../runtime/process/ProcessRuntimeTest.java | 74 ++++++++-
.../pulsar/functions/worker/FunctionActioner.java | 1 +
.../functions/worker/SchedulerManagerTest.java | 21 +--
.../worker/rest/api/FunctionsImplTest.java | 4 +-
tests/docker-images/java-test-functions/pom.xml | 20 +++
tests/pulsar-client-admin-shade-test/pom.xml | 7 +
70 files changed, 677 insertions(+), 125 deletions(-)
copy {pulsar-client-admin => pulsar-client-admin-api}/.gitignore (100%)
copy {pulsar-transaction/coordinator => pulsar-client-admin-api}/pom.xml (64%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Bookies.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/BrokerStats.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Brokers.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Clusters.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Functions.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/LongRunningProcessStatus.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Lookup.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Namespaces.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/NonPersistentTopics.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/OffloadProcessStatus.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Packages.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Properties.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/ProxyStats.java
(100%)
create mode 100644
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/PulsarAdminBuilder.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/PulsarAdminException.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/ResourceQuotas.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Schemas.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Sink.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Sinks.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Source.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Sources.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Tenants.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Topics.java
(100%)
rename {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/Worker.java
(100%)
copy {pulsar-client-admin =>
pulsar-client-admin-api}/src/main/java/org/apache/pulsar/client/admin/package-info.java
(100%)
copy pulsar-client/src/main/java/org/apache/pulsar/client/util/MathUtils.java
=>
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/utils/DefaultImplementation.java
(58%)
copy {pulsar-client-api/src/main/java/org/apache/pulsar/client/internal =>
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/utils}/ReflectionUtils.java
(98%)
copy {pulsar-client-api/src/main/java/org/apache/pulsar/client/internal =>
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/utils}/package-info.java
(95%)
rename
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/{PulsarAdmin.java
=> internal/PulsarAdminImpl.java} (88%)
create mode 100644
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/CursorManagementFunction.java
