diff --git a/.github/workflows/static_checks_etc.yml b/.github/workflows/static_checks_etc.yml index 741b1cf0476..2ec7d4d9d82 100644 --- a/.github/workflows/static_checks_etc.yml +++ b/.github/workflows/static_checks_etc.yml @@ -1,6 +1,7 @@ name: Static Code Checks, Etc. on: + - pull_request - push permissions: read-all diff --git a/go/boost/topo/watcher/cached_size.go b/go/boost/topo/watcher/cached_size.go index 7be50c828b8..6294f3af857 100644 --- a/go/boost/topo/watcher/cached_size.go +++ b/go/boost/topo/watcher/cached_size.go @@ -65,10 +65,12 @@ func (cached *View) CachedSize(alloc bool) int64 { } // field topkOrder []vitess.io/vitess/go/boost/server/controller/boostplan/viewplan.OrderedColumn { - size += hack.RuntimeAllocSize(int64(cap(cached.topkOrder)) * int64(9)) + size += hack.RuntimeAllocSize(int64(cap(cached.topkOrder)) * int64(16)) } // field metrics *vitess.io/vitess/go/boost/topo/watcher.scopedMetrics size += cached.metrics.CachedSize(true) + // field collationEnv *vitess.io/vitess/go/mysql/collations.Environment + size += cached.collationEnv.CachedSize(true) return size } func (cached *scopedMetrics) CachedSize(alloc bool) int64 { @@ -83,7 +85,7 @@ func (cached *scopedMetrics) CachedSize(alloc bool) int64 { size += hack.RuntimeAllocSize(int64(len(cached.publicQueryID))) // field hitrate *vitess.io/vitess/go/boost/common/metrics.RateCounter if cached.hitrate != nil { - size += hack.RuntimeAllocSize(int64(57)) + size += hack.RuntimeAllocSize(int64(64)) } return size } diff --git a/go/cache/theine/bf/bf_test.go b/go/cache/theine/bf/bf_test.go index f0e505766e7..135826195ac 100644 --- a/go/cache/theine/bf/bf_test.go +++ b/go/cache/theine/bf/bf_test.go @@ -21,4 +21,24 @@ func TestBloom(t *testing.T) { exist = bf.Exist(456) require.False(t, exist) + + bf = New(0.01) + require.Equal(t, 512, bf.Capacity) + require.Equal(t, 0.01, bf.FalsePositiveRate) + + bf.Insert(123) + exist = bf.Exist(123) + require.True(t, exist) + + bf.Insert(256) + exist = bf.Exist(256) + require.True(t, exist) + + bf.Reset() + + exist = bf.Exist(123) + require.False(t, exist) + + exist = bf.Exist(256) + require.False(t, exist) } diff --git a/go/sqltypes/cached_size.go b/go/sqltypes/cached_size.go index 2a488f8450e..d70455cab1c 100644 --- a/go/sqltypes/cached_size.go +++ b/go/sqltypes/cached_size.go @@ -17,15 +17,22 @@ limitations under the License. package sqltypes -import hack "vitess.io/vitess/go/hack" +import ( + "math" + "reflect" + "unsafe" + hack "vitess.io/vitess/go/hack" +) + +//go:nocheckptr func (cached *Result) CachedSize(alloc bool) int64 { if cached == nil { return int64(0) } size := int64(0) if alloc { - size += int64(112) + size += int64(128) } // field Fields []*vitess.io/vitess/go/vt/proto/query.Field { @@ -34,6 +41,22 @@ func (cached *Result) CachedSize(alloc bool) int64 { size += elem.CachedSize(true) } } + // field IndexesUsed map[[3]string]bool + if cached.IndexesUsed != nil { + size += int64(48) + hmap := reflect.ValueOf(cached.IndexesUsed) + numBuckets := int(math.Pow(2, float64((*(*uint8)(unsafe.Pointer(hmap.Pointer() + uintptr(9))))))) + numOldBuckets := (*(*uint16)(unsafe.Pointer(hmap.Pointer() + uintptr(10)))) + size += hack.RuntimeAllocSize(int64(numOldBuckets * 408)) + if len(cached.IndexesUsed) > 0 || numBuckets > 1 { + size += hack.RuntimeAllocSize(int64(numBuckets * 408)) + } + for k := range cached.IndexesUsed { + for _, elem := range k { + size += hack.RuntimeAllocSize(int64(len(elem))) + } + } + } // field Rows [][]vitess.io/vitess/go/sqltypes.Value { size += hack.RuntimeAllocSize(int64(cap(cached.Rows)) * int64(24)) diff --git a/go/timer/timer_test.go b/go/timer/timer_test.go index c504a7d0eb2..fe268938db0 100644 --- a/go/timer/timer_test.go +++ b/go/timer/timer_test.go @@ -74,3 +74,13 @@ func TestIndefinite(t *testing.T) { time.Sleep(quarter) assert.Equal(t, int64(1), numcalls.Load()) } + +func TestInterval(t *testing.T) { + timer := NewTimer(100) + in := timer.Interval() + assert.Equal(t, 100*time.Nanosecond, in) + + timer.interval.Store(200) + in = timer.Interval() + assert.Equal(t, 200*time.Nanosecond, in) +} diff --git a/go/vt/key/destination_test.go b/go/vt/key/destination_test.go index 1f51323c715..f348b9ffa25 100644 --- a/go/vt/key/destination_test.go +++ b/go/vt/key/destination_test.go @@ -17,9 +17,12 @@ limitations under the License. package key import ( - "reflect" + "encoding/hex" "testing" + "github.com/stretchr/testify/assert" + "github.com/stretchr/testify/require" + topodatapb "vitess.io/vitess/go/vt/proto/topodata" ) @@ -51,9 +54,7 @@ func initShardArray(t *testing.T, shardingSpec string) []*topodatapb.ShardRefere } shardKrArray, err := ParseShardingSpec(shardingSpec) - if err != nil { - t.Fatalf("ParseShardingSpec failed: %v", err) - } + require.NoError(t, err, "ParseShardingSpec failed") result := make([]*topodatapb.ShardReference, len(shardKrArray)) for i, kr := range shardKrArray { @@ -137,9 +138,7 @@ func TestDestinationExactKeyRange(t *testing.T) { keyRange = &topodatapb.KeyRange{} } else { krArray, err := ParseShardingSpec(testCase.keyRange) - if err != nil { - t.Errorf("Got error while parsing sharding spec %v", err) - } + assert.NoError(t, err, "Got error while parsing sharding spec") keyRange = krArray[0] } dkr := DestinationExactKeyRange{KeyRange: keyRange} @@ -148,12 +147,10 @@ func TestDestinationExactKeyRange(t *testing.T) { gotShards = append(gotShards, shard) return nil }) - if err != nil && err.Error() != testCase.err { - t.Errorf("gotShards: %v, want %s", err, testCase.err) - } - if !reflect.DeepEqual(testCase.shards, gotShards) { - t.Errorf("want \n%#v, got \n%#v", testCase.shards, gotShards) + if testCase.err != "" { + assert.ErrorContains(t, err, testCase.err) } + assert.Equal(t, testCase.shards, gotShards) } } @@ -241,21 +238,202 @@ func TestDestinationKeyRange(t *testing.T) { keyRange = &topodatapb.KeyRange{} } else { krArray, err := ParseShardingSpec(testCase.keyRange) - if err != nil { - t.Errorf("Got error while parsing sharding spec %v", err) - } + assert.NoError(t, err, "Got error while parsing sharding spec") keyRange = krArray[0] } dkr := DestinationKeyRange{KeyRange: keyRange} var gotShards []string - if err := dkr.Resolve(allShards, func(shard string) error { + err := dkr.Resolve(allShards, func(shard string) error { gotShards = append(gotShards, shard) return nil - }); err != nil { - t.Errorf("want nil, got %v", err) - } - if !reflect.DeepEqual(testCase.shards, gotShards) { - t.Errorf("want \n%#v, got \n%#v", testCase.shards, gotShards) - } + }) + assert.NoError(t, err) + assert.Equal(t, testCase.shards, gotShards) + } +} + +func TestDestinationsString(t *testing.T) { + kr2040 := &topodatapb.KeyRange{ + Start: []byte{0x20}, + End: []byte{0x40}, + } + + got := DestinationsString([]Destination{ + DestinationShard("2"), + DestinationShards{"2", "3"}, + DestinationExactKeyRange{KeyRange: kr2040}, + DestinationKeyRange{KeyRange: kr2040}, + DestinationKeyspaceID{1, 2}, + DestinationKeyspaceIDs{ + {1, 2}, + {2, 3}, + }, + DestinationAllShards{}, + DestinationNone{}, + DestinationAnyShard{}, + }) + want := "Destinations:DestinationShard(2),DestinationShards(2,3),DestinationExactKeyRange(20-40),DestinationKeyRange(20-40),DestinationKeyspaceID(0102),DestinationKeyspaceIDs(0102,0203),DestinationAllShards(),DestinationNone(),DestinationAnyShard()" + assert.Equal(t, want, got) +} + +func TestDestinationShardResolve(t *testing.T) { + allShards := initShardArray(t, "") + + ds := DestinationShard("test-destination-shard") + + var calledVar string + err := ds.Resolve(allShards, func(shard string) error { + calledVar = shard + return nil + }) + assert.NoError(t, err) + assert.Equal(t, "test-destination-shard", calledVar) +} + +func TestDestinationShardsResolve(t *testing.T) { + allShards := initShardArray(t, "") + + ds := DestinationShards{"ds1", "ds2"} + + var calledVar []string + err := ds.Resolve(allShards, func(shard string) error { + calledVar = append(calledVar, shard) + return nil + }) + assert.NoError(t, err) + + want := []string{"ds1", "ds2"} + assert.ElementsMatch(t, want, calledVar) +} + +func TestDestinationKeyspaceIDResolve(t *testing.T) { + allShards := initShardArray(t, "60-80-90") + + testCases := []struct { + keyspaceID string + want string + err string + }{ + {"59", "", "KeyspaceId 59 didn't match any shards"}, + // Should include start limit of keyRange + {"60", "60-80", ""}, + {"79", "60-80", ""}, + {"80", "80-90", ""}, + {"89", "80-90", ""}, + // Shouldn't include end limit of keyRange + {"90", "", "KeyspaceId 90 didn't match any shards"}, + } + + for _, tc := range testCases { + t.Run(tc.keyspaceID, func(t *testing.T) { + k, err := hex.DecodeString(tc.keyspaceID) + assert.NoError(t, err) + + ds := DestinationKeyspaceID(k) + + var calledVar string + addShard := func(shard string) error { + calledVar = shard + return nil + } + + err = ds.Resolve(allShards, addShard) + if tc.err != "" { + assert.ErrorContains(t, err, tc.err) + return + } + + assert.Equal(t, tc.want, calledVar) + }) + } + + // Expect error when allShards is empty + ds := DestinationKeyspaceID("80") + err := ds.Resolve([]*topodatapb.ShardReference{}, func(_ string) error { + return nil + }) + assert.ErrorContains(t, err, "no shard in keyspace") +} + +func TestDestinationKeyspaceIDsResolve(t *testing.T) { + allShards := initShardArray(t, "60-80-90") + + k1, err := hex.DecodeString("82") + assert.NoError(t, err) + + k2, err := hex.DecodeString("61") + assert.NoError(t, err) + + k3, err := hex.DecodeString("89") + assert.NoError(t, err) + + ds := DestinationKeyspaceIDs{k1, k2, k3} + + var calledVar []string + addShard := func(shard string) error { + calledVar = append(calledVar, shard) + return nil + } + + err = ds.Resolve(allShards, addShard) + assert.NoError(t, err) + + want := []string{"80-90", "60-80", "80-90"} + assert.Equal(t, want, calledVar) +} + +func TestDestinationAllShardsResolve(t *testing.T) { + allShards := initShardArray(t, "60-80-90") + + ds := DestinationAllShards{} + + var calledVar []string + addShard := func(shard string) error { + calledVar = append(calledVar, shard) + return nil } + + err := ds.Resolve(allShards, addShard) + assert.NoError(t, err) + + want := []string{"60-80", "80-90"} + assert.ElementsMatch(t, want, calledVar) +} + +func TestDestinationNoneResolve(t *testing.T) { + allShards := initShardArray(t, "60-80-90") + + ds := DestinationNone{} + + var called bool + addShard := func(shard string) error { + called = true + return nil + } + + err := ds.Resolve(allShards, addShard) + assert.NoError(t, err) + assert.False(t, called, "addShard shouldn't be called in the case of DestinationNone") +} + +func TestDestinationAnyShardResolve(t *testing.T) { + allShards := initShardArray(t, "custom") + + ds := DestinationAnyShard{} + + var calledVar string + addShard := func(shard string) error { + calledVar = shard + return nil + } + + err := ds.Resolve(allShards, addShard) + assert.NoError(t, err) + + possibleShards := []string{"0", "1"} + assert.Contains(t, possibleShards, calledVar) + + // Expect error when allShards is empty + err = ds.Resolve([]*topodatapb.ShardReference{}, addShard) + assert.ErrorContains(t, err, "no shard in keyspace") } diff --git a/go/vt/key/key_test.go b/go/vt/key/key_test.go index 8db45aa79b9..84d4365ff0e 100644 --- a/go/vt/key/key_test.go +++ b/go/vt/key/key_test.go @@ -333,25 +333,18 @@ func TestEvenShardsKeyRange(t *testing.T) { for _, tc := range testCases { got, err := EvenShardsKeyRange(tc.i, tc.n) - if err != nil { - t.Fatalf("EvenShardsKeyRange(%v, %v) returned unexpected error: %v", tc.i, tc.n, err) - } - if !proto.Equal(got, tc.want) { - t.Errorf("EvenShardsKeyRange(%v, %v) = (%x, %x), want = (%x, %x)", tc.i, tc.n, got.Start, got.End, tc.want.Start, tc.want.End) - } + require.NoError(t, err) + assert.True(t, proto.Equal(got, tc.want), "got=(%x, %x), want=(%x, %x)", got.Start, got.End, tc.want.Start, tc.want.End) // Check if the string representation is equal as well. - if gotStr, want := KeyRangeString(got), tc.wantSpec; gotStr != want { - t.Errorf("EvenShardsKeyRange(%v) = %v, want = %v", got, gotStr, want) - } + gotStr := KeyRangeString(got) + assert.Equal(t, tc.wantSpec, gotStr) // Now verify that ParseKeyRangeParts() produces the same KeyRange object as // we do. parts := strings.Split(tc.wantSpec, "-") kr, _ := ParseKeyRangeParts(parts[0], parts[1]) - if !proto.Equal(got, kr) { - t.Errorf("EvenShardsKeyRange(%v, %v) != ParseKeyRangeParts(%v, %v): (%x, %x) != (%x, %x)", tc.i, tc.n, parts[0], parts[1], got.Start, got.End, kr.Start, kr.End) - } + assert.True(t, proto.Equal(got, kr), "EvenShardsKeyRange(%v, %v) != ParseKeyRangeParts(%v, %v): (%x, %x) != (%x, %x)", tc.i, tc.n, parts[0], parts[1], got.Start, got.End, kr.Start, kr.End) } } @@ -477,9 +470,7 @@ func TestKeyRangeEndEqual(t *testing.T) { first := stringToKeyRange(tcase.first) second := stringToKeyRange(tcase.second) out := KeyRangeEndEqual(first, second) - if out != tcase.out { - t.Fatalf("KeyRangeEndEqual(%q, %q) expected %t, got %t", tcase.first, tcase.second, tcase.out, out) - } + require.Equal(t, tcase.out, out) } } @@ -518,9 +509,7 @@ func TestKeyRangeStartEqual(t *testing.T) { first := stringToKeyRange(tcase.first) second := stringToKeyRange(tcase.second) out := KeyRangeStartEqual(first, second) - if out != tcase.out { - t.Fatalf("KeyRangeStartEqual(%q, %q) expected %t, got %t", tcase.first, tcase.second, tcase.out, out) - } + require.Equal(t, tcase.out, out) } } @@ -555,9 +544,7 @@ func TestKeyRangeEqual(t *testing.T) { first := stringToKeyRange(tcase.first) second := stringToKeyRange(tcase.second) out := KeyRangeEqual(first, second) - if out != tcase.out { - t.Fatalf("KeyRangeEqual(%q, %q) expected %t, got %t", tcase.first, tcase.second, tcase.out, out) - } + require.Equal(t, tcase.out, out) } } @@ -600,9 +587,7 @@ func TestKeyRangeContiguous(t *testing.T) { first := stringToKeyRange(tcase.first) second := stringToKeyRange(tcase.second) out := KeyRangeContiguous(first, second) - if out != tcase.out { - t.Fatalf("KeyRangeContiguous(%q, %q) expected %t, got %t", tcase.first, tcase.second, tcase.out, out) - } + require.Equal(t, tcase.out, out) } } @@ -626,10 +611,8 @@ func TestEvenShardsKeyRange_Error(t *testing.T) { } for _, tc := range testCases { - kr, err := EvenShardsKeyRange(tc.i, tc.n) - if err == nil || !strings.Contains(err.Error(), tc.wantError) { - t.Fatalf("EvenShardsKeyRange(%v, %v) = (%v, %v) want error = %v", tc.i, tc.n, kr, err, tc.wantError) - } + _, err := EvenShardsKeyRange(tc.i, tc.n) + require.ErrorContains(t, err, tc.wantError) } } @@ -653,25 +636,17 @@ func TestParseShardingSpec(t *testing.T) { } for key, wanted := range goodTable { r, err := ParseShardingSpec(key) - if err != nil { - t.Errorf("Unexpected error: %v.", err) - } - if len(r) != len(wanted) { - t.Errorf("Wrong result: wanted %v, got %v", wanted, r) + assert.NoError(t, err) + if !assert.Len(t, r, len(wanted)) { continue } for i, w := range wanted { - if !proto.Equal(r[i], w) { - t.Errorf("Wrong result: wanted %v, got %v", w, r[i]) - break - } + require.Truef(t, proto.Equal(r[i], w), "wanted %v, got %v", w, r[i]) } } for _, bad := range badTable { _, err := ParseShardingSpec(bad) - if err == nil { - t.Errorf("Didn't get expected error for %v.", bad) - } + assert.Error(t, err) } } @@ -1081,27 +1056,19 @@ func TestKeyRangeContains(t *testing.T) { for _, el := range table { s, err := hex.DecodeString(el.start) - if err != nil { - t.Errorf("Unexpected error: %v", err) - } + assert.NoError(t, err) e, err := hex.DecodeString(el.end) - if err != nil { - t.Errorf("Unexpected error: %v", err) - } + assert.NoError(t, err) kr := &topodatapb.KeyRange{ Start: s, End: e, } k, err := hex.DecodeString(el.kid) - if err != nil { - t.Errorf("Unexpected error: %v", err) - } - if c := KeyRangeContains(kr, k); c != el.contained { - t.Errorf("Unexpected result: contains for %v and (%v-%v) yields %v.", el.kid, el.start, el.end, c) - } - if !KeyRangeContains(nil, k) { - t.Errorf("KeyRangeContains(nil, x) should always be true") - } + assert.NoError(t, err) + c := KeyRangeContains(kr, k) + assert.Equal(t, el.contained, c) + + assert.True(t, KeyRangeContains(nil, k), "KeyRangeContains(nil, x) should always be true") } } @@ -1601,3 +1568,24 @@ func stringToKeyRange(spec string) *topodatapb.KeyRange { } return kr } + +func TestKeyRangeIsPartial(t *testing.T) { + testCases := []struct { + name string + keyRange *topodatapb.KeyRange + want bool + }{ + {"nil key range", nil, false}, + {"empty start and end", &topodatapb.KeyRange{}, false}, + {"empty end", &topodatapb.KeyRange{Start: []byte("12")}, true}, + {"empty start", &topodatapb.KeyRange{End: []byte("13")}, true}, + {"non-empty start and end", &topodatapb.KeyRange{Start: []byte("12"), End: []byte("13")}, true}, + } + + for _, tc := range testCases { + t.Run(tc.name, func(t *testing.T) { + isPartial := KeyRangeIsPartial(tc.keyRange) + assert.Equal(t, tc.want, isPartial) + }) + } +} diff --git a/go/vt/proto/binlogdata/binlogdata.pb.go b/go/vt/proto/binlogdata/binlogdata.pb.go index 52131ce7c53..5698e690f0d 100644 --- a/go/vt/proto/binlogdata/binlogdata.pb.go +++ b/go/vt/proto/binlogdata/binlogdata.pb.go @@ -19,7 +19,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: binlogdata.proto diff --git a/go/vt/proto/binlogservice/binlogservice.pb.go b/go/vt/proto/binlogservice/binlogservice.pb.go index 0acdb32cc33..e23504604dd 100644 --- a/go/vt/proto/binlogservice/binlogservice.pb.go +++ b/go/vt/proto/binlogservice/binlogservice.pb.go @@ -19,7 +19,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: binlogservice.proto diff --git a/go/vt/proto/logutil/logutil.pb.go b/go/vt/proto/logutil/logutil.pb.go index ff8f1ea58c7..b6273fa066d 100644 --- a/go/vt/proto/logutil/logutil.pb.go +++ b/go/vt/proto/logutil/logutil.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: logutil.proto diff --git a/go/vt/proto/mysqlctl/mysqlctl.pb.go b/go/vt/proto/mysqlctl/mysqlctl.pb.go index d5b066dab32..4be14ec22ec 100644 --- a/go/vt/proto/mysqlctl/mysqlctl.pb.go +++ b/go/vt/proto/mysqlctl/mysqlctl.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: mysqlctl.proto diff --git a/go/vt/proto/query/query.pb.go b/go/vt/proto/query/query.pb.go index c81466e96d8..042791a1aec 100644 --- a/go/vt/proto/query/query.pb.go +++ b/go/vt/proto/query/query.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: query.proto diff --git a/go/vt/proto/queryservice/queryservice.pb.go b/go/vt/proto/queryservice/queryservice.pb.go index c8c1cb9863d..6dd33872b40 100644 --- a/go/vt/proto/queryservice/queryservice.pb.go +++ b/go/vt/proto/queryservice/queryservice.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: queryservice.proto diff --git a/go/vt/proto/replicationdata/replicationdata.pb.go b/go/vt/proto/replicationdata/replicationdata.pb.go index 58a9074556c..5d8256cfa2e 100644 --- a/go/vt/proto/replicationdata/replicationdata.pb.go +++ b/go/vt/proto/replicationdata/replicationdata.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: replicationdata.proto diff --git a/go/vt/proto/tableacl/tableacl.pb.go b/go/vt/proto/tableacl/tableacl.pb.go index 56a572a0332..f05afb00fba 100644 --- a/go/vt/proto/tableacl/tableacl.pb.go +++ b/go/vt/proto/tableacl/tableacl.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: tableacl.proto diff --git a/go/vt/proto/tabletmanagerdata/tabletmanagerdata.pb.go b/go/vt/proto/tabletmanagerdata/tabletmanagerdata.pb.go index fb79fab340f..6ec17060dd3 100644 --- a/go/vt/proto/tabletmanagerdata/tabletmanagerdata.pb.go +++ b/go/vt/proto/tabletmanagerdata/tabletmanagerdata.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: tabletmanagerdata.proto diff --git a/go/vt/proto/tabletmanagerservice/tabletmanagerservice.pb.go b/go/vt/proto/tabletmanagerservice/tabletmanagerservice.pb.go index bcf894b70a3..3d7e42cf4e3 100644 --- a/go/vt/proto/tabletmanagerservice/tabletmanagerservice.pb.go +++ b/go/vt/proto/tabletmanagerservice/tabletmanagerservice.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: tabletmanagerservice.proto diff --git a/go/vt/proto/throttlerdata/throttlerdata.pb.go b/go/vt/proto/throttlerdata/throttlerdata.pb.go index 70fac1e9373..905a862af57 100644 --- a/go/vt/proto/throttlerdata/throttlerdata.pb.go +++ b/go/vt/proto/throttlerdata/throttlerdata.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: throttlerdata.proto diff --git a/go/vt/proto/throttlerservice/throttlerservice.pb.go b/go/vt/proto/throttlerservice/throttlerservice.pb.go index f5561d36abb..7fdd1e2ce6a 100644 --- a/go/vt/proto/throttlerservice/throttlerservice.pb.go +++ b/go/vt/proto/throttlerservice/throttlerservice.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: throttlerservice.proto diff --git a/go/vt/proto/topodata/topodata.pb.go b/go/vt/proto/topodata/topodata.pb.go index 53e4330e61f..1d5b8470803 100644 --- a/go/vt/proto/topodata/topodata.pb.go +++ b/go/vt/proto/topodata/topodata.pb.go @@ -20,7 +20,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: topodata.proto diff --git a/go/vt/proto/vschema/vschema.pb.go b/go/vt/proto/vschema/vschema.pb.go index 18eec5b5086..10ef8c1296b 100644 --- a/go/vt/proto/vschema/vschema.pb.go +++ b/go/vt/proto/vschema/vschema.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vschema.proto diff --git a/go/vt/proto/vtadmin/vtadmin.pb.go b/go/vt/proto/vtadmin/vtadmin.pb.go index 609c4691045..efefbef6f21 100644 --- a/go/vt/proto/vtadmin/vtadmin.pb.go +++ b/go/vt/proto/vtadmin/vtadmin.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vtadmin.proto diff --git a/go/vt/proto/vtboost/vtboost.pb.go b/go/vt/proto/vtboost/vtboost.pb.go index e69248ebf2f..85f457fe8e9 100644 --- a/go/vt/proto/vtboost/vtboost.pb.go +++ b/go/vt/proto/vtboost/vtboost.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vtboost.proto diff --git a/go/vt/proto/vtctldata/vtctldata.pb.go b/go/vt/proto/vtctldata/vtctldata.pb.go index 42a8493b5ea..06f600f4cf5 100644 --- a/go/vt/proto/vtctldata/vtctldata.pb.go +++ b/go/vt/proto/vtctldata/vtctldata.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vtctldata.proto diff --git a/go/vt/proto/vtctlservice/vtctlservice.pb.go b/go/vt/proto/vtctlservice/vtctlservice.pb.go index 043026f974b..85bbb622299 100644 --- a/go/vt/proto/vtctlservice/vtctlservice.pb.go +++ b/go/vt/proto/vtctlservice/vtctlservice.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vtctlservice.proto diff --git a/go/vt/proto/vtgate/vtgate.pb.go b/go/vt/proto/vtgate/vtgate.pb.go index 25940d148b0..62790b78b6d 100644 --- a/go/vt/proto/vtgate/vtgate.pb.go +++ b/go/vt/proto/vtgate/vtgate.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vtgate.proto diff --git a/go/vt/proto/vtgateservice/vtgateservice.pb.go b/go/vt/proto/vtgateservice/vtgateservice.pb.go index 19f8bcfb458..b293fd0631b 100644 --- a/go/vt/proto/vtgateservice/vtgateservice.pb.go +++ b/go/vt/proto/vtgateservice/vtgateservice.pb.go @@ -18,7 +18,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vtgateservice.proto diff --git a/go/vt/proto/vtrpc/vtrpc.pb.go b/go/vt/proto/vtrpc/vtrpc.pb.go index b0271564a3c..2466b71513e 100644 --- a/go/vt/proto/vtrpc/vtrpc.pb.go +++ b/go/vt/proto/vtrpc/vtrpc.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vtrpc.proto diff --git a/go/vt/proto/vttest/vttest.pb.go b/go/vt/proto/vttest/vttest.pb.go index 14395ab43df..6295c1b6e68 100644 --- a/go/vt/proto/vttest/vttest.pb.go +++ b/go/vt/proto/vttest/vttest.pb.go @@ -41,7 +41,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vttest.proto diff --git a/go/vt/proto/vttime/vttime.pb.go b/go/vt/proto/vttime/vttime.pb.go index 0fe32550613..9395edfd883 100644 --- a/go/vt/proto/vttime/vttime.pb.go +++ b/go/vt/proto/vttime/vttime.pb.go @@ -17,7 +17,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.0 +// protoc-gen-go v1.34.1 // protoc v3.21.3 // source: vttime.proto