[incubator-inlong] 05/09: Add comment.

[gosonzhang]

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

gosonzhang pushed a commit to branch INLONG-25
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git

commit a6fc39d6f45edbb451c6b15c26933f770dc3e0af
Author: Zijie Lu <wslz...@gmail.com>
AuthorDate: Tue Jun 8 10:42:16 2021 +0800

    Add comment.
    
    Signed-off-by: Zijie Lu <wslz...@gmail.com>
---
 tubemq-client-twins/tubemq-client-go/metadata/partition.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/tubemq-client-twins/tubemq-client-go/metadata/partition.go 
b/tubemq-client-twins/tubemq-client-go/metadata/partition.go
index 3ce1ca5..d01b570 100644
--- a/tubemq-client-twins/tubemq-client-go/metadata/partition.go
+++ b/tubemq-client-twins/tubemq-client-go/metadata/partition.go
@@ -32,6 +32,7 @@ type Partition struct {
        lastConsumed bool
 }
 
+// NewPartition parses a partition from the given string.
 func NewPartition(partition string) (*Partition, error) {
        var b *Node
        var topic string
@@ -81,6 +82,7 @@ func (p *Partition) GetTopic() string {
        return p.topic
 }
 
+// GetBroker returns the broker.
 func (p *Partition) GetBroker() *Node {
        return p.broker
 }
@@ -90,6 +92,7 @@ func (p *Partition) String() string {
        return p.broker.String() + "#" + p.topic + "@" + 
strconv.Itoa(int(p.partitionID))
 }
 
+// SetLastConsumed sets the last consumed.
 func (p *Partition) SetLastConsumed(lastConsumed bool) {
        p.lastConsumed = lastConsumed
 }