Added virtualtimestamps field to cdc description

Author: rekby

CHANGELOG.md

@@ -1,3 +1,5 @@
+* Added virtualtimestamps field to cdc description
+
 ## v3.99.10
 * Returned legacy behaviour for interpret as `time.Time` YDB types `Date`, `Datetime` and `Timestamp` 
 

table/options/models.go

@@ -562,18 +562,20 @@ func (unit *TimeToLiveUnit) ToYDB() Ydb_Table.ValueSinceUnixEpochModeSettings_Un
 }
 
 type ChangefeedDescription struct {
-	Name   string
-	Mode   ChangefeedMode
-	Format ChangefeedFormat
-	State  ChangefeedState
+	Name             string
+	Mode             ChangefeedMode
+	Format           ChangefeedFormat
+	State            ChangefeedState
+	VirtualTimestamp bool
 }
 
 func NewChangefeedDescription(proto *Ydb_Table.ChangefeedDescription) ChangefeedDescription {
 	return ChangefeedDescription{
-		Name:   proto.GetName(),
-		Mode:   ChangefeedMode(proto.GetMode()),
-		Format: ChangefeedFormat(proto.GetFormat()),
-		State:  ChangefeedState(proto.GetState()),
+		Name:             proto.GetName(),
+		Mode:             ChangefeedMode(proto.GetMode()),
+		Format:           ChangefeedFormat(proto.GetFormat()),
+		State:            ChangefeedState(proto.GetState()),
+		VirtualTimestamp: proto.GetVirtualTimestamps(),
 	}
 }
 

tests/integration/table_create_table_description_test.go

@@ -167,3 +167,34 @@ func TestCreateTableDescription(sourceTest *testing.T) {
 		})
 	}
 }
+
+func TestTableDescriptionWithCDC(t *testing.T) {
+	scope := newScope(t)
+	escapedTablePath := "`" + scope.TablePath() + "`"
+	err := scope.Driver().Query().Exec(scope.Ctx, "ALTER TABLE "+escapedTablePath+`
+ADD CHANGEFEED test WITH (
+	MODE='NEW_AND_OLD_IMAGES',
+	FORMAT='JSON',
+	VIRTUAL_TIMESTAMPS = TRUE
+)`)
+	scope.Require.NoError(err)
+
+	var description options.Description
+	err = scope.Driver().Table().Do(scope.Ctx, func(ctx context.Context, s table.Session) error {
+		desc, err := s.DescribeTable(ctx, scope.TablePath())
+		if err == nil {
+			description = desc
+		}
+		return err
+	})
+
+	scope.Require.NoError(err)
+	expectedCDC := options.ChangefeedDescription{
+		Name:             "test",
+		Mode:             options.ChangefeedModeNewAndOldImages,
+		Format:           options.ChangefeedFormatJSON,
+		State:            options.ChangefeedStateEnabled,
+		VirtualTimestamp: true,
+	}
+	scope.Require.Equal([]options.ChangefeedDescription{expectedCDC}, description.Changefeeds)
+}