|
@@ -92,6 +92,7 @@ struct IQueueClient
|
|
|
|
|
|
//! Reads a batch of rows from a given partition of a given queue, starting at (at least) the given offset.
|
|
|
//! Requires the user to have read-access to the specified queue.
|
|
|
+ //! There is no guarantee that `rowBatchReadOptions.MaxRowCount` rows will be returned even if they are in the queue.
|
|
|
virtual TFuture<NQueueClient::IQueueRowsetPtr> PullQueue(
|
|
|
const NYPath::TRichYPath& queuePath,
|
|
|
i64 offset,
|
|
@@ -100,6 +101,7 @@ struct IQueueClient
|
|
|
const TPullQueueOptions& options = {}) = 0;
|
|
|
|
|
|
//! Same as PullQueue, but requires user to have read-access to the consumer and the consumer being registered for the given queue.
|
|
|
+ //! There is no guarantee that `rowBatchReadOptions.MaxRowCount` rows will be returned even if they are in the queue.
|
|
|
virtual TFuture<NQueueClient::IQueueRowsetPtr> PullConsumer(
|
|
|
const NYPath::TRichYPath& consumerPath,
|
|
|
const NYPath::TRichYPath& queuePath,
|