This is an automated email from the ASF dual-hosted git repository.
guangning pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 5728977 Expose lastConsumedTimestamp and lastAckedTimestamp to
consumer stats (#6051)
add e1c8d14 [Issue 4175] [pulsar-function-go] Add Go Function heartbeat
(and gRPC service) for production usage (#6031)
No new revisions were added by this update.
Summary of changes:
README.md | 2 +-
pulsar-client-go/go.mod | 2 +
pulsar-function-go/conf/conf.go | 7 +-
pulsar-function-go/conf/conf.yaml | 1 +
pulsar-function-go/examples/inputFunc.go | 2 +-
pulsar-function-go/examples/test/consumer.go | 1 -
pulsar-function-go/go.mod | 10 +-
pulsar-function-go/go.sum | 76 ++-
pulsar-function-go/pb/Function.pb.go | 512 ++++++++++++++-------
pulsar-function-go/pb/InstanceCommunication.pb.go | 299 ++++++++++--
pulsar-function-go/pb/Request.pb.go | 31 +-
pulsar-function-go/pb/doc.go | 2 +-
pulsar-function-go/pb/generate.sh | 2 +-
pulsar-function-go/pf/context.go | 30 +-
pulsar-function-go/pf/context_test.go | 2 +
pulsar-function-go/pf/instance.go | 79 +++-
pulsar-function-go/pf/instanceConf.go | 38 +-
pulsar-function-go/pf/instanceControlServicer.go | 77 ++++
.../pf/instanceControlServicer_test.go | 78 ++++
pulsar-function-go/pf/instance_test.go | 94 ++++
20 files changed, 1084 insertions(+), 261 deletions(-)
create mode 100644 pulsar-function-go/pf/instanceControlServicer.go
create mode 100644 pulsar-function-go/pf/instanceControlServicer_test.go
create mode 100644 pulsar-function-go/pf/instance_test.go
