Skip to content

Commit 1660899

Browse files
authored
Merge branch 'master' into 1660-big-topic-message
2 parents 8801638 + 7957a94 commit 1660899

File tree

4 files changed

+13
-2
lines changed

4 files changed

+13
-2
lines changed

CHANGELOG.md

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
* Fixed hangup when try to send batch of messages with size more, then grpc limits from topic writer internals
22

3+
## v3.101.2
4+
* Added a new metric `ydb_go_sdk_ydb_info` with the current version of the SDK
5+
6+
## v3.101.1
7+
* Changed allowBanned=false for preferred node connections
8+
9+
## v3.101.0
10+
* Added `table.Client.ReadRows` method with internal retries
11+
312
## v3.100.3
413
* Fixed bug with concurrent rewrites source slice of `grpc.DialOption` on dial step
514

internal/balancer/connections_state.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ func (s *connectionsState) GetConnection(ctx context.Context) (_ conn.Conn, fail
8989
func (s *connectionsState) preferConnection(ctx context.Context) conn.Conn {
9090
if nodeID, hasPreferEndpoint := endpoint.ContextNodeID(ctx); hasPreferEndpoint {
9191
c := s.connByNodeID[nodeID]
92-
if c != nil && isOkConnection(c, true) {
92+
if c != nil && isOkConnection(c, false) {
9393
return c
9494
}
9595
}

internal/version/version.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package version
33
const (
44
Major = "3"
55
Minor = "101"
6-
Patch = "0"
6+
Patch = "2"
77

88
Package = "ydb-go-sdk"
99
)

metrics/driver.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import (
55
"sync"
66

77
"github.com/ydb-platform/ydb-go-sdk/v3/internal/repeater"
8+
"github.com/ydb-platform/ydb-go-sdk/v3/internal/version"
89
"github.com/ydb-platform/ydb-go-sdk/v3/internal/xerrors"
910
"github.com/ydb-platform/ydb-go-sdk/v3/trace"
1011
)
@@ -13,6 +14,7 @@ import (
1314
//
1415
//nolint:funlen
1516
func driver(config Config) (t trace.Driver) {
17+
config.GaugeVec("info", "version").With(map[string]string{"version": version.Version}).Set(1)
1618
config = config.WithSystem("driver")
1719
endpoints := config.WithSystem("balancer").GaugeVec("endpoints", "az")
1820
balancersDiscoveries := config.WithSystem("balancer").CounterVec("discoveries", "status", "cause")

0 commit comments

Comments
 (0)