This is an automated email from the ASF dual-hosted git repository.
xiangying pushed a change to branch xiangying/txn/feature_support
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
from c7fe9be Implement transaction_impl
add 8782290 Implement transaction in producer/consumer API
No new revisions were added by this update.
Summary of changes:
pulsar/consumer.go | 2 +
pulsar/consumer_impl.go | 16 ++++++++
pulsar/consumer_partition.go | 72 ++++++++++++++++++++++++++++++++++
pulsar/error.go | 4 +-
pulsar/message.go | 2 +
pulsar/producer_partition.go | 21 ++++++++++
pulsar/transaction.go | 4 +-
pulsar/transactionCoordinatorClient.go | 26 ++++++------
pulsar/transaction_impl.go | 46 +++++++++++-----------
9 files changed, 154 insertions(+), 39 deletions(-)
