change confirm, change session info

Author: rekby

examples/topic/topicreader/topicreader_handler.go

@@ -76,8 +76,8 @@ func (h *TopicEventsHandler) OnStopPartitionSessionRequest(
 	event topiclistener.StopPartitionSessionRequest,
 ) error {
 	h.m.Lock()
-	lockID := h.locks[event.PartitionSessionID]
-	delete(h.locks, event.PartitionSessionID)
+	lockID := h.locks[event.PartitionSession.PartitionSessionID]
+	delete(h.locks, event.PartitionSession.PartitionSessionID)
 	h.m.Unlock()
 
 	err := unlockPartition(ctx, lockID)

internal/topic/topiclistenerinternal/event_handler.go

@@ -71,15 +71,15 @@ func (e *PublicStartPartitionSessionEvent) Confirm(opts ...PublicStartPartitionS
 //
 // Experimental: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#experimental
 type PublicStartPartitionSessionConfirm struct {
-	ReadOffset   *int64
+	readOffset   *int64
 	CommitOffset *int64 ``
 }
 
 // WithReadOffet
 //
 // Experimental: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#experimental
 func (c PublicStartPartitionSessionConfirm) WithReadOffet(val int64) PublicStartPartitionSessionConfirm {
-	c.ReadOffset = &val
+	c.readOffset = &val
 	return c
 }
 

internal/topic/topiclistenerinternal/stream_listener.go

@@ -264,8 +264,8 @@ func (l *streamListener) onStartPartitionRequest(ctx context.Context, m *rawtopi
 		// pass
 	}
 
-	if userResp.ReadOffset != nil {
-		resp.ReadOffset.Offset = rawtopicreader.NewOffset(*userResp.ReadOffset)
+	if userResp.readOffset != nil {
+		resp.ReadOffset.Offset = rawtopicreader.NewOffset(*userResp.readOffset)
 		resp.ReadOffset.HasValue = true
 	}
 	if userResp.CommitOffset != nil {