client-go/util
ekexium 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
..
codec region_request: handle resource group error before Backoff (#719) 2023-03-02 13:40:57 +08:00
israce replica selector refactor (#1142) 2024-03-11 15:40:44 +08:00
dns.go add util to set dns server (#927) 2023-09-18 15:19:39 +08:00
execdetails.go txn: introduce pipelined memdb, Flush and BufferBatchGet for pipelined DML (#1114) 2024-02-23 10:24:44 +08:00
failpoint.go fix license (#267) 2021-08-15 01:48:01 +08:00
main_test.go fix license (#267) 2021-08-15 01:48:01 +08:00
misc.go feat: introduce GetLocal() and BatchGet cache for PipelinedMemDB (#1212) 2024-03-16 11:36:05 +08:00
misc_test.go util: update GCTimeFormat to be the same as the value stored in PD (#616) 2022-11-08 11:08:01 +08:00
pd_interceptor.go pd client: uprade and fit get region option (#1069) 2023-12-01 10:44:04 +08:00
rate_limit.go fix license (#267) 2021-08-15 01:48:01 +08:00
rate_limit_test.go fix license (#267) 2021-08-15 01:48:01 +08:00
request_source.go resource_control: add stats task (#985) 2023-09-21 19:32:00 +08:00
request_source_test.go request_source: remove default label (#890) 2023-08-08 09:38:22 -07:00
ts_set.go fix license (#267) 2021-08-15 01:48:01 +08:00