tikv
/
client-go
mirror of https://github.com/tikv/client-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix:move tikv.NewTxnClient to txnk.NewClient (#534) 

Signed-off-by: 583373805 <583373805@qq.com>
This commit is contained in:
orion 2022-06-27 14:35:00 +08:00 committed by GitHub
parent bb026bdad8
commit 947d923945
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
examples/gcworker/gcworker.go
View File

@ -21,7 +21,7 @@ import (
"time"
"github.com/tikv/client-go/v2/oracle"
"github.com/tikv/client-go/v2/tikv"
"github.com/tikv/client-go/v2/txnkv"
)
var (
@ -31,7 +31,7 @@ var (
func main() {
flag.Parse()
client, err := tikv.NewTxnClient([]string{*pdAddr})
client, err := txnkv.NewClient([]string{*pdAddr})
if err != nil {
panic(err)
}

6
examples/txnkv/1pc_txn/1pc_txn.go
View File

@ -20,18 +20,18 @@ import (
"fmt"
"os"
"github.com/tikv/client-go/v2/tikv"
"github.com/tikv/client-go/v2/txnkv"
)
var (
client *tikv.KVStore
client *txnkv.Client
pdAddr = flag.String("pd", "127.0.0.1:2379", "pd address")
)
// Init initializes information.
func initStore() {
var err error
client, err = tikv.NewTxnClient([]string{*pdAddr})
client, err = txnkv.NewClient([]string{*pdAddr})
if err != nil {
panic(err)
}

6
examples/txnkv/async_commit/async_commit.go
View File

@ -20,19 +20,19 @@ import (
"fmt"
"os"
"github.com/tikv/client-go/v2/tikv"
"github.com/tikv/client-go/v2/txnkv"
"github.com/tikv/client-go/v2/util"
)
var (
client *tikv.KVStore
client *txnkv.Client
pdAddr = flag.String("pd", "127.0.0.1:2379", "pd address")
)
// Init initializes information.
func initStore() {
var err error
client, err = tikv.NewTxnClient([]string{*pdAddr})
client, err = txnkv.NewClient([]string{*pdAddr})
if err != nil {
panic(err)
}

6
examples/txnkv/delete_range/delete_range.go
View File

@ -22,18 +22,18 @@ import (
"math/rand"
"os"
"github.com/tikv/client-go/v2/tikv"
"github.com/tikv/client-go/v2/txnkv"
)
var (
client *tikv.KVStore
client *txnkv.Client
pdAddr = flag.String("pd", "127.0.0.1:2379", "pd address")
)
// Init initializes information.
func initStore() {
var err error
client, err = tikv.NewTxnClient([]string{*pdAddr})
client, err = txnkv.NewClient([]string{*pdAddr})
panicWhenErrNotNil(err)
}

5
examples/txnkv/pessimistic_txn/pessimistic_txn.go
View File

@ -21,7 +21,6 @@ import (
"os"
"github.com/tikv/client-go/v2/kv"
"github.com/tikv/client-go/v2/tikv"
"github.com/tikv/client-go/v2/txnkv"
)
@ -35,14 +34,14 @@ func (kv KV) String() string {
}
var (
client *tikv.KVStore
client *txnkv.Client
pdAddr = flag.String("pd", "127.0.0.1:2379", "pd address")
)
// Init initializes information.
func initStore() {
var err error
client, err = tikv.NewTxnClient([]string{*pdAddr})
client, err = txnkv.NewClient([]string{*pdAddr})
if err != nil {
panic(err)
}

6
examples/txnkv/unsafedestoryrange/unsafedestoryrange.go
View File

@ -22,18 +22,18 @@ import (
"math/rand"
"os"
"github.com/tikv/client-go/v2/tikv"
"github.com/tikv/client-go/v2/txnkv"
)
var (
client *tikv.KVStore
client *txnkv.Client
pdAddr = flag.String("pd", "127.0.0.1:2379", "pd address")
)
// Init initializes information.
func initStore() {
var err error
client, err = tikv.NewTxnClient([]string{*pdAddr})
client, err = txnkv.NewClient([]string{*pdAddr})
panicWhenErrNotNil(err)
}