8a03f8d6b1
build(deps): bump golang.org/x/net in /examples/txnkv ( #1306 )
...
Bumps [golang.org/x/net](https://github.com/golang/net ) from 0.22.0 to 0.23.0.
- [Commits](https://github.com/golang/net/compare/v0.22.0...v0.23.0 )
---
updated-dependencies:
- dependency-name: golang.org/x/net
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2024-04-26 11:41:28 +08:00
6fda9debc2
Change get min ts function name ( #1251 )
2024-03-29 15:29:02 +08:00
87a984a72d
feat: introduce GetLocal() and BatchGet cache for PipelinedMemDB ( #1212 )
...
* feat: introduce GetLocal() for MemBuffer
Signed-off-by: ekexium <eke@fastmail.com>
* downgrade tools to 0.18.0
Signed-off-by: ekexium <eke@fastmail.com>
* fix: set flushingMemDB = nil when an error is returned from a flush
Signed-off-by: ekexium <eke@fastmail.com>
* impl BatchGet for MemBuffer
Signed-off-by: you06 <you1474600@gmail.com>
test membuffer batch get
Signed-off-by: you06 <you1474600@gmail.com>
* add Prefetch & GetPrefetchCache
Signed-off-by: you06 <you1474600@gmail.com>
* cache multi Prefetch call
Signed-off-by: you06 <you1474600@gmail.com>
* add tests
Signed-off-by: you06 <you1474600@gmail.com>
* workaround for golang ci lint failure
Signed-off-by: you06 <you1474600@gmail.com>
* replace assert with require
Signed-off-by: you06 <you1474600@gmail.com>
* workaround golangci lint
Signed-off-by: you06 <you1474600@gmail.com>
* lint
Signed-off-by: you06 <you1474600@gmail.com>
* remove prefetch interface, pipelined memdb will cache batch get result
Signed-off-by: you06 <you1474600@gmail.com>
* update tidb
Signed-off-by: you06 <you1474600@gmail.com>
* fix batch get cache when membuffer is empty
Signed-off-by: you06 <you1474600@gmail.com>
* fix returned delete value
Signed-off-by: you06 <you1474600@gmail.com>
* fix: handle resourceGroupTag of Flush
Signed-off-by: ekexium <eke@fastmail.com>
* fix: set resource group tag for committer if it's pipelined
Signed-off-by: ekexium <eke@fastmail.com>
* Update internal/unionstore/pipelined_memdb.go
Co-authored-by: ekexium <eke@fastmail.com>
* remove prefetch interface
Signed-off-by: you06 <you1474600@gmail.com>
* release mutex
Signed-off-by: you06 <you1474600@gmail.com>
* flush wait to avoid race
Signed-off-by: you06 <you1474600@gmail.com>
* fix unstopped test
Signed-off-by: you06 <you1474600@gmail.com>
* set resource group tags for committer
Signed-off-by: ekexium <eke@fastmail.com>
* skip test due to tikv image not updated yet
Signed-off-by: you06 <you1474600@gmail.com>
* skip more test
Signed-off-by: you06 <you1474600@gmail.com>
---------
Signed-off-by: ekexium <eke@fastmail.com>
Signed-off-by: you06 <you1474600@gmail.com>
Co-authored-by: you06 <you1474600@gmail.com>
2024-03-16 11:36:05 +08:00
88fbc938cd
p-dml: fix unstopped resolve ( #1210 )
...
* fix unstopped resolve when the txn cross regions
Signed-off-by: you06 <you1474600@gmail.com>
* cancel context when flush done or abort
Signed-off-by: you06 <you1474600@gmail.com>
---------
Signed-off-by: you06 <you1474600@gmail.com>
Co-authored-by: ekexium <eke@fastmail.com>
2024-03-11 21:20:38 +08:00
bfab41501b
update pd client to the latest master ( #1195 )
...
Signed-off-by: Ryan Leung <rleungx@gmail.com>
2024-02-29 15:58:03 +08:00
8d28d3cd3a
txn: introduce pipelined memdb, Flush and BufferBatchGet for pipelined DML ( #1114 )
...
* Support pipelined memdb.
Signed-off-by: you06 <you1474600@gmail.com>
* fix mutex for pipelined memdb
Signed-off-by: you06 <you1474600@gmail.com>
---------
Signed-off-by: you06 <you1474600@gmail.com>
2024-02-23 10:24:44 +08:00
8c13f6b5a6
*: upgrade grpc1.62 ( #1168 )
...
Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
2024-02-22 13:15:55 +08:00
4bb62b6db7
upgrade grpc ( #1156 )
...
Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
2024-02-18 11:41:12 +08:00
ea379b071f
Bump google.golang.org/grpc in /examples/txnkv/pessimistic_txn ( #1036 )
...
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go ) from 1.54.0 to 1.56.3.
- [Release notes](https://github.com/grpc/grpc-go/releases )
- [Commits](https://github.com/grpc/grpc-go/compare/v1.54.0...v1.56.3 )
---
updated-dependencies:
- dependency-name: google.golang.org/grpc
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-11-07 20:51:48 +08:00
7c2949f564
Bump google.golang.org/grpc in /examples/txnkv/delete_range ( #1037 )
...
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go ) from 1.54.0 to 1.56.3.
- [Release notes](https://github.com/grpc/grpc-go/releases )
- [Commits](https://github.com/grpc/grpc-go/compare/v1.54.0...v1.56.3 )
---
updated-dependencies:
- dependency-name: google.golang.org/grpc
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-11-07 20:38:09 +08:00
217b915749
Bump google.golang.org/grpc in /examples/txnkv/async_commit ( #1039 )
...
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go ) from 1.54.0 to 1.56.3.
- [Release notes](https://github.com/grpc/grpc-go/releases )
- [Commits](https://github.com/grpc/grpc-go/compare/v1.54.0...v1.56.3 )
---
updated-dependencies:
- dependency-name: google.golang.org/grpc
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-11-07 20:28:18 +08:00
a418afd74b
Bump google.golang.org/grpc in /examples/txnkv/unsafedestoryrange ( #1041 )
...
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go ) from 1.54.0 to 1.56.3.
- [Release notes](https://github.com/grpc/grpc-go/releases )
- [Commits](https://github.com/grpc/grpc-go/compare/v1.54.0...v1.56.3 )
---
updated-dependencies:
- dependency-name: google.golang.org/grpc
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-11-07 20:18:57 +08:00
f990d49236
Bump google.golang.org/grpc in /examples/txnkv/1pc_txn ( #1042 )
...
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go ) from 1.54.0 to 1.56.3.
- [Release notes](https://github.com/grpc/grpc-go/releases )
- [Commits](https://github.com/grpc/grpc-go/compare/v1.54.0...v1.56.3 )
---
updated-dependencies:
- dependency-name: google.golang.org/grpc
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-11-07 20:10:10 +08:00
3520f13fc0
*: upgrade grpc and etcd ( #1044 )
...
Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
2023-10-30 10:15:33 +08:00
d1f15f96e3
Bump golang.org/x/net in /examples/txnkv/pessimistic_txn ( #1013 )
...
Bumps [golang.org/x/net](https://github.com/golang/net ) from 0.10.0 to 0.17.0.
- [Commits](https://github.com/golang/net/compare/v0.10.0...v0.17.0 )
---
updated-dependencies:
- dependency-name: golang.org/x/net
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-10-20 14:54:07 +08:00
49734c3a07
Bump golang.org/x/net from 0.10.0 to 0.17.0 in /examples/txnkv ( #1012 )
...
Bumps [golang.org/x/net](https://github.com/golang/net ) from 0.10.0 to 0.17.0.
- [Commits](https://github.com/golang/net/compare/v0.10.0...v0.17.0 )
---
updated-dependencies:
- dependency-name: golang.org/x/net
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-10-20 12:36:46 +08:00
671033c8ad
Bump golang.org/x/net from 0.10.0 to 0.17.0 in /examples/txnkv/1pc_txn ( #1010 )
...
Bumps [golang.org/x/net](https://github.com/golang/net ) from 0.10.0 to 0.17.0.
- [Commits](https://github.com/golang/net/compare/v0.10.0...v0.17.0 )
---
updated-dependencies:
- dependency-name: golang.org/x/net
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-10-20 12:22:47 +08:00
b1611f764e
Bump golang.org/x/net in /examples/txnkv/delete_range ( #1008 )
...
Bumps [golang.org/x/net](https://github.com/golang/net ) from 0.10.0 to 0.17.0.
- [Commits](https://github.com/golang/net/compare/v0.10.0...v0.17.0 )
---
updated-dependencies:
- dependency-name: golang.org/x/net
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-10-20 12:15:03 +08:00
e4dcb91843
Bump golang.org/x/net in /examples/txnkv/unsafedestoryrange ( #1009 )
...
Bumps [golang.org/x/net](https://github.com/golang/net ) from 0.10.0 to 0.17.0.
- [Commits](https://github.com/golang/net/compare/v0.10.0...v0.17.0 )
---
updated-dependencies:
- dependency-name: golang.org/x/net
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-10-18 16:24:31 +08:00
7172eb5f00
Bump golang.org/x/net in /examples/txnkv/async_commit ( #1006 )
...
Bumps [golang.org/x/net](https://github.com/golang/net ) from 0.10.0 to 0.17.0.
- [Commits](https://github.com/golang/net/compare/v0.10.0...v0.17.0 )
---
updated-dependencies:
- dependency-name: golang.org/x/net
dependency-type: indirect
...
Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: disksing <i@disksing.com>
2023-10-18 15:19:58 +08:00
b535011f12
update fo mod ( #995 )
...
Signed-off-by: husharp <jinhao.hu@pingcap.com>
Co-authored-by: disksing <i@disksing.com>
2023-10-07 11:37:03 +08:00
df58452fe1
client_batch: add test for auto re-connect idle connection when wait connection ready and fix ci ( #835 )
...
* client_batch: add test
Signed-off-by: crazycs520 <crazycs520@gmail.com>
* fix ci
Signed-off-by: crazycs520 <crazycs520@gmail.com>
* fix ci
Signed-off-by: crazycs520 <crazycs520@gmail.com>
* fix ci
Signed-off-by: crazycs520 <crazycs520@gmail.com>
* update go version
Signed-off-by: crazycs520 <crazycs520@gmail.com>
* fix ci
Signed-off-by: crazycs520 <crazycs520@gmail.com>
* fix ci lint
Signed-off-by: crazycs520 <crazycs520@gmail.com>
* fix ci lint
Signed-off-by: crazycs520 <crazycs520@gmail.com>
---------
Signed-off-by: crazycs520 <crazycs520@gmail.com>
2023-06-13 14:17:17 +08:00
8fd09cd88c
config support both path and names ( #683 )
...
Signed-off-by: HuSharp <jinhao.hu@pingcap.com>
2023-02-02 18:11:45 +08:00
86d51ba7eb
*: update google/btree to improve performance ( #547 )
...
* *: update google/btree to improve performance
Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
* update ci
Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
2022-07-18 16:02:14 +08:00
947d923945
fix:move tikv.NewTxnClient to txnk.NewClient ( #534 )
...
Signed-off-by: 583373805 <583373805@qq.com>
2022-06-27 14:35:00 +08:00
87c1c58064
move tikv.NewTxnClient to txnkv.NewClient ( #391 )
...
Signed-off-by: disksing <i@disksing.com>
2021-12-09 21:38:38 -08:00
b0d9bb8821
Bump go version to 1.16 ( #379 )
...
* Revert "use ioutil.ReadFile to release dependency of Go 1.16 (#217 )"
This reverts commit aadf3cf627
2021-11-18 06:06:13 -08:00
288c649636
fix license ( #267 )
...
Signed-off-by: disksing <i@disksing.com>
2021-08-15 01:48:01 +08:00
d535b62b62
txnkv/transaction: init package ( #260 )
...
Signed-off-by: shirly <AndreMouche@126.com>
Co-authored-by: disksing <i@disksing.com>
2021-07-31 16:26:22 +08:00
ac355144c8
tikv/txn: add new pub function LockKeysWithWaitTime ( #230 )
...
* tikv/txn: add new pub function LockKeysWithWaitTime
Signed-off-by: shirly <AndreMouche@126.com>
* address comments
Signed-off-by: shirly <AndreMouche@126.com>
* tikv/pessimistic: update the constant for lock wait time
Signed-off-by: shirly <AndreMouche@126.com>
* kv/LockCtx: make lockWaitTime private
Signed-off-by: shirly <AndreMouche@126.com>
* address comments
Signed-off-by: shirly <AndreMouche@126.com>
2021-07-23 10:31:23 +08:00
807f0cd7e0
tikv/gc: init UnsafeDestoryRange ( #236 )
...
Signed-off-by: shirly <AndreMouche@126.com>
2021-07-16 09:55:00 +00:00
0539869024
txnkv/*: init txnkv/rangetask package ( #234 )
2021-07-15 10:16:15 +08:00
9a71d1d8e3
examples/txnkv: add example for delete_range ( #232 )
2021-07-14 06:32:15 +00:00
d8c7ea50ab
examples/*: rm go.sum ( #231 )
...
Signed-off-by: shirly <AndreMouche@126.com>
2021-07-13 07:17:17 +00:00
5ef645fed2
example/txnkv: add example for async_commit ( #229 )
...
Signed-off-by: shirly <AndreMouche@126.com>
2021-07-12 10:34:19 +00:00
37bd240cdb
example/txnkv: add example for 1pc ( #224 )
...
Signed-off-by: shirly <AndreMouche@126.com>
2021-07-12 12:03:01 +08:00
2e1ad23d9e
examples/txnkv: add example for pessimistic txn ( #219 )
...
Signed-off-by: shirly <AndreMouche@126.com>
2021-07-12 03:51:17 +00:00
aadf3cf627
use ioutil.ReadFile to release dependency of Go 1.16 ( #217 )
...
Signed-off-by: Sandy Xu <sandy@juicedata.io>
2021-07-09 05:25:06 +00:00
a31f4324c7
examples/txnkv: add example for txnkv ( #107 )
...
Signed-off-by: shirly <AndreMouche@126.com>
2021-06-22 10:49:00 +08:00
2f09a0b49d
create v2 branch
...
Signed-off-by: disksing <i@disksing.com>
2021-06-10 19:44:46 +08:00
77a15fcd87
Use context everywhere ( #23 )
...
* rawkv
Signed-off-by: disksing <i@disksing.com>
* txnkv wip
Signed-off-by: disksing <i@disksing.com>
* txnkv wip
Signed-off-by: disksing <i@disksing.com>
* txnkv update get & batchGet
Signed-off-by: disksing <i@disksing.com>
* txnkv iterators
Signed-off-by: disksing <i@disksing.com>
2019-06-20 01:18:29 +08:00
940d55927c
config: cleanup and pass config as parameter ( #14 )
...
* config: cleanup and pass config as parameter
Signed-off-by: disksing <i@disksing.com>
* fix review comments
Signed-off-by: disksing <i@disksing.com>
* fix conflicts
Signed-off-by: disksing <i@disksing.com>
* address comment
Signed-off-by: disksing <i@disksing.com>
2019-04-19 17:01:34 +08:00
2130e26d4f
add code lint ( #10 )
...
* add code lint
Signed-off-by: disksing <i@disksing.com>
2019-03-27 11:41:47 +08:00
970883c423
Replace pingap/errors with pkg/errors ( #8 )
...
* replace pingcap/errors with pkg/errors
Signed-off-by: disksing <i@disksing.com>
* get compiled
Signed-off-by: disksing <i@disksing.com>
* update meta.go
Signed-off-by: disksing <i@disksing.com>
* update txnkv.go
Signed-off-by: disksing <i@disksing.com>
* update codec.go
Signed-off-by: disksing <i@disksing.com>
* update region_cache.go
Signed-off-by: disksing <i@disksing.com>
* update mock.go
Signed-off-by: disksing <i@disksing.com>
* update txn_committer.go
Signed-off-by: disksing <i@disksing.com>
* update mvcc_leveldb.go
Signed-off-by: disksing <i@disksing.com>
* update rawkv.go
Signed-off-by: disksing <i@disksing.com>
* update snapshot.go
Signed-off-by: disksing <i@disksing.com>
* update lock_resolver.go
Signed-off-by: disksing <i@disksing.com>
* update scan.go
Signed-off-by: disksing <i@disksing.com>
* update region_request.go
Signed-off-by: disksing <i@disksing.com>
* update mvcc.go
Signed-off-by: disksing <i@disksing.com>
* update rpc.go, backoff.go client.go
Signed-off-by: disksing <i@disksing.com>
* update kv/*.go
Signed-off-by: disksing <i@disksing.com>
* update txn.go, pd.go
Signed-off-by: disksing <i@disksing.com>
* update txn/store/*
Signed-off-by: disksing <i@disksing.com>
* go mod tidy
Signed-off-by: disksing <i@disksing.com>
2019-03-21 11:01:52 +08:00
a9347f9bec
add txnkv support and examples ( #6 )
...
* add txnkv support
Signed-off-by: disksing <i@disksing.com>
* add examples
Signed-off-by: disksing <i@disksing.com>
2019-03-18 19:47:54 +08:00
dependabot[bot]