[pulsar-client-go] branch reader-last-msgID created (now 06feb849)

[xi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xiangying pushed a change to branch reader-last-msgID
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git


      at 06feb849 [improve][client] Implement GetLastMSgID for Reader

This branch includes the following new commits:

     new 06feb849 [improve][client] Implement GetLastMSgID for Reader

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[pulsar-client-go] 01/01: [improve][client] Implement GetLastMSgID for Reader

[xi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xiangying pushed a commit to branch reader-last-msgID
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git

commit 06feb849915cc933002e03c588d7ba87fc755705
Author: xiangying <19...@qq.com>
AuthorDate: Fri Sep 1 16:03:05 2023 +0800

    [improve][client] Implement GetLastMSgID for Reader
---
 pulsar/reader.go      | 3 +++
 pulsar/reader_impl.go | 4 ++++
 2 files changed, 7 insertions(+)

diff --git a/pulsar/reader.go b/pulsar/reader.go
index d58d06f6..d4d1762e 100644
--- a/pulsar/reader.go
+++ b/pulsar/reader.go
@@ -134,4 +134,7 @@ type Reader interface {
 	//            the message publish time where to reposition the subscription
 	//
 	SeekByTime(time time.Time) error
+
+	// GetLastMSgID get the last message id available for consume.
+	GetLastMSgID() (MessageID, error)
 }
diff --git a/pulsar/reader_impl.go b/pulsar/reader_impl.go
index 5a2128a3..0ebd8578 100644
--- a/pulsar/reader_impl.go
+++ b/pulsar/reader_impl.go
@@ -244,3 +244,7 @@ func (r *reader) SeekByTime(time time.Time) error {
 
 	return r.pc.SeekByTime(time)
 }
+
+func (r *reader) GetLastMSgID() (MessageID, error) {
+	return r.pc.getLastMessageID()
+}