addMonitoringTag(std::string tag)=0 | facebook::logdevice::AsyncReader | pure virtual |
doNotDecodeBufferedWrites()=0 | facebook::logdevice::AsyncReader | pure virtual |
doNotSkipPartiallyTrimmedSections()=0 | facebook::logdevice::AsyncReader | pure virtual |
forceNoSingleCopyDelivery()=0 | facebook::logdevice::AsyncReader | pure virtual |
getBytesBuffered(std::function< void(size_t)> callback)=0 | facebook::logdevice::AsyncReader | pure virtual |
includeByteOffset()=0 | facebook::logdevice::AsyncReader | pure virtual |
isConnectionHealthy(logid_t) const =0 | facebook::logdevice::AsyncReader | pure virtual |
nextFromLsnWhenStuck(lsn_t stuck_lsn=LSN_INVALID, lsn_t tail_lsn=LSN_INVALID) | facebook::logdevice::AsyncReader | static |
resumeReading(logid_t log_id)=0 | facebook::logdevice::AsyncReader | pure virtual |
setDoneCallback(std::function< void(logid_t)>)=0 | facebook::logdevice::AsyncReader | pure virtual |
setGapCallback(std::function< bool(const GapRecord &)>)=0 | facebook::logdevice::AsyncReader | pure virtual |
setHealthChangeCallback(std::function< void(logid_t, HealthChangeType)>)=0 | facebook::logdevice::AsyncReader | pure virtual |
setReaderName(const std::string &reader_name)=0 (defined in facebook::logdevice::AsyncReader) | facebook::logdevice::AsyncReader | pure virtual |
setRecordCallback(std::function< bool(std::unique_ptr< DataRecord > &)>)=0 | facebook::logdevice::AsyncReader | pure virtual |
startReading(logid_t log_id, lsn_t from, lsn_t until=LSN_MAX, const ReadStreamAttributes *attrs=nullptr)=0 | facebook::logdevice::AsyncReader | pure virtual |
stopReading(logid_t log_id, std::function< void()> callback=nullptr)=0 | facebook::logdevice::AsyncReader | pure virtual |
withoutPayload()=0 | facebook::logdevice::AsyncReader | pure virtual |
~AsyncReader() (defined in facebook::logdevice::AsyncReader) | facebook::logdevice::AsyncReader | inlinevirtual |