Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft: table level RAW #524

Draft
wants to merge 41 commits into
base: main
Choose a base branch
from
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
41 commits
Select commit Hold shift + click to select a range
9a69582
add: latest_gtid_for_table.go
terry-xuan-gao Aug 11, 2024
7e760f4
deal: safe_session.go with LatestGTIDForTable
terry-xuan-gao Aug 12, 2024
db2b0a4
deal: scatter_conn.go with LatestGTIDForTable
terry-xuan-gao Aug 14, 2024
3c1c947
fix: e2e test
terry-xuan-gao Sep 9, 2024
2ffe951
fix: tools version latest->0.24.0
terry-xuan-gao Sep 9, 2024
8f50f5f
fix: tools version latest->0.24.0
terry-xuan-gao Sep 9, 2024
7241a8e
feat: update gtid
terry-xuan-gao Sep 12, 2024
9417b7c
update: query.proto
terry-xuan-gao Sep 12, 2024
d013467
update: .pb.go
terry-xuan-gao Sep 13, 2024
4843ef7
fix: go.mod go.sum
terry-xuan-gao Sep 13, 2024
042d799
feat: get gtid map
terry-xuan-gao Sep 15, 2024
db1c431
update: vtgate.proto
terry-xuan-gao Sep 15, 2024
c4a81bf
add: getReadAfterWriteGtid()
terry-xuan-gao Sep 16, 2024
55ca658
update: init opts.TableReadAfterWriteGtidMap
terry-xuan-gao Sep 18, 2024
f969358
fix: gtid rollback issue
terry-xuan-gao Sep 22, 2024
f3fd223
fix: init latestGTIDForTable in safeSession
terry-xuan-gao Sep 23, 2024
0819854
fix: add latest_gtid_for_table in ReadAfterWrite
terry-xuan-gao Sep 24, 2024
5f4a287
fix: scatter_conn.go
terry-xuan-gao Sep 24, 2024
7269c30
fix: vtgate.proto
terry-xuan-gao Sep 24, 2024
43f38f6
fix: vtgate.proto
terry-xuan-gao Sep 24, 2024
ee20ef2
fix: vtgate.proto
terry-xuan-gao Sep 24, 2024
9948c39
fix: query_executor.go
terry-xuan-gao Sep 24, 2024
c655033
fix: query_executor.go
terry-xuan-gao Sep 25, 2024
a256a89
fix: query_executor.go
terry-xuan-gao Sep 25, 2024
337e205
fix: query_executor.go
terry-xuan-gao Sep 25, 2024
0f8711f
fix: query_executor.go
terry-xuan-gao Sep 25, 2024
51d7751
fix: query_executor.go
terry-xuan-gao Sep 25, 2024
6d44dfb
fix: scattor_conn.go
terry-xuan-gao Sep 25, 2024
05363b6
fix: scattor_conn.go
terry-xuan-gao Sep 25, 2024
01478cb
fix: scattor_conn.go
terry-xuan-gao Sep 25, 2024
5b55897
fix: safe_session.go
terry-xuan-gao Sep 25, 2024
905d205
fix: safe_session.go
terry-xuan-gao Sep 25, 2024
72432fc
fix: safe_session.go
terry-xuan-gao Sep 25, 2024
63916e7
fix: getRAWGtid
terry-xuan-gao Sep 25, 2024
f34339d
feat: support set table_level
terry-xuan-gao Sep 25, 2024
a27e2cb
fix: getRAWGtid
terry-xuan-gao Sep 26, 2024
1eb066d
Test Table Level RAW (#541)
terry-xuan-gao Sep 28, 2024
2d40c7f
fix: reuse Parse(sql)
terry-xuan-gao Sep 28, 2024
d391498
Merge branch 'feature/table_level_RAW' into ospp-dev
terry-xuan-gao Sep 28, 2024
fe5575b
fix: reuse Parse(sql)
terry-xuan-gao Sep 28, 2024
d9b4d32
fix: function name
terry-xuan-gao Sep 28, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ jobs:
sudo apt-get install -y make unzip g++ etcd curl git wget
sudo service etcd stop
go mod download
go install golang.org/x/tools/cmd/goimports@latest
go install golang.org/x/tools/cmd/goimports@v0.24.0

- name: Run make minimaltools
if: steps.skip-workflow.outputs.skip-workflow == 'false' && steps.changes.outputs.vtadmin_changes == 'true'
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/archive/static_checks_etc.yml
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ jobs:
- name: Install goimports
if: steps.skip-workflow.outputs.skip-workflow == 'false' && (steps.changes.outputs.go_files == 'true' || steps.changes.outputs.visitor == 'true')
run: |
go install golang.org/x/tools/cmd/goimports@latest
go install golang.org/x/tools/cmd/goimports@v0.24.0

- name: Run goimports
if: steps.skip-workflow.outputs.skip-workflow == 'false' && steps.changes.outputs.go_files == 'true'
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/archive/unit_race.yml
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ jobs:
mv dist/etcd-v3.3.10-linux-amd64/{etcd,etcdctl} bin/

go mod download
go install golang.org/x/tools/cmd/goimports@latest
go install golang.org/x/tools/cmd/goimports@v0.24.0

- name: Run make tools
if: steps.skip-workflow.outputs.skip-workflow == 'false' && steps.changes.outputs.unit_tests == 'true'
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/unit_test_mysql57.yml
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ jobs:
mv dist/etcd-v3.3.10-linux-amd64/{etcd,etcdctl} bin/

go mod download
go install golang.org/x/tools/cmd/goimports@latest
go install golang.org/x/tools/cmd/goimports@v0.24.0

# install JUnit report formatter
go install github.com/vitessio/go-junit-report@HEAD
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/unit_test_mysql80.yml
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ jobs:
mv dist/etcd-v3.3.10-linux-amd64/{etcd,etcdctl} bin/

go mod download
go install golang.org/x/tools/cmd/goimports@latest
go install golang.org/x/tools/cmd/goimports@v0.24.0

# install JUnit report formatter
go install github.com/vitessio/go-junit-report@HEAD
Expand Down
94 changes: 53 additions & 41 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -3,30 +3,30 @@ module vitess.io/vitess
go 1.21

require (
cloud.google.com/go/storage v1.29.0
cloud.google.com/go/storage v1.40.0
github.com/AdaLogics/go-fuzz-headers v0.0.0-20230106234847-43070de90fa1
github.com/Azure/azure-pipeline-go v0.2.3
github.com/Azure/azure-storage-blob-go v0.15.0
github.com/DataDog/datadog-go v4.8.3+incompatible
github.com/HdrHistogram/hdrhistogram-go v0.9.0 // indirect
github.com/PuerkitoBio/goquery v1.5.1
github.com/PuerkitoBio/goquery v1.8.1
github.com/aquarapid/vaultlib v0.5.1
github.com/armon/go-metrics v0.4.1 // indirect
github.com/aws/aws-sdk-go v1.44.192
github.com/buger/jsonparser v1.1.1
github.com/cespare/xxhash/v2 v2.2.0
github.com/cespare/xxhash/v2 v2.3.0
github.com/codegangsta/inject v0.0.0-20150114235600-33e0aa1cb7c0 // indirect
github.com/corpix/uarand v0.1.1 // indirect
github.com/dave/jennifer v1.6.0
github.com/fsnotify/fsnotify v1.6.0
github.com/go-martini/martini v0.0.0-20170121215854-22fa46961aab
github.com/go-sql-driver/mysql v1.7.1
github.com/golang/glog v1.0.0
github.com/go-sql-driver/mysql v1.8.1
github.com/golang/glog v1.2.1
github.com/golang/mock v1.6.0
github.com/golang/snappy v0.0.4
github.com/google/go-cmp v0.5.9
github.com/google/go-cmp v0.6.0
github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510
github.com/google/uuid v1.3.0
github.com/google/uuid v1.6.0
github.com/gorilla/handlers v1.5.1
github.com/gorilla/mux v1.8.0
github.com/grpc-ecosystem/go-grpc-middleware v1.3.0
Expand All @@ -37,10 +37,9 @@ require (
github.com/howeyc/gopass v0.0.0-20210920133722-c8aef6fb66ef
github.com/icrowley/fake v0.0.0-20180203215853-4178557ae428
github.com/jmespath/go-jmespath v0.4.0 // indirect
github.com/klauspost/compress v1.15.15
github.com/klauspost/compress v1.17.6
github.com/klauspost/pgzip v1.2.5
github.com/magiconair/properties v1.8.7
github.com/mattn/go-sqlite3 v1.14.16 // indirect
github.com/minio/minio-go v0.0.0-20190131015406-c8a261de75c1
github.com/montanaflynn/stats v0.7.0
github.com/olekukonko/tablewriter v0.0.5
Expand All @@ -64,7 +63,7 @@ require (
github.com/spyzhov/ajson v0.7.2
github.com/stretchr/testify v1.9.0
github.com/tchap/go-patricia v2.3.0+incompatible
github.com/tidwall/gjson v1.12.1
github.com/tidwall/gjson v1.14.4
github.com/tinylib/msgp v1.1.8 // indirect
github.com/uber/jaeger-client-go v2.30.0+incompatible
github.com/uber/jaeger-lib v2.4.1+incompatible // indirect
Expand All @@ -73,22 +72,22 @@ require (
go.etcd.io/etcd/api/v3 v3.5.7
go.etcd.io/etcd/client/pkg/v3 v3.5.7
go.etcd.io/etcd/client/v3 v3.5.7
golang.org/x/crypto v0.14.0 // indirect
golang.org/x/crypto v0.23.0 // indirect
golang.org/x/lint v0.0.0-20210508222113-6edffad5e616
golang.org/x/mod v0.12.0 // indirect
golang.org/x/net v0.17.0
golang.org/x/oauth2 v0.7.0
golang.org/x/sys v0.13.0 // indirect
golang.org/x/term v0.13.0
golang.org/x/text v0.13.0
golang.org/x/time v0.3.0
golang.org/x/tools v0.13.0
google.golang.org/api v0.114.0
google.golang.org/genproto v0.0.0-20230410155749-daa745c078e1 // indirect
google.golang.org/grpc v1.54.0
golang.org/x/mod v0.16.0 // indirect
golang.org/x/net v0.25.0
golang.org/x/oauth2 v0.20.0
golang.org/x/sys v0.20.0 // indirect
golang.org/x/term v0.20.0
golang.org/x/text v0.15.0
golang.org/x/time v0.5.0
golang.org/x/tools v0.14.0
google.golang.org/api v0.180.0
google.golang.org/genproto v0.0.0-20240401170217-c3f982113cda // indirect
google.golang.org/grpc v1.65.0
google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.2.0
google.golang.org/grpc/examples v0.0.0-20210430044426-28078834f35b
google.golang.org/protobuf v1.30.0
google.golang.org/protobuf v1.34.2
gopkg.in/DataDog/dd-trace-go.v1 v1.47.0
gopkg.in/asn1-ber.v1 v1.0.0-20181015200546-f715ec2f112d // indirect
gopkg.in/gcfg.v1 v1.2.3
Expand All @@ -107,24 +106,26 @@ require (
github.com/kr/text v0.2.0
github.com/nsf/jsondiff v0.0.0-20210926074059-1e845ec5d249
github.com/pingcap/errors v0.11.5-0.20210425183316-da1aaba5fb63
golang.org/x/exp v0.0.0-20230519143937-03e91628a987
golang.org/x/exp v0.0.0-20230713183714-613f0c0eb8a1
golang.org/x/tools/cmd/cover v0.1.0-deprecated
k8s.io/utils v0.0.0-20230115233650-391b47cb4029
modernc.org/sqlite v1.20.3
)

require (
cloud.google.com/go v0.110.0 // indirect
cloud.google.com/go/compute v1.19.1 // indirect
cloud.google.com/go/compute/metadata v0.2.3 // indirect
cloud.google.com/go/iam v0.13.0 // indirect
cloud.google.com/go v0.113.0 // indirect
cloud.google.com/go/auth v0.4.1 // indirect
cloud.google.com/go/auth/oauth2adapt v0.2.2 // indirect
cloud.google.com/go/compute/metadata v0.3.0 // indirect
cloud.google.com/go/iam v1.1.7 // indirect
filippo.io/edwards25519 v1.1.0 // indirect
github.com/DataDog/datadog-agent/pkg/obfuscate v0.42.0 // indirect
github.com/DataDog/datadog-agent/pkg/remoteconfig/state v0.42.0 // indirect
github.com/DataDog/datadog-go/v5 v5.2.0 // indirect
github.com/DataDog/go-tuf v0.3.0--fix-localmeta-fork // indirect
github.com/DataDog/sketches-go v1.4.1 // indirect
github.com/Microsoft/go-winio v0.6.0 // indirect
github.com/andybalholm/cascadia v1.1.0 // indirect
github.com/Microsoft/go-winio v0.6.1 // indirect
github.com/andybalholm/cascadia v1.3.2 // indirect
github.com/benbjohnson/clock v1.3.5 // indirect
github.com/beorn7/perks v1.0.1 // indirect
github.com/coreos/go-semver v0.3.1 // indirect
Expand All @@ -134,13 +135,15 @@ require (
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/dgraph-io/ristretto v0.1.1 // indirect
github.com/dustin/go-humanize v1.0.1 // indirect
github.com/fatih/color v1.14.1 // indirect
github.com/felixge/httpsnoop v1.0.3 // indirect
github.com/go-logr/logr v1.2.3 // indirect
github.com/fatih/color v1.17.0 // indirect
github.com/felixge/httpsnoop v1.0.4 // indirect
github.com/go-logr/logr v1.4.1 // indirect
github.com/go-logr/stdr v1.2.2 // indirect
github.com/gogo/protobuf v1.3.2 // indirect
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
github.com/googleapis/enterprise-certificate-proxy v0.2.3 // indirect
github.com/googleapis/gax-go/v2 v2.7.1 // indirect
github.com/google/s2a-go v0.1.7 // indirect
github.com/googleapis/enterprise-certificate-proxy v0.3.2 // indirect
github.com/googleapis/gax-go/v2 v2.12.4 // indirect
github.com/hashicorp/go-cleanhttp v0.5.2 // indirect
github.com/hashicorp/go-hclog v1.4.0 // indirect
github.com/hashicorp/go-rootcerts v1.0.2 // indirect
Expand All @@ -150,7 +153,7 @@ require (
github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 // indirect
github.com/mattn/go-colorable v0.1.13 // indirect
github.com/mattn/go-ieproxy v0.0.9 // indirect
github.com/mattn/go-isatty v0.0.17 // indirect
github.com/mattn/go-isatty v0.0.20 // indirect
github.com/mattn/go-runewidth v0.0.14 // indirect
github.com/matttproud/golang_protobuf_extensions v1.0.4 // indirect
github.com/mitchellh/go-homedir v1.1.0 // indirect
Expand All @@ -161,24 +164,32 @@ require (
github.com/prometheus/procfs v0.9.0 // indirect
github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
github.com/rivo/uniseg v0.4.3 // indirect
github.com/rogpeppe/go-internal v1.9.0 // indirect
github.com/rogpeppe/go-internal v1.11.0 // indirect
github.com/russross/blackfriday/v2 v2.1.0 // indirect
github.com/secure-systems-lab/go-securesystemslib v0.4.0 // indirect
github.com/spf13/afero v1.9.3 // indirect
github.com/spf13/cast v1.5.0 // indirect
github.com/spf13/jwalterweatherman v1.1.0 // indirect
github.com/stealthrocket/wazergo v0.19.1 // indirect
github.com/subosito/gotenv v1.4.2 // indirect
github.com/tidwall/match v1.1.1 // indirect
github.com/tidwall/pretty v1.2.0 // indirect
go.opencensus.io v0.24.0 // indirect
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.49.0 // indirect
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.49.0 // indirect
go.opentelemetry.io/otel v1.24.0 // indirect
go.opentelemetry.io/otel/metric v1.24.0 // indirect
go.opentelemetry.io/otel/trace v1.24.0 // indirect
go.uber.org/atomic v1.11.0 // indirect
go.uber.org/multierr v1.11.0 // indirect
go.uber.org/zap v1.24.0 // indirect
go4.org/intern v0.0.0-20220617035311-6925f38cc365 // indirect
go4.org/unsafe/assume-no-moving-gc v0.0.0-20220617031537-928513b29760 // indirect
golang.org/x/exp/typeparams v0.0.0-20230131160201-f062dba9d201 // indirect
golang.org/x/xerrors v0.0.0-20220907171357-04be3eba64a2 // indirect
google.golang.org/appengine v1.6.7 // indirect
golang.org/x/sync v0.7.0 // indirect
golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20240528184218-531527333157 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20240528184218-531527333157 // indirect
gopkg.in/yaml.v2 v2.4.0 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
inet.af/netaddr v0.0.0-20220811202034-502d2d690317 // indirect
Expand All @@ -198,8 +209,9 @@ require (
require (
github.com/BurntSushi/toml v1.3.2
github.com/brianvoe/gofakeit/v6 v6.25.0
github.com/golang/protobuf v1.5.3
github.com/golang/protobuf v1.5.4
github.com/pingcap/failpoint v0.0.0-20220801062533-2eaa32854a6c
github.com/stealthrocket/wasi-go v0.8.0
github.com/tetratelabs/wazero v1.7.1
gopkg.in/ini.v1 v1.67.0
)
)
Loading
Loading