Skip to content

Commit 7531a92

Browse files
committed
driver: implement tkv driver for tarantool support
- New TKV driver package (driver/tkv). - Integration testing for TKV, that expects TARANTOOL_ADDR env variable - Updated .golangci.yml to fix needed packages. - Modified core driver interfaces to be compatible with tkv. - Update go module dependencies. Also TCS is now TKV, won't be confused with 'column storage'. Closes #TNTP-4188
1 parent 6961faf commit 7531a92

File tree

14 files changed

+1179
-152
lines changed

14 files changed

+1179
-152
lines changed

.golangci.yml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,10 +50,12 @@ linters:
5050
- "go.etcd.io/etcd/client/v3"
5151
- "github.com/tarantool/go-tarantool/v2"
5252
- "github.com/tarantool/go-option"
53+
- "github.com/vmihailenco/msgpack/v5"
5354
test:
5455
files:
5556
- "$test"
5657
allow:
5758
- $gostd
5859
- "github.com/tarantool/go-storage"
5960
- "github.com/stretchr/testify"
61+
- "github.com/tarantool/go-tarantool/v2"

driver/driver.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,5 +26,5 @@ type Driver interface {
2626

2727
// Watch establishes a watch stream for changes to a specific key or prefix.
2828
// The returned channel will receive events as changes occur.
29-
Watch(ctx context.Context, key []byte, opts ...watch.Option) <-chan watch.Event
29+
Watch(ctx context.Context, key []byte, opts ...watch.Option) (<-chan watch.Event, func(), error)
3030
}

driver/etcd/etcd.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,6 @@ func (d Driver) Execute(
6969

7070
// Watch monitors changes to a specific key and returns a stream of events.
7171
// It supports optional watch configuration through the opts parameter.
72-
func (d Driver) Watch(_ context.Context, _ []byte, _ ...watch.Option) <-chan watch.Event {
72+
func (d Driver) Watch(_ context.Context, _ []byte, _ ...watch.Option) (<-chan watch.Event, func(), error) {
7373
panic("implement me")
7474
}

driver/tcs/tcs.go

Lines changed: 0 additions & 84 deletions
This file was deleted.

0 commit comments

Comments
 (0)