正在查询正在增长的数据集

我们有一个在应用程序处理数据集时增长的数据集。经过长时间的讨论，我们决定现在不需要阻塞或异步API，我们将定期查询我们的数据存储。

我们考虑了两个选项来设计一个API来查询我们的存储：

1. 查询方法返回数据的快照和指示天气的标志，我们可能有更多的数据。当我们完成对最后一个返回的快照的迭代时，我们再次查询以获得其余数据的另一个快照
2. 查询方法在数据上返回一个"活动"迭代器，当迭代器前进时，它返回以下选项之一：data is available，No more data，May have more data

我们使用C++，我们借用了.NET样式的枚举器API，原因超出了这个问题的范围。下面是一些代码来演示这两个选项。你更喜欢哪个选项？

/* ======== FIRST OPTION ============== */
// similar to the familier .NET enumerator.
class IFooEnumerator
{
    // true --> A data element may be accessed using the Current() method
    // false --> End of sequence. Calling Current() is an invalid operation.
    virtual bool MoveNext() = 0;
    virtual Foo Current() const = 0;
    virtual ~IFooEnumerator() {}
};
enum class Availability
{
    EndOfData,
    MightHaveMoreData,
};
class IDataProvider
{
    // Query params allow specifying the ID of the starting element. Here is the intended usage pattern:
    //  1. Call GetFoo() without specifying a starting point. 
    //  2. Process all elements returned by IFooEnumerator until it ends.
    //  3. Check the availability. 
    //     3.1 MightHaveMoreDataLater --> Invoke GetFoo() again after some time by specifying the last processed element as the starting point
    //                                    and repeat steps (2) and (3)   
    //     3.2 EndOfData --> The data set will not grow any more and we know that we have finished processing.
    virtual std::tuple<std::unique_ptr<IFooEnumerator>, Availability> GetFoo(query-params) = 0;
};

/* ====== SECOND OPTION ====== */
enum class Availability
{
    HasData,
    MightHaveMoreData,
    EndOfData,
};

class IGrowingFooEnumerator
{
    // HasData:
    //      We might access the current data element by invoking Current()
    // EndOfData:
    //      The data set has finished growing and no more data elements will arrive later
    // MightHaveMoreData:
    //      The data set will grow and we need to continue calling MoveNext() periodically (preferably after a short delay)
    //      until we get a "HasData" or "EndOfData" result.
    virtual Availability MoveNext() = 0;
    virtual Foo Current() const = 0;
    virtual ~IFooEnumerator() {}
};
class IDataProvider
{
    std::unique_ptr<IGrowingFooEnumerator> GetFoo(query-params) = 0;
};

更新

鉴于目前的答案，我有一些澄清。争论主要集中在接口上——它在表示不断增长的数据集的查询时的表现力和直观性，而这些数据集在某个时间点将停止增长。由于以下属性，在没有竞争条件的情况下（至少我们相信是这样）实现这两个接口是可能的：

1. 如果迭代器+标志对表示查询时系统的快照，则可以正确实现第一个选项。获取快照语义不是问题，因为我们使用数据库事务
2. 第二个选项可以在正确执行第一个选项的情况下执行。第二个选项的"MoveNext（）"将在内部使用类似于第一个选项的东西，并在需要时重新发出查询
3. 数据集可以从"可能有更多数据"更改为"数据结束"，但不能反之亦然。因此，如果我们因为比赛条件而错误地返回"可能有更多数据"，我们只会得到一小部分性能开销，因为我们需要再次查询，下次我们将收到"数据结束"