From 342465334335012b688b99d9fd4bde4f0a80fa82 Mon Sep 17 00:00:00 2001
From: Rohit Nayak <rohit@planetscale.com>
Date: Wed, 6 Sep 2023 11:58:30 +0200
Subject: [PATCH] Update proto files

Signed-off-by: Rohit Nayak <rohit@planetscale.com>
---
 .../proto/binlogdata/binlogdata_vtproto.pb.go | 74 +++++++++++++++++++
 go/vt/proto/vtctldata/vtctldata_vtproto.pb.go |  2 +
 2 files changed, 76 insertions(+)

diff --git a/go/vt/proto/binlogdata/binlogdata_vtproto.pb.go b/go/vt/proto/binlogdata/binlogdata_vtproto.pb.go
index c3b86502979..379583b0354 100644
--- a/go/vt/proto/binlogdata/binlogdata_vtproto.pb.go
+++ b/go/vt/proto/binlogdata/binlogdata_vtproto.pb.go
@@ -345,6 +345,7 @@ func (m *RowEvent) CloneVT() *RowEvent {
 		TableName: m.TableName,
 		Keyspace:  m.Keyspace,
 		Shard:     m.Shard,
+		Flags:     m.Flags,
 	}
 	if rhs := m.RowChanges; rhs != nil {
 		tmpContainer := make([]*RowChange, len(rhs))
@@ -704,6 +705,67 @@ func (m *VStreamRowsResponse) CloneMessageVT() proto.Message {
 	return m.CloneVT()
 }
 
+func (m *VStreamTablesRequest) CloneVT() *VStreamTablesRequest {
+	if m == nil {
+		return (*VStreamTablesRequest)(nil)
+	}
+	r := &VStreamTablesRequest{
+		EffectiveCallerId: m.EffectiveCallerId.CloneVT(),
+		ImmediateCallerId: m.ImmediateCallerId.CloneVT(),
+		Target:            m.Target.CloneVT(),
+	}
+	if len(m.unknownFields) > 0 {
+		r.unknownFields = make([]byte, len(m.unknownFields))
+		copy(r.unknownFields, m.unknownFields)
+	}
+	return r
+}
+
+func (m *VStreamTablesRequest) CloneMessageVT() proto.Message {
+	return m.CloneVT()
+}
+
+func (m *VStreamTablesResponse) CloneVT() *VStreamTablesResponse {
+	if m == nil {
+		return (*VStreamTablesResponse)(nil)
+	}
+	r := &VStreamTablesResponse{
+		TableName: m.TableName,
+		Gtid:      m.Gtid,
+		Lastpk:    m.Lastpk.CloneVT(),
+	}
+	if rhs := m.Fields; rhs != nil {
+		tmpContainer := make([]*query.Field, len(rhs))
+		for k, v := range rhs {
+			tmpContainer[k] = v.CloneVT()
+		}
+		r.Fields = tmpContainer
+	}
+	if rhs := m.Pkfields; rhs != nil {
+		tmpContainer := make([]*query.Field, len(rhs))
+		for k, v := range rhs {
+			tmpContainer[k] = v.CloneVT()
+		}
+		r.Pkfields = tmpContainer
+	}
+	if rhs := m.Rows; rhs != nil {
+		tmpContainer := make([]*query.Row, len(rhs))
+		for k, v := range rhs {
+			tmpContainer[k] = v.CloneVT()
+		}
+		r.Rows = tmpContainer
+	}
+	if len(m.unknownFields) > 0 {
+		r.unknownFields = make([]byte, len(m.unknownFields))
+		copy(r.unknownFields, m.unknownFields)
+	}
+	return r
+}
+
+func (m *VStreamTablesResponse) CloneMessageVT() proto.Message {
+	return m.CloneVT()
+}
+
 func (m *LastPKEvent) CloneVT() *LastPKEvent {
 	if m == nil {
 		return (*LastPKEvent)(nil)
@@ -3058,11 +3120,23 @@ var vtprotoPool_VStreamTablesResponse = sync.Pool{
 }
 
 func (m *VStreamTablesResponse) ResetVT() {
+	for _, mm := range m.Fields {
+		mm.Reset()
+	}
+	f0 := m.Fields[:0]
+	for _, mm := range m.Pkfields {
+		mm.Reset()
+	}
+	f1 := m.Pkfields[:0]
 	for _, mm := range m.Rows {
 		mm.ResetVT()
 	}
+	f2 := m.Rows[:0]
 	m.Lastpk.ReturnToVTPool()
 	m.Reset()
+	m.Fields = f0
+	m.Pkfields = f1
+	m.Rows = f2
 }
 func (m *VStreamTablesResponse) ReturnToVTPool() {
 	if m != nil {
diff --git a/go/vt/proto/vtctldata/vtctldata_vtproto.pb.go b/go/vt/proto/vtctldata/vtctldata_vtproto.pb.go
index effc0ddf947..b4f4d4a00f8 100644
--- a/go/vt/proto/vtctldata/vtctldata_vtproto.pb.go
+++ b/go/vt/proto/vtctldata/vtctldata_vtproto.pb.go
@@ -110,6 +110,7 @@ func (m *MaterializeSettings) CloneVT() *MaterializeSettings {
 		OnDdl:                     m.OnDdl,
 		DeferSecondaryKeys:        m.DeferSecondaryKeys,
 		TabletSelectionPreference: m.TabletSelectionPreference,
+		AtomicCopy:                m.AtomicCopy,
 	}
 	if rhs := m.TableSettings; rhs != nil {
 		tmpContainer := make([]*TableMaterializeSettings, len(rhs))
@@ -2555,6 +2556,7 @@ func (m *MoveTablesCreateRequest) CloneVT() *MoveTablesCreateRequest {
 		DeferSecondaryKeys:        m.DeferSecondaryKeys,
 		AutoStart:                 m.AutoStart,
 		NoRoutingRules:            m.NoRoutingRules,
+		AtomicCopy:                m.AtomicCopy,
 	}
 	if rhs := m.Cells; rhs != nil {
 		tmpContainer := make([]string, len(rhs))