Skip to content

Commit d195b8f

Browse files
committed
rangefeed: rename nextPerQueueStateLocked to nextPerStreamStateLocked
Epic: none Release note: None
1 parent 456d0b3 commit d195b8f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

pkg/kv/kvserver/rangefeed/buffered_sender.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -182,7 +182,7 @@ func (bs *BufferedSender) sendBuffered(
182182
if !ok {
183183
return errNoSuchStream
184184
}
185-
nextState, err := bs.nextPerQueueStateLocked(status, ev)
185+
nextState, err := bs.nextPerStreamStateLocked(status, ev)
186186
if nextState == streamErrored {
187187
// We will be admitting this event but no events after this.
188188
assertTrue(err == nil, "expected error event to be admitted")
@@ -209,11 +209,11 @@ func (bs *BufferedSender) sendBuffered(
209209
return nil
210210
}
211211

212-
// nextPerQueueStateLocked returns the next state that should be stored for the
212+
// nextPerStreamStateLocked returns the next state that should be stored for the
213213
// stream related to the given rangefeed event. If an error is returned, the
214214
// event should not be admitted and the given error should be returned to the
215215
// client.
216-
func (bs *BufferedSender) nextPerQueueStateLocked(
216+
func (bs *BufferedSender) nextPerStreamStateLocked(
217217
status streamStatus, ev *kvpb.MuxRangeFeedEvent,
218218
) (streamState, error) {
219219
// An error should always put us into stateErrored, so let's do that first.

0 commit comments

Comments
 (0)