T- ring buffer item type
public interface RingbufferStore<T>
|Modifier and Type||Method and Description|
Return the largest sequence seen by the data store.
Loads the value of a given sequence.
Stores one item with it's corresponding sequence.
Stores multiple items.
void store(long sequence, T data)
Ringbufferfrom adding the item. It is the responsibility of the store to ensure that it keeps consistent with the Ringbuffer and in case of an exception is thrown, the data is not in the store.
sequence- the sequence ID of the data
data- the value of the data to store
void storeAll(long firstItemSequence, T items)
Ringbufferfrom adding any of the items. It is the responsibility of the store to ensure that it keeps consistent with the Ringbuffer and in case of an exception is thrown the passed data is not in the store.
firstItemSequence- the sequence of the first item
items- the items that are being stored
T load(long sequence)
sequence- the sequence of the requested item
Ringbuffer.readManyAsync(long, int, int, IFunction)
Copyright © 2020 Hazelcast, Inc.. All rights reserved.