diff --git a/go.mod b/go.mod
index 3cbe6b2..9a52e21 100644
--- a/go.mod
+++ b/go.mod
@@ -1,15 +1,15 @@
 module github.com/planetscale/psdb
 
-go 1.24
+go 1.24.5
 
 require (
 	connectrpc.com/connect v1.18.1
 	github.com/klauspost/connect-compress/v2 v2.0.0
-	github.com/planetscale/vitess-types v0.0.0-20250409004758-020920d5ec5a
-	github.com/planetscale/vtprotobuf v0.6.0
+	github.com/planetscale/vitess-types v0.0.0-20260313221731-c96dbf730f7d
+	github.com/planetscale/vtprotobuf v0.6.1-0.20241121165744-79df5c4772f2
 	github.com/segmentio/asm v1.2.0
 	github.com/stretchr/testify v1.8.4
-	google.golang.org/protobuf v1.35.1
+	google.golang.org/protobuf v1.36.5
 )
 
 require (
diff --git a/go.sum b/go.sum
index f7493b3..87245da 100644
--- a/go.sum
+++ b/go.sum
@@ -8,10 +8,10 @@ github.com/klauspost/compress v1.16.7 h1:2mk3MPGNzKyxErAw8YaohYh69+pa4sIQSC0fPGC
 github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE=
 github.com/klauspost/connect-compress/v2 v2.0.0 h1:L7TVsLa6Oo9Hkkb6r3DwSrhBbcWlXjneqBj7fCRXviU=
 github.com/klauspost/connect-compress/v2 v2.0.0/go.mod h1:604CD9JSAjGqtVzCM4SRgM/9TFTkWBcp+2wlQfGyJ6c=
-github.com/planetscale/vitess-types v0.0.0-20250409004758-020920d5ec5a h1:PMzdwra0DsbjTAufVMx8OMMTdMTMMnyKexN9AqUxCko=
-github.com/planetscale/vitess-types v0.0.0-20250409004758-020920d5ec5a/go.mod h1:yRbhtyT9XaBRJ9vwiC++ED8suzJkSmrW4j2XDN7+SPQ=
-github.com/planetscale/vtprotobuf v0.6.0 h1:nBeETjudeJ5ZgBHUz1fVHvbqUKnYOXNhsIEabROxmNA=
-github.com/planetscale/vtprotobuf v0.6.0/go.mod h1:t/avpk3KcrXxUnYOhZhMXJlSEyie6gQbtLq5NM3loB8=
+github.com/planetscale/vitess-types v0.0.0-20260313221731-c96dbf730f7d h1:6r2nVRGJSg9RJ6Et6PthIjYNzMG+zJM8RmZxX8l6zTU=
+github.com/planetscale/vitess-types v0.0.0-20260313221731-c96dbf730f7d/go.mod h1:TArDr1Y/xRBA4DCA8f2dY0hV+Y8E4JcCvZ61RLgXL5E=
+github.com/planetscale/vtprotobuf v0.6.1-0.20241121165744-79df5c4772f2 h1:1sLMdKq4gNANTj0dUibycTLzpIEKVnLnbaEkxws78nw=
+github.com/planetscale/vtprotobuf v0.6.1-0.20241121165744-79df5c4772f2/go.mod h1:t/avpk3KcrXxUnYOhZhMXJlSEyie6gQbtLq5NM3loB8=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/segmentio/asm v1.2.0 h1:9BQrFxC+YOHJlTlHGkTrFWf59nbL3XnCoFLTwDCI7ys=
@@ -24,8 +24,8 @@ golang.org/x/sys v0.11.0 h1:eG7RXZHdqOJ1i+0lgLgCpSXAp6M3LYlAo6osgSi0xOM=
 golang.org/x/sys v0.11.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
 golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
-google.golang.org/protobuf v1.35.1 h1:m3LfL6/Ca+fqnjnlqQXNpFPABW1UD7mjh8KO2mKFytA=
-google.golang.org/protobuf v1.35.1/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
+google.golang.org/protobuf v1.36.5 h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM=
+google.golang.org/protobuf v1.36.5/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
diff --git a/proto-src/buf.lock b/proto-src/buf.lock
index e55ed60..15c41c4 100644
--- a/proto-src/buf.lock
+++ b/proto-src/buf.lock
@@ -4,5 +4,5 @@ deps:
   - remote: buf.build
     owner: planetscale
     repository: vitess
-    commit: 4cad49e0382a4a21a13e508cb3dbf701
-    digest: shake256:8c04095a096df6a86b5229a88fc9188a03f02dc7772b1a2c05c1902216cb6139139e8bd279e66f5ef2d184de12476ac78954a869a9d50db1d944abbba72163fb
+    commit: 5b7c5f01d66e46969fcc8b4fee3ba31c
+    digest: shake256:e2c076e176ffc9adc554e03d5dae5fbdea6131a888eb891072d480d0d33da2851861e55fdbcd89552550f103d3471efe7a2383e81546fb70492ea9474e8499e8
diff --git a/proto-src/psdb/v1alpha1/database.proto b/proto-src/psdb/v1alpha1/database.proto
index f968c07..ca636ca 100644
--- a/proto-src/psdb/v1alpha1/database.proto
+++ b/proto-src/psdb/v1alpha1/database.proto
@@ -2,9 +2,9 @@ syntax = "proto3";
 package psdb.v1alpha1;
 
 import "psdb/data/v1/data.proto";
-import "vitess/query/v21/query.proto";
-import "vitess/vtgate/v21/vtgate.proto";
-import "vitess/vtrpc/v21/vtrpc.proto";
+import "vitess/query/v22/query.proto";
+import "vitess/vtgate/v22/vtgate.proto";
+import "vitess/vtrpc/v22/vtrpc.proto";
 
 option go_package = "github.com/planetscale/psdb/types/psdb/v1alpha1;psdbv1alpha1";
 
@@ -26,14 +26,15 @@ message ExecuteRequest {
   Session session = 1;
 
   string query = 2;
-  map<string, vitess.query.v21.BindVariable> bind_variables = 3;
+  map<string, vitess.query.v22.BindVariable> bind_variables = 3;
+  bool prepared = 4;
 }
 
 message ExecuteResponse {
   Session session = 1;
 
-  vitess.query.v21.QueryResult result = 2;
-  vitess.vtrpc.v21.RPCError error = 3;
+  vitess.query.v22.QueryResult result = 2;
+  vitess.vtrpc.v22.RPCError error = 3;
 
   // optional timing, in seconds, for the response, if empty or 0, this wasn't set
   // does not exist in the response from a StreamExecute.
@@ -44,14 +45,15 @@ message PrepareRequest {
   Session session = 1;
 
   string query = 2;
-  map<string, vitess.query.v21.BindVariable> bind_variables = 3;
+  map<string, vitess.query.v22.BindVariable> bind_variables = 3;
 }
 
 message PrepareResponse {
   Session session = 1;
 
-  repeated vitess.query.v21.Field fields = 2;
-  vitess.vtrpc.v21.RPCError error = 3;
+  repeated vitess.query.v22.Field fields = 2;
+  vitess.vtrpc.v22.RPCError error = 3;
+  uint32 params_count = 4;
 }
 
 message CloseSessionRequest {
@@ -60,12 +62,12 @@ message CloseSessionRequest {
 
 message CloseSessionResponse {
   Session session = 1;
-  vitess.vtrpc.v21.RPCError error = 2;
+  vitess.vtrpc.v22.RPCError error = 2;
 }
 
 message Session {
   bytes signature = 1;
-  vitess.vtgate.v21.Session vitess_session = 2;
+  vitess.vtgate.v22.Session vitess_session = 2;
 }
 
 service Database {
diff --git a/proto-src/psdbconnect/v1alpha1/connect.proto b/proto-src/psdbconnect/v1alpha1/connect.proto
index d2c7301..c9e069a 100644
--- a/proto-src/psdbconnect/v1alpha1/connect.proto
+++ b/proto-src/psdbconnect/v1alpha1/connect.proto
@@ -2,8 +2,8 @@ syntax = "proto3";
 
 package psdbconnect.v1alpha1;
 
-import "vitess/query/v21/query.proto";
-import "vitess/vtrpc/v21/vtrpc.proto";
+import "vitess/query/v22/query.proto";
+import "vitess/vtrpc/v22/vtrpc.proto";
 
 option go_package = "github.com/planetscale/psdb/types/psdbconnect/v1alpha1;psdbconnectv1alpha1";
 
@@ -46,25 +46,25 @@ message SyncRequest {
 // DeletedRow denotes a row that is deleted from the table referenced in the SyncRequest
 message DeletedRow {
   // This result will contain only the primary keys from the deleted row.
-  vitess.query.v21.QueryResult result = 1;
+  vitess.query.v22.QueryResult result = 1;
 }
 
 // Updated denotes a row that is updated in the table referenced in the SyncRequest
 message UpdatedRow {
   // All values of the table before the update was made.
-  vitess.query.v21.QueryResult before = 1;
+  vitess.query.v22.QueryResult before = 1;
   // All values of the table after the update was made.
-  vitess.query.v21.QueryResult after = 2;
+  vitess.query.v22.QueryResult after = 2;
 }
 
 // SyncResponse denotes a response to the SyncRequest
 message SyncResponse {
   // An array of rows that denote inserts into the table.
-  repeated vitess.query.v21.QueryResult result = 1;
+  repeated vitess.query.v22.QueryResult result = 1;
   // A state object to use that denotes the current state of the SyncResponse.
   TableCursor cursor = 2;
   // Any errors encountered in streaming data from the table.
-  vitess.vtrpc.v21.RPCError error = 3;
+  vitess.vtrpc.v22.RPCError error = 3;
   // An array of rows that denote deletes from the table.
   repeated DeletedRow deletes = 4;
   // An array of rows that denote updates to the table.
@@ -85,7 +85,7 @@ message TableCursor {
   // the SyncRequest will fail.
   string position = 3;
   // Any known last known primary key values from the a previous session.
-  vitess.query.v21.QueryResult last_known_pk = 4;
+  vitess.query.v22.QueryResult last_known_pk = 4;
 }
 
 service Connect {
diff --git a/types/.done b/types/.done
deleted file mode 100644
index e69de29..0000000
diff --git a/types/psdb/data/v1/data.pb.go b/types/psdb/data/v1/data.pb.go
index 350316d..2354a22 100644
--- a/types/psdb/data/v1/data.pb.go
+++ b/types/psdb/data/v1/data.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.35.1
+// 	protoc-gen-go v1.36.5
 // 	protoc        (unknown)
 // source: psdb/data/v1/data.proto
 
@@ -11,6 +11,7 @@ import (
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	reflect "reflect"
 	sync "sync"
+	unsafe "unsafe"
 )
 
 const (
@@ -75,7 +76,7 @@ func (Role) EnumDescriptor() ([]byte, []int) {
 
 var File_psdb_data_v1_data_proto protoreflect.FileDescriptor
 
-var file_psdb_data_v1_data_proto_rawDesc = []byte{
+var file_psdb_data_v1_data_proto_rawDesc = string([]byte{
 	0x0a, 0x17, 0x70, 0x73, 0x64, 0x62, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x76, 0x31, 0x2f, 0x64,
 	0x61, 0x74, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0c, 0x70, 0x73, 0x64, 0x62, 0x2e,
 	0x64, 0x61, 0x74, 0x61, 0x2e, 0x76, 0x31, 0x2a, 0x39, 0x0a, 0x04, 0x52, 0x6f, 0x6c, 0x65, 0x12,
@@ -87,16 +88,16 @@ var file_psdb_data_v1_data_proto_rawDesc = []byte{
 	0x62, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2f, 0x70, 0x73, 0x64, 0x62, 0x2f, 0x64, 0x61, 0x74,
 	0x61, 0x2f, 0x76, 0x31, 0x3b, 0x70, 0x73, 0x64, 0x62, 0x64, 0x61, 0x74, 0x61, 0x76, 0x31, 0x62,
 	0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
-}
+})
 
 var (
 	file_psdb_data_v1_data_proto_rawDescOnce sync.Once
-	file_psdb_data_v1_data_proto_rawDescData = file_psdb_data_v1_data_proto_rawDesc
+	file_psdb_data_v1_data_proto_rawDescData []byte
 )
 
 func file_psdb_data_v1_data_proto_rawDescGZIP() []byte {
 	file_psdb_data_v1_data_proto_rawDescOnce.Do(func() {
-		file_psdb_data_v1_data_proto_rawDescData = protoimpl.X.CompressGZIP(file_psdb_data_v1_data_proto_rawDescData)
+		file_psdb_data_v1_data_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_psdb_data_v1_data_proto_rawDesc), len(file_psdb_data_v1_data_proto_rawDesc)))
 	})
 	return file_psdb_data_v1_data_proto_rawDescData
 }
@@ -122,7 +123,7 @@ func file_psdb_data_v1_data_proto_init() {
 	out := protoimpl.TypeBuilder{
 		File: protoimpl.DescBuilder{
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
-			RawDescriptor: file_psdb_data_v1_data_proto_rawDesc,
+			RawDescriptor: unsafe.Slice(unsafe.StringData(file_psdb_data_v1_data_proto_rawDesc), len(file_psdb_data_v1_data_proto_rawDesc)),
 			NumEnums:      1,
 			NumMessages:   0,
 			NumExtensions: 0,
@@ -133,7 +134,6 @@ func file_psdb_data_v1_data_proto_init() {
 		EnumInfos:         file_psdb_data_v1_data_proto_enumTypes,
 	}.Build()
 	File_psdb_data_v1_data_proto = out.File
-	file_psdb_data_v1_data_proto_rawDesc = nil
 	file_psdb_data_v1_data_proto_goTypes = nil
 	file_psdb_data_v1_data_proto_depIdxs = nil
 }
diff --git a/types/psdb/v1alpha1/database.pb.go b/types/psdb/v1alpha1/database.pb.go
index 6feb653..1e5beaa 100644
--- a/types/psdb/v1alpha1/database.pb.go
+++ b/types/psdb/v1alpha1/database.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.35.1
+// 	protoc-gen-go v1.36.5
 // 	protoc        (unknown)
 // source: psdb/v1alpha1/database.proto
 
@@ -8,13 +8,14 @@ package psdbv1alpha1
 
 import (
 	v1 "github.com/planetscale/psdb/types/psdb/data/v1"
-	v21 "github.com/planetscale/vitess-types/gen/vitess/query/v21"
-	v212 "github.com/planetscale/vitess-types/gen/vitess/vtgate/v21"
-	v211 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v21"
+	v22 "github.com/planetscale/vitess-types/gen/vitess/query/v22"
+	v222 "github.com/planetscale/vitess-types/gen/vitess/vtgate/v22"
+	v221 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v22"
 	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	reflect "reflect"
 	sync "sync"
+	unsafe "unsafe"
 )
 
 const (
@@ -25,13 +26,12 @@ const (
 )
 
 type User struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Username      string                 `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
+	Psid          string                 `protobuf:"bytes,2,opt,name=psid,proto3" json:"psid,omitempty"`
+	Role          v1.Role                `protobuf:"varint,3,opt,name=role,proto3,enum=psdb.data.v1.Role" json:"role,omitempty"`
 	unknownFields protoimpl.UnknownFields
-
-	Username string  `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
-	Psid     string  `protobuf:"bytes,2,opt,name=psid,proto3" json:"psid,omitempty"`
-	Role     v1.Role `protobuf:"varint,3,opt,name=role,proto3,enum=psdb.data.v1.Role" json:"role,omitempty"`
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *User) Reset() {
@@ -86,9 +86,9 @@ func (x *User) GetRole() v1.Role {
 }
 
 type CreateSessionRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
+	state         protoimpl.MessageState `protogen:"open.v1"`
 	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *CreateSessionRequest) Reset() {
@@ -122,13 +122,12 @@ func (*CreateSessionRequest) Descriptor() ([]byte, []int) {
 }
 
 type CreateSessionResponse struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Branch        string                 `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
+	User          *User                  `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
+	Session       *Session               `protobuf:"bytes,4,opt,name=session,proto3" json:"session,omitempty"`
 	unknownFields protoimpl.UnknownFields
-
-	Branch  string   `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
-	User    *User    `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
-	Session *Session `protobuf:"bytes,4,opt,name=session,proto3" json:"session,omitempty"`
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *CreateSessionResponse) Reset() {
@@ -183,13 +182,13 @@ func (x *CreateSessionResponse) GetSession() *Session {
 }
 
 type ExecuteRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
+	state         protoimpl.MessageState       `protogen:"open.v1"`
 	Session       *Session                     `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
 	Query         string                       `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
-	BindVariables map[string]*v21.BindVariable `protobuf:"bytes,3,rep,name=bind_variables,json=bindVariables,proto3" json:"bind_variables,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
+	BindVariables map[string]*v22.BindVariable `protobuf:"bytes,3,rep,name=bind_variables,json=bindVariables,proto3" json:"bind_variables,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
+	Prepared      bool                         `protobuf:"varint,4,opt,name=prepared,proto3" json:"prepared,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *ExecuteRequest) Reset() {
@@ -236,24 +235,30 @@ func (x *ExecuteRequest) GetQuery() string {
 	return ""
 }
 
-func (x *ExecuteRequest) GetBindVariables() map[string]*v21.BindVariable {
+func (x *ExecuteRequest) GetBindVariables() map[string]*v22.BindVariable {
 	if x != nil {
 		return x.BindVariables
 	}
 	return nil
 }
 
-type ExecuteResponse struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
+func (x *ExecuteRequest) GetPrepared() bool {
+	if x != nil {
+		return x.Prepared
+	}
+	return false
+}
 
-	Session *Session         `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
-	Result  *v21.QueryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
-	Error   *v211.RPCError   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
+type ExecuteResponse struct {
+	state   protoimpl.MessageState `protogen:"open.v1"`
+	Session *Session               `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
+	Result  *v22.QueryResult       `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
+	Error   *v221.RPCError         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
 	// optional timing, in seconds, for the response, if empty or 0, this wasn't set
 	// does not exist in the response from a StreamExecute.
-	Timing float64 `protobuf:"fixed64,4,opt,name=timing,proto3" json:"timing,omitempty"`
+	Timing        float64 `protobuf:"fixed64,4,opt,name=timing,proto3" json:"timing,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *ExecuteResponse) Reset() {
@@ -293,14 +298,14 @@ func (x *ExecuteResponse) GetSession() *Session {
 	return nil
 }
 
-func (x *ExecuteResponse) GetResult() *v21.QueryResult {
+func (x *ExecuteResponse) GetResult() *v22.QueryResult {
 	if x != nil {
 		return x.Result
 	}
 	return nil
 }
 
-func (x *ExecuteResponse) GetError() *v211.RPCError {
+func (x *ExecuteResponse) GetError() *v221.RPCError {
 	if x != nil {
 		return x.Error
 	}
@@ -315,13 +320,12 @@ func (x *ExecuteResponse) GetTiming() float64 {
 }
 
 type PrepareRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
+	state         protoimpl.MessageState       `protogen:"open.v1"`
 	Session       *Session                     `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
 	Query         string                       `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
-	BindVariables map[string]*v21.BindVariable `protobuf:"bytes,3,rep,name=bind_variables,json=bindVariables,proto3" json:"bind_variables,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
+	BindVariables map[string]*v22.BindVariable `protobuf:"bytes,3,rep,name=bind_variables,json=bindVariables,proto3" json:"bind_variables,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *PrepareRequest) Reset() {
@@ -368,7 +372,7 @@ func (x *PrepareRequest) GetQuery() string {
 	return ""
 }
 
-func (x *PrepareRequest) GetBindVariables() map[string]*v21.BindVariable {
+func (x *PrepareRequest) GetBindVariables() map[string]*v22.BindVariable {
 	if x != nil {
 		return x.BindVariables
 	}
@@ -376,13 +380,13 @@ func (x *PrepareRequest) GetBindVariables() map[string]*v21.BindVariable {
 }
 
 type PrepareResponse struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Session       *Session               `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
+	Fields        []*v22.Field           `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
+	Error         *v221.RPCError         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
+	ParamsCount   uint32                 `protobuf:"varint,4,opt,name=params_count,json=paramsCount,proto3" json:"params_count,omitempty"`
 	unknownFields protoimpl.UnknownFields
-
-	Session *Session       `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
-	Fields  []*v21.Field   `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
-	Error   *v211.RPCError `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *PrepareResponse) Reset() {
@@ -422,26 +426,32 @@ func (x *PrepareResponse) GetSession() *Session {
 	return nil
 }
 
-func (x *PrepareResponse) GetFields() []*v21.Field {
+func (x *PrepareResponse) GetFields() []*v22.Field {
 	if x != nil {
 		return x.Fields
 	}
 	return nil
 }
 
-func (x *PrepareResponse) GetError() *v211.RPCError {
+func (x *PrepareResponse) GetError() *v221.RPCError {
 	if x != nil {
 		return x.Error
 	}
 	return nil
 }
 
+func (x *PrepareResponse) GetParamsCount() uint32 {
+	if x != nil {
+		return x.ParamsCount
+	}
+	return 0
+}
+
 type CloseSessionRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Session       *Session               `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
 	unknownFields protoimpl.UnknownFields
-
-	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *CloseSessionRequest) Reset() {
@@ -482,12 +492,11 @@ func (x *CloseSessionRequest) GetSession() *Session {
 }
 
 type CloseSessionResponse struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Session       *Session               `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
+	Error         *v221.RPCError         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
 	unknownFields protoimpl.UnknownFields
-
-	Session *Session       `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
-	Error   *v211.RPCError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *CloseSessionResponse) Reset() {
@@ -527,7 +536,7 @@ func (x *CloseSessionResponse) GetSession() *Session {
 	return nil
 }
 
-func (x *CloseSessionResponse) GetError() *v211.RPCError {
+func (x *CloseSessionResponse) GetError() *v221.RPCError {
 	if x != nil {
 		return x.Error
 	}
@@ -535,12 +544,11 @@ func (x *CloseSessionResponse) GetError() *v211.RPCError {
 }
 
 type Session struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	Signature     []byte                 `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
+	VitessSession *v222.Session          `protobuf:"bytes,2,opt,name=vitess_session,json=vitessSession,proto3" json:"vitess_session,omitempty"`
 	unknownFields protoimpl.UnknownFields
-
-	Signature     []byte        `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
-	VitessSession *v212.Session `protobuf:"bytes,2,opt,name=vitess_session,json=vitessSession,proto3" json:"vitess_session,omitempty"`
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *Session) Reset() {
@@ -580,7 +588,7 @@ func (x *Session) GetSignature() []byte {
 	return nil
 }
 
-func (x *Session) GetVitessSession() *v212.Session {
+func (x *Session) GetVitessSession() *v222.Session {
 	if x != nil {
 		return x.VitessSession
 	}
@@ -589,17 +597,17 @@ func (x *Session) GetVitessSession() *v212.Session {
 
 var File_psdb_v1alpha1_database_proto protoreflect.FileDescriptor
 
-var file_psdb_v1alpha1_database_proto_rawDesc = []byte{
+var file_psdb_v1alpha1_database_proto_rawDesc = string([]byte{
 	0x0a, 0x1c, 0x70, 0x73, 0x64, 0x62, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f,
 	0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0d,
 	0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x1a, 0x17, 0x70,
 	0x73, 0x64, 0x62, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x76, 0x31, 0x2f, 0x64, 0x61, 0x74, 0x61,
 	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2f, 0x71,
-	0x75, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x31, 0x2f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x70,
+	0x75, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x32, 0x2f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x70,
 	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2f, 0x76, 0x74, 0x67,
-	0x61, 0x74, 0x65, 0x2f, 0x76, 0x32, 0x31, 0x2f, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x70,
+	0x61, 0x74, 0x65, 0x2f, 0x76, 0x32, 0x32, 0x2f, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x70,
 	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2f, 0x76, 0x74, 0x72,
-	0x70, 0x63, 0x2f, 0x76, 0x32, 0x31, 0x2f, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x72, 0x6f,
+	0x70, 0x63, 0x2f, 0x76, 0x32, 0x32, 0x2f, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x72, 0x6f,
 	0x74, 0x6f, 0x22, 0x5e, 0x0a, 0x04, 0x55, 0x73, 0x65, 0x72, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73,
 	0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73,
 	0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x73, 0x69, 0x64, 0x18, 0x02,
@@ -616,7 +624,7 @@ var file_psdb_v1alpha1_database_proto_rawDesc = []byte{
 	0x04, 0x75, 0x73, 0x65, 0x72, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
 	0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31,
 	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07,
-	0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x93, 0x02, 0x0a, 0x0e, 0x45, 0x78, 0x65, 0x63,
+	0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0xaf, 0x02, 0x0a, 0x0e, 0x45, 0x78, 0x65, 0x63,
 	0x75, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65,
 	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73,
 	0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73,
@@ -627,114 +635,118 @@ var file_psdb_v1alpha1_database_proto_rawDesc = []byte{
 	0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75,
 	0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61,
 	0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0d, 0x62, 0x69,
-	0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x1a, 0x60, 0x0a, 0x12, 0x42,
-	0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72,
-	0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03,
-	0x6b, 0x65, 0x79, 0x12, 0x34, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01,
-	0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72,
-	0x79, 0x2e, 0x76, 0x32, 0x31, 0x2e, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62,
-	0x6c, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xc4, 0x01,
-	0x0a, 0x0f, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
-	0x65, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01,
-	0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68,
-	0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73,
-	0x69, 0x6f, 0x6e, 0x12, 0x35, 0x0a, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x02, 0x20,
-	0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65,
-	0x72, 0x79, 0x2e, 0x76, 0x32, 0x31, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75,
-	0x6c, 0x74, 0x52, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x30, 0x0a, 0x05, 0x65, 0x72,
-	0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65,
-	0x73, 0x73, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x32, 0x31, 0x2e, 0x52, 0x50, 0x43,
-	0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x16, 0x0a, 0x06,
-	0x74, 0x69, 0x6d, 0x69, 0x6e, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x01, 0x52, 0x06, 0x74, 0x69,
-	0x6d, 0x69, 0x6e, 0x67, 0x22, 0x93, 0x02, 0x0a, 0x0e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65,
-	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69,
-	0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e,
-	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
-	0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x14, 0x0a, 0x05, 0x71, 0x75, 0x65,
-	0x72, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12,
-	0x57, 0x0a, 0x0e, 0x62, 0x69, 0x6e, 0x64, 0x5f, 0x76, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65,
-	0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76,
-	0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x52,
-	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61,
-	0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0d, 0x62, 0x69, 0x6e, 0x64, 0x56,
-	0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x1a, 0x60, 0x0a, 0x12, 0x42, 0x69, 0x6e, 0x64,
-	0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10,
-	0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79,
-	0x12, 0x34, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
-	0x1e, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76,
-	0x32, 0x31, 0x2e, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x52,
-	0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xa6, 0x01, 0x0a, 0x0f, 0x50,
-	0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x30,
-	0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
-	0x16, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e,
-	0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
-	0x12, 0x2f, 0x0a, 0x06, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b,
-	0x32, 0x17, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
-	0x76, 0x32, 0x31, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x52, 0x06, 0x66, 0x69, 0x65, 0x6c, 0x64,
-	0x73, 0x12, 0x30, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b,
-	0x32, 0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e,
-	0x76, 0x32, 0x31, 0x2e, 0x52, 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72,
-	0x72, 0x6f, 0x72, 0x22, 0x47, 0x0a, 0x13, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73,
-	0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65,
+	0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x70,
+	0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x70,
+	0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x64, 0x1a, 0x60, 0x0a, 0x12, 0x42, 0x69, 0x6e, 0x64, 0x56,
+	0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a,
+	0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12,
+	0x34, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e,
+	0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32,
+	0x32, 0x2e, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x05,
+	0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xc4, 0x01, 0x0a, 0x0f, 0x45, 0x78,
+	0x65, 0x63, 0x75, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x30, 0x0a,
+	0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16,
+	0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53,
+	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12,
+	0x35, 0x0a, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
+	0x1d, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76,
+	0x32, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x06,
+	0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x30, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18,
+	0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x76,
+	0x74, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x32, 0x32, 0x2e, 0x52, 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f,
+	0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x69, 0x6d, 0x69,
+	0x6e, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x01, 0x52, 0x06, 0x74, 0x69, 0x6d, 0x69, 0x6e, 0x67,
+	0x22, 0x93, 0x02, 0x0a, 0x0e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x52, 0x65, 0x71, 0x75,
+	0x65, 0x73, 0x74, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01,
+	0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c,
+	0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65,
+	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x14, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x02,
+	0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x57, 0x0a, 0x0e, 0x62,
+	0x69, 0x6e, 0x64, 0x5f, 0x76, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x18, 0x03, 0x20,
+	0x03, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70,
+	0x68, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
+	0x73, 0x74, 0x2e, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73,
+	0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0d, 0x62, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61,
+	0x62, 0x6c, 0x65, 0x73, 0x1a, 0x60, 0x0a, 0x12, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69,
+	0x61, 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65,
+	0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x34, 0x0a, 0x05,
+	0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x76, 0x69,
+	0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x32, 0x2e, 0x42,
+	0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c,
+	0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xc9, 0x01, 0x0a, 0x0f, 0x50, 0x72, 0x65, 0x70, 0x61,
+	0x72, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65,
 	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73,
 	0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73,
-	0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x7a, 0x0a, 0x14,
-	0x43, 0x6c, 0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70,
-	0x6f, 0x6e, 0x73, 0x65, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18,
-	0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61,
-	0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73,
-	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x30, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18,
-	0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x76,
-	0x74, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x32, 0x31, 0x2e, 0x52, 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f,
-	0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x6a, 0x0a, 0x07, 0x53, 0x65, 0x73, 0x73,
-	0x69, 0x6f, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65,
-	0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72,
-	0x65, 0x12, 0x41, 0x0a, 0x0e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x5f, 0x73, 0x65, 0x73, 0x73,
-	0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65,
-	0x73, 0x73, 0x2e, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x76, 0x32, 0x31, 0x2e, 0x53, 0x65,
-	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0d, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x53, 0x65, 0x73,
-	0x73, 0x69, 0x6f, 0x6e, 0x32, 0xaf, 0x03, 0x0a, 0x08, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73,
-	0x65, 0x12, 0x5c, 0x0a, 0x0d, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69,
-	0x6f, 0x6e, 0x12, 0x23, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68,
-	0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
-	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x24, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76,
-	0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x65,
-	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12,
-	0x4a, 0x0a, 0x07, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x12, 0x1d, 0x2e, 0x70, 0x73, 0x64,
-	0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75,
-	0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, 0x73, 0x64, 0x62,
+	0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x2f, 0x0a, 0x06,
+	0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x76,
+	0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x32, 0x2e,
+	0x46, 0x69, 0x65, 0x6c, 0x64, 0x52, 0x06, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x12, 0x30, 0x0a,
+	0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x76,
+	0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x76, 0x32, 0x32, 0x2e,
+	0x52, 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12,
+	0x21, 0x0a, 0x0c, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18,
+	0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x43, 0x6f, 0x75,
+	0x6e, 0x74, 0x22, 0x47, 0x0a, 0x13, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69,
+	0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65, 0x73,
+	0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73, 0x64,
+	0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69,
+	0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x7a, 0x0a, 0x14, 0x43,
+	0x6c, 0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f,
+	0x6e, 0x73, 0x65, 0x12, 0x30, 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01,
+	0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c,
+	0x70, 0x68, 0x61, 0x31, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65,
+	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x30, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02,
+	0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x74,
+	0x72, 0x70, 0x63, 0x2e, 0x76, 0x32, 0x32, 0x2e, 0x52, 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f, 0x72,
+	0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x6a, 0x0a, 0x07, 0x53, 0x65, 0x73, 0x73, 0x69,
+	0x6f, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x18,
+	0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65,
+	0x12, 0x41, 0x0a, 0x0e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x5f, 0x73, 0x65, 0x73, 0x73, 0x69,
+	0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73,
+	0x73, 0x2e, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x76, 0x32, 0x32, 0x2e, 0x53, 0x65, 0x73,
+	0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0d, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x53, 0x65, 0x73, 0x73,
+	0x69, 0x6f, 0x6e, 0x32, 0xaf, 0x03, 0x0a, 0x08, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65,
+	0x12, 0x5c, 0x0a, 0x0d, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f,
+	0x6e, 0x12, 0x23, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
+	0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52,
+	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x24, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31,
+	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x65, 0x73,
+	0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x4a,
+	0x0a, 0x07, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x12, 0x1d, 0x2e, 0x70, 0x73, 0x64, 0x62,
 	0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74,
-	0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x52, 0x0a, 0x0d, 0x53,
-	0x74, 0x72, 0x65, 0x61, 0x6d, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x12, 0x1d, 0x2e, 0x70,
-	0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x78, 0x65,
-	0x63, 0x75, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, 0x73,
+	0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e,
+	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x52, 0x0a, 0x0d, 0x53, 0x74,
+	0x72, 0x65, 0x61, 0x6d, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x12, 0x1d, 0x2e, 0x70, 0x73,
 	0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63,
-	0x75, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x30, 0x01, 0x12,
-	0x4a, 0x0a, 0x07, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x12, 0x1d, 0x2e, 0x70, 0x73, 0x64,
-	0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61,
-	0x72, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, 0x73, 0x64, 0x62,
+	0x75, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, 0x73, 0x64,
+	0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75,
+	0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x30, 0x01, 0x12, 0x4a,
+	0x0a, 0x07, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x12, 0x1d, 0x2e, 0x70, 0x73, 0x64, 0x62,
 	0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72,
-	0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x59, 0x0a, 0x0c, 0x43,
-	0x6c, 0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x22, 0x2e, 0x70, 0x73,
-	0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x6f, 0x73,
-	0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
-	0x23, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e,
-	0x43, 0x6c, 0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70,
-	0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x3e, 0x5a, 0x3c, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62,
-	0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x70, 0x6c, 0x61, 0x6e, 0x65, 0x74, 0x73, 0x63, 0x61, 0x6c, 0x65,
-	0x2f, 0x70, 0x73, 0x64, 0x62, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2f, 0x70, 0x73, 0x64, 0x62,
-	0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x3b, 0x70, 0x73, 0x64, 0x62, 0x76, 0x31,
-	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
-}
+	0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e,
+	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x65, 0x70, 0x61, 0x72, 0x65,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x59, 0x0a, 0x0c, 0x43, 0x6c,
+	0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x22, 0x2e, 0x70, 0x73, 0x64,
+	0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x6c, 0x6f, 0x73, 0x65,
+	0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23,
+	0x2e, 0x70, 0x73, 0x64, 0x62, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43,
+	0x6c, 0x6f, 0x73, 0x65, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f,
+	0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x3e, 0x5a, 0x3c, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e,
+	0x63, 0x6f, 0x6d, 0x2f, 0x70, 0x6c, 0x61, 0x6e, 0x65, 0x74, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x2f,
+	0x70, 0x73, 0x64, 0x62, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2f, 0x70, 0x73, 0x64, 0x62, 0x2f,
+	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x3b, 0x70, 0x73, 0x64, 0x62, 0x76, 0x31, 0x61,
+	0x6c, 0x70, 0x68, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+})
 
 var (
 	file_psdb_v1alpha1_database_proto_rawDescOnce sync.Once
-	file_psdb_v1alpha1_database_proto_rawDescData = file_psdb_v1alpha1_database_proto_rawDesc
+	file_psdb_v1alpha1_database_proto_rawDescData []byte
 )
 
 func file_psdb_v1alpha1_database_proto_rawDescGZIP() []byte {
 	file_psdb_v1alpha1_database_proto_rawDescOnce.Do(func() {
-		file_psdb_v1alpha1_database_proto_rawDescData = protoimpl.X.CompressGZIP(file_psdb_v1alpha1_database_proto_rawDescData)
+		file_psdb_v1alpha1_database_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_psdb_v1alpha1_database_proto_rawDesc), len(file_psdb_v1alpha1_database_proto_rawDesc)))
 	})
 	return file_psdb_v1alpha1_database_proto_rawDescData
 }
@@ -754,11 +766,11 @@ var file_psdb_v1alpha1_database_proto_goTypes = []any{
 	nil,                           // 10: psdb.v1alpha1.ExecuteRequest.BindVariablesEntry
 	nil,                           // 11: psdb.v1alpha1.PrepareRequest.BindVariablesEntry
 	(v1.Role)(0),                  // 12: psdb.data.v1.Role
-	(*v21.QueryResult)(nil),       // 13: vitess.query.v21.QueryResult
-	(*v211.RPCError)(nil),         // 14: vitess.vtrpc.v21.RPCError
-	(*v21.Field)(nil),             // 15: vitess.query.v21.Field
-	(*v212.Session)(nil),          // 16: vitess.vtgate.v21.Session
-	(*v21.BindVariable)(nil),      // 17: vitess.query.v21.BindVariable
+	(*v22.QueryResult)(nil),       // 13: vitess.query.v22.QueryResult
+	(*v221.RPCError)(nil),         // 14: vitess.vtrpc.v22.RPCError
+	(*v22.Field)(nil),             // 15: vitess.query.v22.Field
+	(*v222.Session)(nil),          // 16: vitess.vtgate.v22.Session
+	(*v22.BindVariable)(nil),      // 17: vitess.query.v22.BindVariable
 }
 var file_psdb_v1alpha1_database_proto_depIdxs = []int32{
 	12, // 0: psdb.v1alpha1.User.role:type_name -> psdb.data.v1.Role
@@ -767,19 +779,19 @@ var file_psdb_v1alpha1_database_proto_depIdxs = []int32{
 	9,  // 3: psdb.v1alpha1.ExecuteRequest.session:type_name -> psdb.v1alpha1.Session
 	10, // 4: psdb.v1alpha1.ExecuteRequest.bind_variables:type_name -> psdb.v1alpha1.ExecuteRequest.BindVariablesEntry
 	9,  // 5: psdb.v1alpha1.ExecuteResponse.session:type_name -> psdb.v1alpha1.Session
-	13, // 6: psdb.v1alpha1.ExecuteResponse.result:type_name -> vitess.query.v21.QueryResult
-	14, // 7: psdb.v1alpha1.ExecuteResponse.error:type_name -> vitess.vtrpc.v21.RPCError
+	13, // 6: psdb.v1alpha1.ExecuteResponse.result:type_name -> vitess.query.v22.QueryResult
+	14, // 7: psdb.v1alpha1.ExecuteResponse.error:type_name -> vitess.vtrpc.v22.RPCError
 	9,  // 8: psdb.v1alpha1.PrepareRequest.session:type_name -> psdb.v1alpha1.Session
 	11, // 9: psdb.v1alpha1.PrepareRequest.bind_variables:type_name -> psdb.v1alpha1.PrepareRequest.BindVariablesEntry
 	9,  // 10: psdb.v1alpha1.PrepareResponse.session:type_name -> psdb.v1alpha1.Session
-	15, // 11: psdb.v1alpha1.PrepareResponse.fields:type_name -> vitess.query.v21.Field
-	14, // 12: psdb.v1alpha1.PrepareResponse.error:type_name -> vitess.vtrpc.v21.RPCError
+	15, // 11: psdb.v1alpha1.PrepareResponse.fields:type_name -> vitess.query.v22.Field
+	14, // 12: psdb.v1alpha1.PrepareResponse.error:type_name -> vitess.vtrpc.v22.RPCError
 	9,  // 13: psdb.v1alpha1.CloseSessionRequest.session:type_name -> psdb.v1alpha1.Session
 	9,  // 14: psdb.v1alpha1.CloseSessionResponse.session:type_name -> psdb.v1alpha1.Session
-	14, // 15: psdb.v1alpha1.CloseSessionResponse.error:type_name -> vitess.vtrpc.v21.RPCError
-	16, // 16: psdb.v1alpha1.Session.vitess_session:type_name -> vitess.vtgate.v21.Session
-	17, // 17: psdb.v1alpha1.ExecuteRequest.BindVariablesEntry.value:type_name -> vitess.query.v21.BindVariable
-	17, // 18: psdb.v1alpha1.PrepareRequest.BindVariablesEntry.value:type_name -> vitess.query.v21.BindVariable
+	14, // 15: psdb.v1alpha1.CloseSessionResponse.error:type_name -> vitess.vtrpc.v22.RPCError
+	16, // 16: psdb.v1alpha1.Session.vitess_session:type_name -> vitess.vtgate.v22.Session
+	17, // 17: psdb.v1alpha1.ExecuteRequest.BindVariablesEntry.value:type_name -> vitess.query.v22.BindVariable
+	17, // 18: psdb.v1alpha1.PrepareRequest.BindVariablesEntry.value:type_name -> vitess.query.v22.BindVariable
 	1,  // 19: psdb.v1alpha1.Database.CreateSession:input_type -> psdb.v1alpha1.CreateSessionRequest
 	3,  // 20: psdb.v1alpha1.Database.Execute:input_type -> psdb.v1alpha1.ExecuteRequest
 	3,  // 21: psdb.v1alpha1.Database.StreamExecute:input_type -> psdb.v1alpha1.ExecuteRequest
@@ -806,7 +818,7 @@ func file_psdb_v1alpha1_database_proto_init() {
 	out := protoimpl.TypeBuilder{
 		File: protoimpl.DescBuilder{
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
-			RawDescriptor: file_psdb_v1alpha1_database_proto_rawDesc,
+			RawDescriptor: unsafe.Slice(unsafe.StringData(file_psdb_v1alpha1_database_proto_rawDesc), len(file_psdb_v1alpha1_database_proto_rawDesc)),
 			NumEnums:      0,
 			NumMessages:   12,
 			NumExtensions: 0,
@@ -817,7 +829,6 @@ func file_psdb_v1alpha1_database_proto_init() {
 		MessageInfos:      file_psdb_v1alpha1_database_proto_msgTypes,
 	}.Build()
 	File_psdb_v1alpha1_database_proto = out.File
-	file_psdb_v1alpha1_database_proto_rawDesc = nil
 	file_psdb_v1alpha1_database_proto_goTypes = nil
 	file_psdb_v1alpha1_database_proto_depIdxs = nil
 }
diff --git a/types/psdb/v1alpha1/database_vtproto.pb.go b/types/psdb/v1alpha1/database_vtproto.pb.go
index b181c82..0e583ae 100644
--- a/types/psdb/v1alpha1/database_vtproto.pb.go
+++ b/types/psdb/v1alpha1/database_vtproto.pb.go
@@ -1,5 +1,5 @@
 // Code generated by protoc-gen-go-vtproto. DO NOT EDIT.
-// protoc-gen-go-vtproto version: v0.6.0
+// protoc-gen-go-vtproto version: v0.6.1-0.20241121165744-79df5c4772f2
 // source: psdb/v1alpha1/database.proto
 
 package psdbv1alpha1
@@ -8,9 +8,9 @@ import (
 	binary "encoding/binary"
 	fmt "fmt"
 	v1 "github.com/planetscale/psdb/types/psdb/data/v1"
-	v21 "github.com/planetscale/vitess-types/gen/vitess/query/v21"
-	v212 "github.com/planetscale/vitess-types/gen/vitess/vtgate/v21"
-	v211 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v21"
+	v22 "github.com/planetscale/vitess-types/gen/vitess/query/v22"
+	v222 "github.com/planetscale/vitess-types/gen/vitess/vtgate/v22"
+	v221 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v22"
 	protohelpers "github.com/planetscale/vtprotobuf/protohelpers"
 	proto "google.golang.org/protobuf/proto"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
@@ -200,6 +200,16 @@ func (m *ExecuteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
 		i -= len(m.unknownFields)
 		copy(dAtA[i:], m.unknownFields)
 	}
+	if m.Prepared {
+		i--
+		if m.Prepared {
+			dAtA[i] = 1
+		} else {
+			dAtA[i] = 0
+		}
+		i--
+		dAtA[i] = 0x20
+	}
 	if len(m.BindVariables) > 0 {
 		for k := range m.BindVariables {
 			v := m.BindVariables[k]
@@ -461,6 +471,11 @@ func (m *PrepareResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
 		i -= len(m.unknownFields)
 		copy(dAtA[i:], m.unknownFields)
 	}
+	if m.ParamsCount != 0 {
+		i = protohelpers.EncodeVarint(dAtA, i, uint64(m.ParamsCount))
+		i--
+		dAtA[i] = 0x20
+	}
 	if m.Error != nil {
 		if vtmsg, ok := interface{}(m.Error).(interface {
 			MarshalToSizedBufferVT([]byte) (int, error)
@@ -776,6 +791,9 @@ func (m *ExecuteRequest) SizeVT() (n int) {
 			n += mapEntrySize + 1 + protohelpers.SizeOfVarint(uint64(mapEntrySize))
 		}
 	}
+	if m.Prepared {
+		n += 2
+	}
 	n += len(m.unknownFields)
 	return n
 }
@@ -886,6 +904,9 @@ func (m *PrepareResponse) SizeVT() (n int) {
 		}
 		n += 1 + l + protohelpers.SizeOfVarint(uint64(l))
 	}
+	if m.ParamsCount != 0 {
+		n += 1 + protohelpers.SizeOfVarint(uint64(m.ParamsCount))
+	}
 	n += len(m.unknownFields)
 	return n
 }
@@ -1419,10 +1440,10 @@ func (m *ExecuteRequest) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.BindVariables == nil {
-				m.BindVariables = make(map[string]*v21.BindVariable)
+				m.BindVariables = make(map[string]*v22.BindVariable)
 			}
 			var mapkey string
-			var mapvalue *v21.BindVariable
+			var mapvalue *v22.BindVariable
 			for iNdEx < postIndex {
 				entryPreIndex := iNdEx
 				var wire uint64
@@ -1496,7 +1517,7 @@ func (m *ExecuteRequest) UnmarshalVT(dAtA []byte) error {
 					if postmsgIndex > l {
 						return io.ErrUnexpectedEOF
 					}
-					mapvalue = &v21.BindVariable{}
+					mapvalue = &v22.BindVariable{}
 					if unmarshal, ok := interface{}(mapvalue).(interface {
 						UnmarshalVT([]byte) error
 					}); ok {
@@ -1526,6 +1547,26 @@ func (m *ExecuteRequest) UnmarshalVT(dAtA []byte) error {
 			}
 			m.BindVariables[mapkey] = mapvalue
 			iNdEx = postIndex
+		case 4:
+			if wireType != 0 {
+				return fmt.Errorf("proto: wrong wireType = %d for field Prepared", wireType)
+			}
+			var v int
+			for shift := uint(0); ; shift += 7 {
+				if shift >= 64 {
+					return protohelpers.ErrIntOverflow
+				}
+				if iNdEx >= l {
+					return io.ErrUnexpectedEOF
+				}
+				b := dAtA[iNdEx]
+				iNdEx++
+				v |= int(b&0x7F) << shift
+				if b < 0x80 {
+					break
+				}
+			}
+			m.Prepared = bool(v != 0)
 		default:
 			iNdEx = preIndex
 			skippy, err := protohelpers.Skip(dAtA[iNdEx:])
@@ -1643,7 +1684,7 @@ func (m *ExecuteResponse) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.Result == nil {
-				m.Result = &v21.QueryResult{}
+				m.Result = &v22.QueryResult{}
 			}
 			if unmarshal, ok := interface{}(m.Result).(interface {
 				UnmarshalVT([]byte) error
@@ -1687,7 +1728,7 @@ func (m *ExecuteResponse) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.Error == nil {
-				m.Error = &v211.RPCError{}
+				m.Error = &v221.RPCError{}
 			}
 			if unmarshal, ok := interface{}(m.Error).(interface {
 				UnmarshalVT([]byte) error
@@ -1861,10 +1902,10 @@ func (m *PrepareRequest) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.BindVariables == nil {
-				m.BindVariables = make(map[string]*v21.BindVariable)
+				m.BindVariables = make(map[string]*v22.BindVariable)
 			}
 			var mapkey string
-			var mapvalue *v21.BindVariable
+			var mapvalue *v22.BindVariable
 			for iNdEx < postIndex {
 				entryPreIndex := iNdEx
 				var wire uint64
@@ -1938,7 +1979,7 @@ func (m *PrepareRequest) UnmarshalVT(dAtA []byte) error {
 					if postmsgIndex > l {
 						return io.ErrUnexpectedEOF
 					}
-					mapvalue = &v21.BindVariable{}
+					mapvalue = &v22.BindVariable{}
 					if unmarshal, ok := interface{}(mapvalue).(interface {
 						UnmarshalVT([]byte) error
 					}); ok {
@@ -2084,7 +2125,7 @@ func (m *PrepareResponse) UnmarshalVT(dAtA []byte) error {
 			if postIndex > l {
 				return io.ErrUnexpectedEOF
 			}
-			m.Fields = append(m.Fields, &v21.Field{})
+			m.Fields = append(m.Fields, &v22.Field{})
 			if unmarshal, ok := interface{}(m.Fields[len(m.Fields)-1]).(interface {
 				UnmarshalVT([]byte) error
 			}); ok {
@@ -2127,7 +2168,7 @@ func (m *PrepareResponse) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.Error == nil {
-				m.Error = &v211.RPCError{}
+				m.Error = &v221.RPCError{}
 			}
 			if unmarshal, ok := interface{}(m.Error).(interface {
 				UnmarshalVT([]byte) error
@@ -2141,6 +2182,25 @@ func (m *PrepareResponse) UnmarshalVT(dAtA []byte) error {
 				}
 			}
 			iNdEx = postIndex
+		case 4:
+			if wireType != 0 {
+				return fmt.Errorf("proto: wrong wireType = %d for field ParamsCount", wireType)
+			}
+			m.ParamsCount = 0
+			for shift := uint(0); ; shift += 7 {
+				if shift >= 64 {
+					return protohelpers.ErrIntOverflow
+				}
+				if iNdEx >= l {
+					return io.ErrUnexpectedEOF
+				}
+				b := dAtA[iNdEx]
+				iNdEx++
+				m.ParamsCount |= uint32(b&0x7F) << shift
+				if b < 0x80 {
+					break
+				}
+			}
 		default:
 			iNdEx = preIndex
 			skippy, err := protohelpers.Skip(dAtA[iNdEx:])
@@ -2345,7 +2405,7 @@ func (m *CloseSessionResponse) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.Error == nil {
-				m.Error = &v211.RPCError{}
+				m.Error = &v221.RPCError{}
 			}
 			if unmarshal, ok := interface{}(m.Error).(interface {
 				UnmarshalVT([]byte) error
@@ -2474,7 +2534,7 @@ func (m *Session) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.VitessSession == nil {
-				m.VitessSession = &v212.Session{}
+				m.VitessSession = &v222.Session{}
 			}
 			if unmarshal, ok := interface{}(m.VitessSession).(interface {
 				UnmarshalVT([]byte) error
diff --git a/types/psdbconnect/v1alpha1/connect.pb.go b/types/psdbconnect/v1alpha1/connect.pb.go
index ac0cc48..57d2b13 100644
--- a/types/psdbconnect/v1alpha1/connect.pb.go
+++ b/types/psdbconnect/v1alpha1/connect.pb.go
@@ -1,18 +1,19 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.35.1
+// 	protoc-gen-go v1.36.5
 // 	protoc        (unknown)
 // source: psdbconnect/v1alpha1/connect.proto
 
 package psdbconnectv1alpha1
 
 import (
-	v21 "github.com/planetscale/vitess-types/gen/vitess/query/v21"
-	v211 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v21"
+	v22 "github.com/planetscale/vitess-types/gen/vitess/query/v22"
+	v221 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v22"
 	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	reflect "reflect"
 	sync "sync"
+	unsafe "unsafe"
 )
 
 const (
@@ -80,10 +81,7 @@ func (TabletType) EnumDescriptor() ([]byte, []int) {
 
 // SyncRequest sets up the Sync session for a specific table in a keyspace, shard.
 type SyncRequest struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
+	state protoimpl.MessageState `protogen:"open.v1"`
 	// The table name to Sync
 	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
 	// Any known state of the table from the last time a sync was run.
@@ -101,7 +99,9 @@ type SyncRequest struct {
 	Columns []string `protobuf:"bytes,7,rep,name=columns,proto3" json:"columns,omitempty"`
 	// if specified, these cells are used to pick source tablets from.
 	// defaults to the cell of the vtgate serving the VStream API.
-	Cells []string `protobuf:"bytes,8,rep,name=cells,proto3" json:"cells,omitempty"`
+	Cells         []string `protobuf:"bytes,8,rep,name=cells,proto3" json:"cells,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *SyncRequest) Reset() {
@@ -192,12 +192,11 @@ func (x *SyncRequest) GetCells() []string {
 
 // DeletedRow denotes a row that is deleted from the table referenced in the SyncRequest
 type DeletedRow struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
+	state protoimpl.MessageState `protogen:"open.v1"`
 	// This result will contain only the primary keys from the deleted row.
-	Result *v21.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
+	Result        *v22.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *DeletedRow) Reset() {
@@ -230,7 +229,7 @@ func (*DeletedRow) Descriptor() ([]byte, []int) {
 	return file_psdbconnect_v1alpha1_connect_proto_rawDescGZIP(), []int{1}
 }
 
-func (x *DeletedRow) GetResult() *v21.QueryResult {
+func (x *DeletedRow) GetResult() *v22.QueryResult {
 	if x != nil {
 		return x.Result
 	}
@@ -239,14 +238,13 @@ func (x *DeletedRow) GetResult() *v21.QueryResult {
 
 // Updated denotes a row that is updated in the table referenced in the SyncRequest
 type UpdatedRow struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
+	state protoimpl.MessageState `protogen:"open.v1"`
 	// All values of the table before the update was made.
-	Before *v21.QueryResult `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"`
+	Before *v22.QueryResult `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"`
 	// All values of the table after the update was made.
-	After *v21.QueryResult `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"`
+	After         *v22.QueryResult `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *UpdatedRow) Reset() {
@@ -279,14 +277,14 @@ func (*UpdatedRow) Descriptor() ([]byte, []int) {
 	return file_psdbconnect_v1alpha1_connect_proto_rawDescGZIP(), []int{2}
 }
 
-func (x *UpdatedRow) GetBefore() *v21.QueryResult {
+func (x *UpdatedRow) GetBefore() *v22.QueryResult {
 	if x != nil {
 		return x.Before
 	}
 	return nil
 }
 
-func (x *UpdatedRow) GetAfter() *v21.QueryResult {
+func (x *UpdatedRow) GetAfter() *v22.QueryResult {
 	if x != nil {
 		return x.After
 	}
@@ -295,20 +293,19 @@ func (x *UpdatedRow) GetAfter() *v21.QueryResult {
 
 // SyncResponse denotes a response to the SyncRequest
 type SyncResponse struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
+	state protoimpl.MessageState `protogen:"open.v1"`
 	// An array of rows that denote inserts into the table.
-	Result []*v21.QueryResult `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
+	Result []*v22.QueryResult `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
 	// A state object to use that denotes the current state of the SyncResponse.
 	Cursor *TableCursor `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
 	// Any errors encountered in streaming data from the table.
-	Error *v211.RPCError `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
+	Error *v221.RPCError `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
 	// An array of rows that denote deletes from the table.
 	Deletes []*DeletedRow `protobuf:"bytes,4,rep,name=deletes,proto3" json:"deletes,omitempty"`
 	// An array of rows that denote updates to the table.
-	Updates []*UpdatedRow `protobuf:"bytes,5,rep,name=updates,proto3" json:"updates,omitempty"`
+	Updates       []*UpdatedRow `protobuf:"bytes,5,rep,name=updates,proto3" json:"updates,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *SyncResponse) Reset() {
@@ -341,7 +338,7 @@ func (*SyncResponse) Descriptor() ([]byte, []int) {
 	return file_psdbconnect_v1alpha1_connect_proto_rawDescGZIP(), []int{3}
 }
 
-func (x *SyncResponse) GetResult() []*v21.QueryResult {
+func (x *SyncResponse) GetResult() []*v22.QueryResult {
 	if x != nil {
 		return x.Result
 	}
@@ -355,7 +352,7 @@ func (x *SyncResponse) GetCursor() *TableCursor {
 	return nil
 }
 
-func (x *SyncResponse) GetError() *v211.RPCError {
+func (x *SyncResponse) GetError() *v221.RPCError {
 	if x != nil {
 		return x.Error
 	}
@@ -379,10 +376,7 @@ func (x *SyncResponse) GetUpdates() []*UpdatedRow {
 // TableCursor denotes state of a Sync request to a table.
 // This type can be round-tripped in a SyncRequest to pickup where the last Sync session left off.
 type TableCursor struct {
-	state         protoimpl.MessageState
-	sizeCache     protoimpl.SizeCache
-	unknownFields protoimpl.UnknownFields
-
+	state protoimpl.MessageState `protogen:"open.v1"`
 	// The shard to sync data from.
 	Shard string `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
 	// Keyspace within a shard where the table resides.
@@ -394,7 +388,9 @@ type TableCursor struct {
 	// the SyncRequest will fail.
 	Position string `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"`
 	// Any known last known primary key values from the a previous session.
-	LastKnownPk *v21.QueryResult `protobuf:"bytes,4,opt,name=last_known_pk,json=lastKnownPk,proto3" json:"last_known_pk,omitempty"`
+	LastKnownPk   *v22.QueryResult `protobuf:"bytes,4,opt,name=last_known_pk,json=lastKnownPk,proto3" json:"last_known_pk,omitempty"`
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
 }
 
 func (x *TableCursor) Reset() {
@@ -448,7 +444,7 @@ func (x *TableCursor) GetPosition() string {
 	return ""
 }
 
-func (x *TableCursor) GetLastKnownPk() *v21.QueryResult {
+func (x *TableCursor) GetLastKnownPk() *v22.QueryResult {
 	if x != nil {
 		return x.LastKnownPk
 	}
@@ -457,14 +453,14 @@ func (x *TableCursor) GetLastKnownPk() *v21.QueryResult {
 
 var File_psdbconnect_v1alpha1_connect_proto protoreflect.FileDescriptor
 
-var file_psdbconnect_v1alpha1_connect_proto_rawDesc = []byte{
+var file_psdbconnect_v1alpha1_connect_proto_rawDesc = string([]byte{
 	0x0a, 0x22, 0x70, 0x73, 0x64, 0x62, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x2f, 0x76, 0x31,
 	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x2e, 0x70,
 	0x72, 0x6f, 0x74, 0x6f, 0x12, 0x14, 0x70, 0x73, 0x64, 0x62, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
 	0x74, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x1a, 0x1c, 0x76, 0x69, 0x74, 0x65,
-	0x73, 0x73, 0x2f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x31, 0x2f, 0x71, 0x75, 0x65,
+	0x73, 0x73, 0x2f, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x32, 0x2f, 0x71, 0x75, 0x65,
 	0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73,
-	0x2f, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2f, 0x76, 0x32, 0x31, 0x2f, 0x76, 0x74, 0x72, 0x70, 0x63,
+	0x2f, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2f, 0x76, 0x32, 0x32, 0x2f, 0x76, 0x74, 0x72, 0x70, 0x63,
 	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xd5, 0x02, 0x0a, 0x0b, 0x53, 0x79, 0x6e, 0x63, 0x52,
 	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f,
 	0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x74, 0x61, 0x62, 0x6c,
@@ -489,27 +485,27 @@ var file_psdbconnect_v1alpha1_connect_proto_rawDesc = []byte{
 	0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x63, 0x65, 0x6c, 0x6c, 0x73, 0x22, 0x43,
 	0x0a, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, 0x12, 0x35, 0x0a, 0x06,
 	0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x76,
-	0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x31, 0x2e,
+	0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x32, 0x2e,
 	0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x06, 0x72, 0x65, 0x73,
 	0x75, 0x6c, 0x74, 0x22, 0x78, 0x0a, 0x0a, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x64, 0x52, 0x6f,
 	0x77, 0x12, 0x35, 0x0a, 0x06, 0x62, 0x65, 0x66, 0x6f, 0x72, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
 	0x0b, 0x32, 0x1d, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79,
-	0x2e, 0x76, 0x32, 0x31, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74,
+	0x2e, 0x76, 0x32, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74,
 	0x52, 0x06, 0x62, 0x65, 0x66, 0x6f, 0x72, 0x65, 0x12, 0x33, 0x0a, 0x05, 0x61, 0x66, 0x74, 0x65,
 	0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73,
-	0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x31, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79,
+	0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79,
 	0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x05, 0x61, 0x66, 0x74, 0x65, 0x72, 0x22, 0xaa, 0x02,
 	0x0a, 0x0c, 0x53, 0x79, 0x6e, 0x63, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x35,
 	0x0a, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d,
 	0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32,
-	0x31, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x06, 0x72,
+	0x32, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x06, 0x72,
 	0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x39, 0x0a, 0x06, 0x63, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x18,
 	0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x63, 0x6f, 0x6e, 0x6e,
 	0x65, 0x63, 0x74, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x54, 0x61, 0x62,
 	0x6c, 0x65, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x52, 0x06, 0x63, 0x75, 0x72, 0x73, 0x6f, 0x72,
 	0x12, 0x30, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32,
 	0x1a, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x76,
-	0x32, 0x31, 0x2e, 0x52, 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72,
+	0x32, 0x32, 0x2e, 0x52, 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72,
 	0x6f, 0x72, 0x12, 0x3a, 0x0a, 0x07, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x73, 0x18, 0x04, 0x20,
 	0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x70, 0x73, 0x64, 0x62, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
 	0x74, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74,
@@ -526,7 +522,7 @@ var file_psdbconnect_v1alpha1_connect_proto_rawDesc = []byte{
 	0x70, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x41, 0x0a, 0x0d, 0x6c, 0x61, 0x73, 0x74,
 	0x5f, 0x6b, 0x6e, 0x6f, 0x77, 0x6e, 0x5f, 0x70, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32,
 	0x1d, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x76,
-	0x32, 0x31, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x0b,
+	0x32, 0x32, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x0b,
 	0x6c, 0x61, 0x73, 0x74, 0x4b, 0x6e, 0x6f, 0x77, 0x6e, 0x50, 0x6b, 0x2a, 0x31, 0x0a, 0x0a, 0x54,
 	0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x72, 0x65, 0x70,
 	0x6c, 0x69, 0x63, 0x61, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x70, 0x72, 0x69, 0x6d, 0x61, 0x72,
@@ -543,16 +539,16 @@ var file_psdbconnect_v1alpha1_connect_proto_rawDesc = []byte{
 	0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x3b, 0x70, 0x73, 0x64, 0x62, 0x63, 0x6f, 0x6e, 0x6e, 0x65,
 	0x63, 0x74, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
 	0x6f, 0x33,
-}
+})
 
 var (
 	file_psdbconnect_v1alpha1_connect_proto_rawDescOnce sync.Once
-	file_psdbconnect_v1alpha1_connect_proto_rawDescData = file_psdbconnect_v1alpha1_connect_proto_rawDesc
+	file_psdbconnect_v1alpha1_connect_proto_rawDescData []byte
 )
 
 func file_psdbconnect_v1alpha1_connect_proto_rawDescGZIP() []byte {
 	file_psdbconnect_v1alpha1_connect_proto_rawDescOnce.Do(func() {
-		file_psdbconnect_v1alpha1_connect_proto_rawDescData = protoimpl.X.CompressGZIP(file_psdbconnect_v1alpha1_connect_proto_rawDescData)
+		file_psdbconnect_v1alpha1_connect_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_psdbconnect_v1alpha1_connect_proto_rawDesc), len(file_psdbconnect_v1alpha1_connect_proto_rawDesc)))
 	})
 	return file_psdbconnect_v1alpha1_connect_proto_rawDescData
 }
@@ -566,21 +562,21 @@ var file_psdbconnect_v1alpha1_connect_proto_goTypes = []any{
 	(*UpdatedRow)(nil),      // 3: psdbconnect.v1alpha1.UpdatedRow
 	(*SyncResponse)(nil),    // 4: psdbconnect.v1alpha1.SyncResponse
 	(*TableCursor)(nil),     // 5: psdbconnect.v1alpha1.TableCursor
-	(*v21.QueryResult)(nil), // 6: vitess.query.v21.QueryResult
-	(*v211.RPCError)(nil),   // 7: vitess.vtrpc.v21.RPCError
+	(*v22.QueryResult)(nil), // 6: vitess.query.v22.QueryResult
+	(*v221.RPCError)(nil),   // 7: vitess.vtrpc.v22.RPCError
 }
 var file_psdbconnect_v1alpha1_connect_proto_depIdxs = []int32{
 	5,  // 0: psdbconnect.v1alpha1.SyncRequest.cursor:type_name -> psdbconnect.v1alpha1.TableCursor
 	0,  // 1: psdbconnect.v1alpha1.SyncRequest.tablet_type:type_name -> psdbconnect.v1alpha1.TabletType
-	6,  // 2: psdbconnect.v1alpha1.DeletedRow.result:type_name -> vitess.query.v21.QueryResult
-	6,  // 3: psdbconnect.v1alpha1.UpdatedRow.before:type_name -> vitess.query.v21.QueryResult
-	6,  // 4: psdbconnect.v1alpha1.UpdatedRow.after:type_name -> vitess.query.v21.QueryResult
-	6,  // 5: psdbconnect.v1alpha1.SyncResponse.result:type_name -> vitess.query.v21.QueryResult
+	6,  // 2: psdbconnect.v1alpha1.DeletedRow.result:type_name -> vitess.query.v22.QueryResult
+	6,  // 3: psdbconnect.v1alpha1.UpdatedRow.before:type_name -> vitess.query.v22.QueryResult
+	6,  // 4: psdbconnect.v1alpha1.UpdatedRow.after:type_name -> vitess.query.v22.QueryResult
+	6,  // 5: psdbconnect.v1alpha1.SyncResponse.result:type_name -> vitess.query.v22.QueryResult
 	5,  // 6: psdbconnect.v1alpha1.SyncResponse.cursor:type_name -> psdbconnect.v1alpha1.TableCursor
-	7,  // 7: psdbconnect.v1alpha1.SyncResponse.error:type_name -> vitess.vtrpc.v21.RPCError
+	7,  // 7: psdbconnect.v1alpha1.SyncResponse.error:type_name -> vitess.vtrpc.v22.RPCError
 	2,  // 8: psdbconnect.v1alpha1.SyncResponse.deletes:type_name -> psdbconnect.v1alpha1.DeletedRow
 	3,  // 9: psdbconnect.v1alpha1.SyncResponse.updates:type_name -> psdbconnect.v1alpha1.UpdatedRow
-	6,  // 10: psdbconnect.v1alpha1.TableCursor.last_known_pk:type_name -> vitess.query.v21.QueryResult
+	6,  // 10: psdbconnect.v1alpha1.TableCursor.last_known_pk:type_name -> vitess.query.v22.QueryResult
 	1,  // 11: psdbconnect.v1alpha1.Connect.Sync:input_type -> psdbconnect.v1alpha1.SyncRequest
 	4,  // 12: psdbconnect.v1alpha1.Connect.Sync:output_type -> psdbconnect.v1alpha1.SyncResponse
 	12, // [12:13] is the sub-list for method output_type
@@ -599,7 +595,7 @@ func file_psdbconnect_v1alpha1_connect_proto_init() {
 	out := protoimpl.TypeBuilder{
 		File: protoimpl.DescBuilder{
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
-			RawDescriptor: file_psdbconnect_v1alpha1_connect_proto_rawDesc,
+			RawDescriptor: unsafe.Slice(unsafe.StringData(file_psdbconnect_v1alpha1_connect_proto_rawDesc), len(file_psdbconnect_v1alpha1_connect_proto_rawDesc)),
 			NumEnums:      1,
 			NumMessages:   5,
 			NumExtensions: 0,
@@ -611,7 +607,6 @@ func file_psdbconnect_v1alpha1_connect_proto_init() {
 		MessageInfos:      file_psdbconnect_v1alpha1_connect_proto_msgTypes,
 	}.Build()
 	File_psdbconnect_v1alpha1_connect_proto = out.File
-	file_psdbconnect_v1alpha1_connect_proto_rawDesc = nil
 	file_psdbconnect_v1alpha1_connect_proto_goTypes = nil
 	file_psdbconnect_v1alpha1_connect_proto_depIdxs = nil
 }
diff --git a/types/psdbconnect/v1alpha1/connect_vtproto.pb.go b/types/psdbconnect/v1alpha1/connect_vtproto.pb.go
index 1e321df..bd7692f 100644
--- a/types/psdbconnect/v1alpha1/connect_vtproto.pb.go
+++ b/types/psdbconnect/v1alpha1/connect_vtproto.pb.go
@@ -1,13 +1,13 @@
 // Code generated by protoc-gen-go-vtproto. DO NOT EDIT.
-// protoc-gen-go-vtproto version: v0.6.0
+// protoc-gen-go-vtproto version: v0.6.1-0.20241121165744-79df5c4772f2
 // source: psdbconnect/v1alpha1/connect.proto
 
 package psdbconnectv1alpha1
 
 import (
 	fmt "fmt"
-	v21 "github.com/planetscale/vitess-types/gen/vitess/query/v21"
-	v211 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v21"
+	v22 "github.com/planetscale/vitess-types/gen/vitess/query/v22"
+	v221 "github.com/planetscale/vitess-types/gen/vitess/vtrpc/v22"
 	protohelpers "github.com/planetscale/vtprotobuf/protohelpers"
 	proto "google.golang.org/protobuf/proto"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
@@ -938,7 +938,7 @@ func (m *DeletedRow) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.Result == nil {
-				m.Result = &v21.QueryResult{}
+				m.Result = &v22.QueryResult{}
 			}
 			if unmarshal, ok := interface{}(m.Result).(interface {
 				UnmarshalVT([]byte) error
@@ -1033,7 +1033,7 @@ func (m *UpdatedRow) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.Before == nil {
-				m.Before = &v21.QueryResult{}
+				m.Before = &v22.QueryResult{}
 			}
 			if unmarshal, ok := interface{}(m.Before).(interface {
 				UnmarshalVT([]byte) error
@@ -1077,7 +1077,7 @@ func (m *UpdatedRow) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.After == nil {
-				m.After = &v21.QueryResult{}
+				m.After = &v22.QueryResult{}
 			}
 			if unmarshal, ok := interface{}(m.After).(interface {
 				UnmarshalVT([]byte) error
@@ -1171,7 +1171,7 @@ func (m *SyncResponse) UnmarshalVT(dAtA []byte) error {
 			if postIndex > l {
 				return io.ErrUnexpectedEOF
 			}
-			m.Result = append(m.Result, &v21.QueryResult{})
+			m.Result = append(m.Result, &v22.QueryResult{})
 			if unmarshal, ok := interface{}(m.Result[len(m.Result)-1]).(interface {
 				UnmarshalVT([]byte) error
 			}); ok {
@@ -1250,7 +1250,7 @@ func (m *SyncResponse) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.Error == nil {
-				m.Error = &v211.RPCError{}
+				m.Error = &v221.RPCError{}
 			}
 			if unmarshal, ok := interface{}(m.Error).(interface {
 				UnmarshalVT([]byte) error
@@ -1509,7 +1509,7 @@ func (m *TableCursor) UnmarshalVT(dAtA []byte) error {
 				return io.ErrUnexpectedEOF
 			}
 			if m.LastKnownPk == nil {
-				m.LastKnownPk = &v21.QueryResult{}
+				m.LastKnownPk = &v22.QueryResult{}
 			}
 			if unmarshal, ok := interface{}(m.LastKnownPk).(interface {
 				UnmarshalVT([]byte) error