Merge pull request #134 from ydb-platform/replace-meta

replace meta in proxyConnection.Invoke and proxyConnection.NewStream

Author: asmyasnikov

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 3.11.5
+* Replaced meta in `proxyConnection.Invoke` and `proxyConnection.NewStream`
+
 ## 3.11.4
 * Refactored `internal/cluster.Cluster` (add option for notify about external lock, lock cluster for update cluster endpoints)
 * Reverted `grpc.ClientConnInterface` API to `ydb.Connection`

internal/meta/version.go

@@ -1,5 +1,5 @@
 package meta
 
 const (
-	Version = "ydb-go-sdk/3.11.4"
+	Version = "ydb-go-sdk/3.11.5"
 )

proxy.go

@@ -35,7 +35,11 @@ func (c *proxyConnection) Invoke(
 	args interface{},
 	reply interface{},
 	opts ...grpc.CallOption,
-) error {
+) (err error) {
+	ctx, err = c.meta.Meta(ctx)
+	if err != nil {
+		return err
+	}
 	return c.connection.Invoke(
 		ctx,
 		method,
@@ -50,7 +54,11 @@ func (c *proxyConnection) NewStream(
 	desc *grpc.StreamDesc,
 	method string,
 	opts ...grpc.CallOption,
-) (grpc.ClientStream, error) {
+) (_ grpc.ClientStream, err error) {
+	ctx, err = c.meta.Meta(ctx)
+	if err != nil {
+		return nil, err
+	}
 	return c.connection.NewStream(
 		ctx,
 		desc,