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 26fd380 fix Double-Checked locking using volatile (#8475)
add 2c9fe27 [Issue 8382][Pulsar Function] Enable e2e encryption for
Pulsar Function (#8432)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/admin/cli/CmdFunctions.java | 7 +
.../org/apache/pulsar/admin/cli/CmdSources.java | 7 +
.../pulsar/common/functions/ConsumerConfig.java | 1 +
.../{ProducerConfig.java => CryptoConfig.java} | 17 ++-
.../pulsar/common/functions/ProducerConfig.java | 1 +
.../org/apache/pulsar/common/util/Reflections.java | 2 +-
pulsar-functions/instance/pom.xml | 6 +
.../functions/instance/JavaInstanceRunnable.java | 15 +-
.../apache/pulsar/functions/sink/PulsarSink.java | 93 ++++++++++---
.../pulsar/functions/sink/PulsarSinkConfig.java | 4 +-
.../pulsar/functions/source/PulsarSource.java | 40 ++++--
.../functions/source/PulsarSourceConfig.java | 1 +
.../functions/api/examples/RawFileKeyReader.java | 74 ++++++++++
.../proto/src/main/proto/Function.proto | 26 ++++
.../apache/pulsar/functions/utils/CryptoUtils.java | 154 +++++++++++++++++++++
.../functions/utils/FunctionConfigUtils.java | 67 +++++++--
.../pulsar/functions/utils/SinkConfigUtils.java | 17 ++-
.../pulsar/functions/utils/SourceConfigUtils.java | 35 +++--
.../pulsar/functions/utils/ValidatorUtils.java | 37 +++++
19 files changed, 542 insertions(+), 62 deletions(-)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/functions/{ProducerConfig.java
=> CryptoConfig.java} (71%)
create mode 100644
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/RawFileKeyReader.java
create mode 100644
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/CryptoUtils.java
