Merge pull request #327 from ydb-platform/topic-adapters

fix topic events mask name

Author: asmyasnikov

trace/details.go

@@ -69,11 +69,11 @@ const (
 		TableSessionQueryEvents |
 		TableSessionTransactionEvents
 
-	TopicReaderAllEvents = TopicReaderStreamEvents | TopicReaderMessageEvents |
+	TopicReaderEvents = TopicReaderStreamEvents | TopicReaderMessageEvents |
 		TopicReaderPartitionEvents |
 		TopicReaderStreamLifeCycleEvents
 
-	TopicAllEvents = TopicControlPlaneEvents | TopicReaderAllEvents
+	TopicEvents = TopicControlPlaneEvents | TopicReaderEvents
 
 	DetailsAll = ^Details(0) // All bits enabled
 )
@@ -109,9 +109,9 @@ var (
 		TablePoolSessionLifeCycleEvents: "ydb.table.pool.session",
 		TablePoolAPIEvents:              "ydb.table.pool.api",
 
-		TopicAllEvents:                   "ydb.topic",
+		TopicEvents:                      "ydb.topic",
 		TopicControlPlaneEvents:          "ydb.topic.controlplane",
-		TopicReaderAllEvents:             "ydb.topic.reader",
+		TopicReaderEvents:                "ydb.topic.reader",
 		TopicReaderStreamEvents:          "ydb.topic.reader.stream",
 		TopicReaderMessageEvents:         "ydb.topic.reader.message",
 		TopicReaderPartitionEvents:       "ydb.topic.reader.partition",

trace/topic.go

@@ -17,12 +17,15 @@ type (
 	// Notice: This API is EXPERIMENTAL and may be changed or removed in a
 	// later release.
 	Topic struct {
+		// TopicReaderStreamLifeCycleEvents
 		OnReaderReconnect        func(startInfo TopicReaderReconnectStartInfo) func(doneInfo TopicReaderReconnectDoneInfo)
 		OnReaderReconnectRequest func(info TopicReaderReconnectRequestInfo)
 
+		// TopicReaderPartitionEvents
 		OnReaderPartitionReadStartResponse func(startInfo TopicReaderPartitionReadStartResponseStartInfo) func(doneInfo TopicReaderPartitionReadStartResponseDoneInfo)
 		OnReaderPartitionReadStopResponse  func(startInfo TopicReaderPartitionReadStopResponseStartInfo) func(doneInfo TopicReaderPartitionReadStopResponseDoneInfo)
 
+		// TopicReaderStreamEvents
 		OnReaderCommit            func(startInfo TopicReaderCommitStartInfo) func(doneInfo TopicReaderCommitDoneInfo)
 		OnReaderSendCommitMessage func(startInfo TopicReaderSendCommitMessageStartInfo) func(doneInfo TopicReaderSendCommitMessageDoneInfo)
 		OnReaderCommittedNotify   func(info TopicReaderCommittedNotifyInfo)
@@ -31,6 +34,7 @@ type (
 		OnReaderError             func(info TopicReaderErrorInfo)
 		OnReaderUpdateToken       func(startInfo OnReadUpdateTokenStartInfo) func(updateTokenInfo OnReadUpdateTokenMiddleTokenReceivedInfo) func(doneInfo OnReadStreamUpdateTokenDoneInfo)
 
+		// TopicReaderMessageEvents
 		OnReaderSentDataRequest     func(startInfo TopicReaderSentDataRequestInfo)
 		OnReaderReceiveDataResponse func(startInfo TopicReaderReceiveDataResponseStartInfo) func(doneInfo TopicReaderReceiveDataResponseDoneInfo)
 		OnReaderReadMessages        func(startInfo TopicReaderReadMessagesStartInfo) func(doneInfo TopicReaderReadMessagesDoneInfo)