[topic] improve DescribeTopicResult

1. Fixed golangci-lint run for e2e test
2. Supported more fields from DescribeTopicResult

Author: shmel1k

CHANGELOG.md

@@ -1,6 +1,3 @@
-## v3.34.3
-* Added missing options from topicservice
-
 ## v3.34.2
 * Added some description to error message from table pool get
 * Moved implementation `sugar.GenerateDeclareSection` to `internal/table`

internal/grpcwrapper/rawtopic/describe_topic.go

@@ -2,11 +2,13 @@ package rawtopic
 
 import (
 	"fmt"
+	"time"
 
 	"github.com/ydb-platform/ydb-go-genproto/protos/Ydb_Topic"
 	"google.golang.org/protobuf/proto"
 
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawscheme"
+	"github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawtopic/rawtopiccommon"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawydb"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xerrors"
 )
@@ -26,9 +28,14 @@ func (req *DescribeTopicRequest) ToProto() *Ydb_Topic.DescribeTopicRequest {
 type DescribeTopicResult struct {
 	Operation rawydb.Operation
 
-	Self                 rawscheme.Entry
-	PartitioningSettings PartitioningSettings
-	Consumers            []Consumer
+	Self                              rawscheme.Entry
+	PartitioningSettings              PartitioningSettings
+	Consumers                         []Consumer
+	SupportedCodecs                   rawtopiccommon.SupportedCodecs
+	RetentionPeriod                   time.Duration
+	PartitionWriteBurstBytes          int64
+	PartitionWriteSpeedBytesPerSecond int64
+	Attributes                        map[string]string
 }
 
 func (res *DescribeTopicResult) FromProto(protoResponse *Ydb_Topic.DescribeTopicResponse) error {
@@ -49,6 +56,23 @@ func (res *DescribeTopicResult) FromProto(protoResponse *Ydb_Topic.DescribeTopic
 		return err
 	}
 
+	res.PartitionWriteBurstBytes = protoResult.PartitionWriteBurstBytes
+	res.PartitionWriteSpeedBytesPerSecond = protoResult.PartitionWriteSpeedBytesPerSecond
+
+	if protoResult.RetentionPeriod != nil {
+		res.RetentionPeriod = protoResult.RetentionPeriod.AsDuration()
+	}
+
+	if protoResult.SupportedCodecs != nil {
+		for _, v := range protoResult.SupportedCodecs.Codecs {
+			res.SupportedCodecs = append(res.SupportedCodecs, rawtopiccommon.Codec(v))
+		}
+	}
+
+	for k, v := range protoResult.Attributes {
+		res.Attributes[k] = v
+	}
+
 	res.Consumers = make([]Consumer, len(protoResult.Consumers))
 	for i := range res.Consumers {
 		res.Consumers[i].MustFromProto(protoResult.Consumers[i])

topic/client_e2e_test.go

@@ -11,7 +11,7 @@ import (
 
 	"github.com/stretchr/testify/require"
 
-	"github.com/ydb-platform/ydb-go-sdk/v3"
+	ydb "github.com/ydb-platform/ydb-go-sdk/v3"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicoptions"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topictypes"
 )

topic/example_test.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"io/ioutil"
 
-	"github.com/ydb-platform/ydb-go-sdk/v3"
+	ydb "github.com/ydb-platform/ydb-go-sdk/v3"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicoptions"
 )
 

topic/reader_e2e_test.go

@@ -14,7 +14,7 @@ import (
 
 	"github.com/stretchr/testify/require"
 
-	"github.com/ydb-platform/ydb-go-sdk/v3"
+	ydb "github.com/ydb-platform/ydb-go-sdk/v3"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/empty"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xcontext"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xtest"

topic/topictypes/topictypes.go

@@ -115,9 +115,14 @@ func (s *PartitionSettings) FromRaw(raw *rawtopic.PartitioningSettings) {
 //
 // Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.
 type TopicDescription struct {
-	Path              string
-	PartitionSettings PartitionSettings
-	Consumers         []Consumer
+	Path                              string
+	PartitionSettings                 PartitionSettings
+	Consumers                         []Consumer
+	SupportedCodecs                   []Codec
+	RetentionPeriod                   time.Duration
+	PartitionWriteBurstBytes          int64
+	PartitionWriteSpeedBytesPerSecond int64
+	Attributes                        map[string]string
 }
 
 // FromRaw
@@ -133,4 +138,41 @@ func (d *TopicDescription) FromRaw(raw *rawtopic.DescribeTopicResult) {
 	for i := 0; i < len(raw.Consumers); i++ {
 		d.Consumers[i].FromRaw(&raw.Consumers[i])
 	}
+
+	d.SupportedCodecs = make([]Codec, len(raw.SupportedCodecs))
+	for i := 0; i < len(raw.SupportedCodecs); i++ {
+		d.SupportedCodecs[i] = Codec(raw.SupportedCodecs[i])
+	}
+
+	d.PartitionWriteSpeedBytesPerSecond = raw.PartitionWriteSpeedBytesPerSecond
+	d.PartitionWriteBurstBytes = raw.PartitionWriteBurstBytes
+	for k, v := range raw.Attributes {
+		d.Attributes[k] = v
+	}
+}
+
+// ToRaw
+//
+// # Experimental
+//
+// Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.
+func (d *TopicDescription) ToRaw(raw *rawtopic.DescribeTopicResult) {
+	raw.Self.Name = d.Path
+	d.PartitionSettings.ToRaw(&raw.PartitioningSettings)
+
+	raw.Consumers = make([]rawtopic.Consumer, len(d.Consumers))
+	for i := 0; i < len(d.Consumers); i++ {
+		d.Consumers[i].ToRaw(&raw.Consumers[i])
+	}
+
+	raw.SupportedCodecs = make([]rawtopiccommon.Codec, len(d.SupportedCodecs))
+	for i := 0; i < len(d.SupportedCodecs); i++ {
+		raw.SupportedCodecs[i] = rawtopiccommon.Codec(d.SupportedCodecs[i])
+	}
+
+	raw.PartitionWriteBurstBytes = d.PartitionWriteBurstBytes
+	raw.PartitionWriteSpeedBytesPerSecond = d.PartitionWriteSpeedBytesPerSecond
+	for k, v := range d.Attributes {
+		raw.Attributes[k] = v
+	}
 }