_buffer (defined in AMPS.Client.BlockPublishStore) | AMPS.Client.BlockPublishStore | protected |
_crc (defined in AMPS.Client.BlockPublishStore) | AMPS.Client.BlockPublishStore | protected |
_errorOnPublishGap (defined in AMPS.Client.BlockPublishStore) | AMPS.Client.BlockPublishStore | protected |
_resizeHandler (defined in AMPS.Client.BlockPublishStore) | AMPS.Client.BlockPublishStore | protected |
BlockPublishStore(Buffer buffer, int blocksPerRealloc, bool errorOnPublishGap_=false) | AMPS.Client.BlockPublishStore | inlineprotected |
BlockPublishStore(Buffer buffer, bool useCrc=false, int blocksPerRealloc=10000, bool errorOnPublishGap_=false) | AMPS.Client.BlockPublishStore | inlineprotected |
close() | AMPS.Client.PublishStore | inline |
discardUpTo(ulong sequence) | AMPS.Client.BlockPublishStore | inlinevirtual |
Dispose() | AMPS.Client.PublishStore | inlinevirtual |
flush() | AMPS.Client.BlockPublishStore | inline |
flush(int timeout) | AMPS.Client.BlockPublishStore | inline |
getErrorOnPublishGap() | AMPS.Client.BlockPublishStore | inlinevirtual |
getHighestUnpersisted() | AMPS.Client.BlockPublishStore | inline |
getLastPersisted() | AMPS.Client.BlockPublishStore | inline |
getLowestUnpersisted() | AMPS.Client.BlockPublishStore | inline |
growFreeListIfEmpty() | AMPS.Client.BlockPublishStore | inlineprotected |
open() | AMPS.Client.PublishStore | inline |
PublishStore(string path, bool errorOnPublishGap=false) | AMPS.Client.PublishStore | inline |
PublishStore(string path, int blocksPerRealloc, bool errorOnPublishGap=false) | AMPS.Client.PublishStore | inline |
recover() | AMPS.Client.BlockPublishStore | inlineprotected |
replay(StoreReplayer replayer) | AMPS.Client.BlockPublishStore | inlinevirtual |
replaySingle(StoreReplayer replayer, ulong sequence) | AMPS.Client.BlockPublishStore | inline |
setCrc(Utilities.CRC32 crc_) | AMPS.Client.PublishStore | inline |
setErrorOnPublishGap(bool errorOnPublishGap_) | AMPS.Client.BlockPublishStore | inline |
setMessage(Message message) | AMPS.Client.BlockPublishStore | inline |
setResizeHandler(PublishStoreResizeHandler handler) | AMPS.Client.BlockPublishStore | inline |
store(Message m) | AMPS.Client.BlockPublishStore | inline |
store(Message m, Boolean assignSequence) | AMPS.Client.BlockPublishStore | inline |
sync() | AMPS.Client.PublishStore | inline |
truncateOnClose(bool truncate) | AMPS.Client.PublishStore | inline |
unpersistedCount() | AMPS.Client.BlockPublishStore | inline |