* Added trace.DriverConnStreamEvents details bit

Author: asmyasnikov

CHANGELOG.md

@@ -1,3 +1,5 @@
+* Added `trace.DriverConnStreamEvents` details bit
+
 ## v3.66.1
 * Added flush messages from buffer before close topic writer
 * Added Flush method for topic writer

log/driver.go

@@ -216,7 +216,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver { //nolint:gocyclo
 		) func(
 			trace.DriverConnNewStreamDoneInfo,
 		) {
-			if d.Details()&trace.DriverConnEvents == 0 {
+			if d.Details()&trace.DriverConnStreamEvents == 0 {
 				return nil
 			}
 			ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "New")
@@ -249,7 +249,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver { //nolint:gocyclo
 		OnConnStreamCloseSend: func(info trace.DriverConnStreamCloseSendStartInfo) func(
 			trace.DriverConnStreamCloseSendDoneInfo,
 		) {
-			if d.Details()&trace.DriverConnEvents == 0 {
+			if d.Details()&trace.DriverConnStreamEvents == 0 {
 				return nil
 			}
 			ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "CloseSend")
@@ -271,7 +271,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver { //nolint:gocyclo
 			}
 		},
 		OnConnStreamSendMsg: func(info trace.DriverConnStreamSendMsgStartInfo) func(trace.DriverConnStreamSendMsgDoneInfo) {
-			if d.Details()&trace.DriverConnEvents == 0 {
+			if d.Details()&trace.DriverConnStreamEvents == 0 {
 				return nil
 			}
 			ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "SendMsg")
@@ -293,7 +293,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver { //nolint:gocyclo
 			}
 		},
 		OnConnStreamRecvMsg: func(info trace.DriverConnStreamRecvMsgStartInfo) func(trace.DriverConnStreamRecvMsgDoneInfo) {
-			if d.Details()&trace.DriverConnEvents == 0 {
+			if d.Details()&trace.DriverConnStreamEvents == 0 {
 				return nil
 			}
 			ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "RecvMsg")

metrics/driver.go

@@ -55,7 +55,7 @@ func driver(config Config) (t trace.Driver) {
 		)
 
 		return func(info trace.DriverConnNewStreamDoneInfo) {
-			if config.Details()&trace.DriverConnEvents != 0 {
+			if config.Details()&trace.DriverConnStreamEvents != 0 {
 				requests.With(map[string]string{
 					"status":   errorBrief(info.Error),
 					"method":   string(method),

trace/details.go

@@ -31,6 +31,7 @@ func (d Details) String() string {
 const (
 	DriverNetEvents Details = 1 << iota // for bitmask: 1, 2, 4, 8, 16, 32, ...
 	DriverConnEvents
+	DriverConnStreamEvents
 	DriverBalancerEvents
 	DriverResolverEvents
 	DriverRepeaterEvents
@@ -79,6 +80,7 @@ const (
 	CoordinationEvents
 
 	DriverEvents = DriverConnEvents |
+		DriverConnStreamEvents |
 		DriverBalancerEvents |
 		DriverResolverEvents |
 		DriverRepeaterEvents |
@@ -128,6 +130,7 @@ var (
 		DriverResolverEvents:    "ydb.driver.resolver",
 		DriverRepeaterEvents:    "ydb.driver.repeater",
 		DriverConnEvents:        "ydb.driver.conn",
+		DriverConnStreamEvents:  "ydb.driver.conn.stream",
 		DriverCredentialsEvents: "ydb.driver.credentials",
 
 		DiscoveryEvents: "ydb.discovery",