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 d35e6c1 [Issue 5904]Support `unload` all partitions of a partitioned
topic (#6187)
add bf7302a [Issue 4175] [pulsar-function-go] Create integration tests
for Go Functions for production-readiness (#6104)
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci-go-functions-style.yaml | 2 +-
.../examples/{test => consumer}/consumer.go | 0
.../examples/{ => contextFunc}/contextFunc.go | 0
.../exclamationFunc.go} | 7 +-
pulsar-function-go/examples/go.mod | 18 ++++
pulsar-function-go/{ => examples}/go.sum | 35 ++-----
pulsar-function-go/examples/{ => hello}/hello.go | 0
.../examples/{ => inputFunc}/inputFunc.go | 0
.../examples/{ => outputFunc}/outputFunc.go | 0
.../examples/{test => producer}/producer.go | 0
pulsar-function-go/go.mod | 15 ++-
pulsar-function-go/go.sum | 32 +++---
pulsar-function-go/pf/instance.go | 4 +-
.../functions/instance/go/GoInstanceConfig.java | 1 +
.../docker-images/latest-version-image/Dockerfile | 27 ++++-
tests/docker-images/latest-version-image/pom.xml | 22 +++++
.../integration/functions/PulsarFunctionsTest.java | 110 ++++++++++++++-------
.../functions/PulsarFunctionsTestBase.java | 6 +-
.../functions/utils/CommandGenerator.java | 89 ++++++++++++-----
19 files changed, 248 insertions(+), 120 deletions(-)
rename pulsar-function-go/examples/{test => consumer}/consumer.go (100%)
rename pulsar-function-go/examples/{ => contextFunc}/contextFunc.go (100%)
copy pulsar-function-go/examples/{outputFunc.go =>
exclamationFunc/exclamationFunc.go} (86%)
create mode 100644 pulsar-function-go/examples/go.mod
copy pulsar-function-go/{ => examples}/go.sum (75%)
rename pulsar-function-go/examples/{ => hello}/hello.go (100%)
rename pulsar-function-go/examples/{ => inputFunc}/inputFunc.go (100%)
rename pulsar-function-go/examples/{ => outputFunc}/outputFunc.go (100%)
rename pulsar-function-go/examples/{test => producer}/producer.go (100%)
