835
836
// UpdateRemoteReaderInfo mocks base method.
837
>
func (m *MockShardContext) UpdateRemoteReaderInfo(readerID, ackTaskID int64, ackTimestamp time.Time) error {
shard_context_mock.go
838
>
m.ctrl.T.Helper()
839
>
ret := m.ctrl.Call(m, "UpdateRemoteReaderInfo", readerID, ackTaskID, ackTimestamp)
840
>
ret0, _ := ret[0].(error)
841
>
return ret0
842
>
}
843
844
// UpdateRemoteReaderInfo indicates an expected call of UpdateRemoteReaderInfo.
845
>
func (mr *MockShardContextMockRecorder) UpdateRemoteReaderInfo(readerID, ackTaskID, ackTimestamp any) *gomock.Call {
shard_context_mock.go
846
>
mr.mock.ctrl.T.Helper()
847
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateRemoteReaderInfo", reflect.TypeOf((*MockShardContext)(nil).UpdateRemoteReaderInfo), readerID, ackTaskID, ackTimestamp)
848
>
}
849
850
// UpdateReplicationQueueReaderState mocks base method.