You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2019/11/14 14:13:48 UTC
[pulsar] branch master updated (b866787 -> 320cebe)
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 b866787 Upgrade bk version to 4.10.0 (#5607)
add 320cebe [functions] Allow functions to pass runtime specific options (#5400)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/admin/cli/CmdFunctions.java | 6 +
.../java/org/apache/pulsar/admin/cli/CmdSinks.java | 6 +
.../org/apache/pulsar/admin/cli/CmdSources.java | 5 +
.../pulsar/common/functions/FunctionConfig.java | 4 +
.../org/apache/pulsar/common/io/SinkConfig.java | 4 +
.../org/apache/pulsar/common/io/SourceConfig.java | 4 +
.../org/apache/pulsar/functions/LocalRunner.java | 2 +-
.../proto/src/main/proto/Function.proto | 1 +
.../auth/ClearTextFunctionTokenAuthProvider.java | 9 +-
.../functions/auth/FunctionAuthProvider.java | 18 +--
.../auth/KubernetesFunctionAuthProvider.java | 18 ++-
.../auth/KubernetesSecretsTokenAuthProvider.java | 52 +++++---
.../functions/runtime/RuntimeCustomizer.java | 14 +--
.../pulsar/functions/runtime/RuntimeFactory.java | 11 +-
.../BasicKubernetesManifestCustomizer.java | 113 +++++++++++++++++
.../kubernetes/KubernetesManifestCustomizer.java} | 22 ++--
.../runtime/kubernetes/KubernetesRuntime.java | 24 +++-
.../kubernetes/KubernetesRuntimeFactory.java | 50 ++++++--
.../kubernetes/KubernetesRuntimeFactoryConfig.java | 1 +
.../runtime/process/ProcessRuntimeFactory.java | 25 +++-
.../runtime/thread/ThreadRuntimeFactory.java | 4 +-
.../pulsar/functions/worker/WorkerConfig.java | 15 +++
.../ClearTextFunctionTokenAuthProviderTest.java | 5 +-
.../KubernetesSecretsTokenAuthProviderTest.java | 24 ++--
.../kubernetes/KubernetesRuntimeFactoryTest.java | 41 +++---
.../runtime/kubernetes/KubernetesRuntimeTest.java | 139 +++++++++++++++++++--
.../runtime/process/ProcessRuntimeTest.java | 2 +-
.../functions/utils/FunctionConfigUtils.java | 11 ++
.../pulsar/functions/utils/SinkConfigUtils.java | 11 ++
.../pulsar/functions/utils/SourceConfigUtils.java | 16 ++-
.../pulsar/functions/worker/FunctionActioner.java | 5 +-
.../functions/worker/FunctionRuntimeManager.java | 19 +--
.../functions/worker/rest/api/FunctionsImpl.java | 10 +-
.../functions/worker/rest/api/SinksImpl.java | 8 +-
.../functions/worker/rest/api/SourcesImpl.java | 8 +-
.../functions/worker/FunctionActionerTest.java | 2 +-
site2/docs/functions-cli.md | 24 ++--
site2/docs/functions-runtime.md | 43 ++++++-
38 files changed, 615 insertions(+), 161 deletions(-)
copy pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSinkOfFlume.java => pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeCustomizer.java (67%)
create mode 100644 pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/BasicKubernetesManifestCustomizer.java
copy pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/{auth/FunctionAuthUtils.java => runtime/kubernetes/KubernetesManifestCustomizer.java} (55%)