-
Notifications
You must be signed in to change notification settings - Fork 97
Open
Labels
easyenhancementNew feature or requestNew feature or requesttopicissue for topic serviceissue for topic service
Description
Write messages offsets, which sent to server in commit request
Lines 156 to 185 in c362289
t.OnReaderSendCommitMessage = func( | |
info trace.TopicReaderSendCommitMessageStartInfo, | |
) func(trace.TopicReaderSendCommitMessageDoneInfo) { | |
if d.Details()&trace.TopicReaderStreamEvents == 0 { | |
return nil | |
} | |
ctx := with(context.Background(), TRACE, "ydb", "topic", "reader", "send", "commit", "message") | |
start := time.Now() | |
l.Log(ctx, "start", | |
Any("partitions_id", info.CommitsInfo.PartitionIDs()), | |
Any("partitions_session_id", info.CommitsInfo.PartitionSessionIDs()), | |
) | |
return func(doneInfo trace.TopicReaderSendCommitMessageDoneInfo) { | |
fields := []Field{ | |
Any("partitions_id", info.CommitsInfo.PartitionIDs()), | |
Any("partitions_session_id", info.CommitsInfo.PartitionSessionIDs()), | |
latencyField(start), | |
} | |
if doneInfo.Error == nil { | |
l.Log(ctx, "done", fields...) | |
} else { | |
l.Log(WithLevel(ctx, WARN), "commit message sent", | |
append(fields, | |
Error(doneInfo.Error), | |
versionField(), | |
)..., | |
) | |
} | |
} | |
} |
Metadata
Metadata
Assignees
Labels
easyenhancementNew feature or requestNew feature or requesttopicissue for topic serviceissue for topic service