driver: implement tkv driver for tarantool support

.golangci.yml

@@ -50,10 +50,12 @@ linters:
             - "go.etcd.io/etcd/client/v3"
             - "github.com/tarantool/go-tarantool/v2"
             - "github.com/tarantool/go-option"
+            - "github.com/vmihailenco/msgpack/v5"
         test:
           files:
             - "$test"
           allow:
             - $gostd
             - "github.com/tarantool/go-storage"
             - "github.com/stretchr/testify"
+            - "github.com/tarantool/go-tarantool/v2"

driver/driver.go

@@ -26,5 +26,7 @@ type Driver interface {
 
 	// Watch establishes a watch stream for changes to a specific key or prefix.
 	// The returned channel will receive events as changes occur.
-	Watch(ctx context.Context, key []byte, opts ...watch.Option) <-chan watch.Event
+	// The returned cleanup function should be called to stop the watch and release resources.
+	// An error is returned if the watch could not be established.
+	Watch(ctx context.Context, key []byte, opts ...watch.Option) (<-chan watch.Event, func(), error)
 }

driver/etcd/etcd.go

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