Skip to content

Commit

Permalink
fixes with linters
Browse files Browse the repository at this point in the history
  • Loading branch information
rekby committed Sep 25, 2024
1 parent 98f75f0 commit 198cf9f
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion topic/topicwriter/topicwriter.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,10 @@ func NewWriter(writer *topicwriterinternal.WriterReconnector) *Writer {
// especially when connection has problems.
//
// It returns ErrQueueLimitExceed (must be checked by errors.Is)
// if ctx cancelled before messages put to internal buffer or try to add more messages, that can be put to queue
// if ctx cancelled before messages put to internal buffer or try to add more messages, that can be put to queue.
//
// Write will return error, inherited from ErrQueueLimitExceed if write cancelled by context and will be NOT
// written to internal buffer. The error guarantee that the messages WILL NOT send to the server.
func (w *Writer) Write(ctx context.Context, messages ...Message) error {
return w.inner.Write(ctx, messages)
}
Expand Down

0 comments on commit 198cf9f

Please sign in to comment.