public interface TimelineQueue
限定符和类型 | 方法和说明 |
---|---|
Future<TimelineEntry> |
batchStore(long sequenceId,
TimelineMessage message)
Batch store message asynchronously with manually set sequence id.
|
Future<TimelineEntry> |
batchStore(long sequenceId,
TimelineMessage message,
TimelineCallback callback)
Store message asynchronously with manually set sequence id by writer.
|
Future<TimelineEntry> |
batchStore(TimelineMessage message)
Batch store message to specified timeline queue with auto-generated sequence id.
|
Future<TimelineEntry> |
batchStore(TimelineMessage message,
TimelineCallback callback)
Store message asynchronously with autogenerated sequence id by writer.
|
void |
close() |
void |
delete(long sequenceId)
Delete timeline entry by specified sequence id.
|
void |
flush()
Flush all the messages in buffer, wait until finish writing.
|
TimelineEntry |
get(long sequenceId)
Get timeline entry by sequence id.
|
TimelineIdentifier |
getIdentifier()
The specified identifier of single timeline queue.
|
long |
getLatestSequenceId()
Get the latest sequence id of specified identifier.
|
TimelineEntry |
getLatestTimelineEntry()
Get the latest timeline entry of specified identifier.
|
Iterator<TimelineEntry> |
scan(ScanParameter parameter)
Scan a specified range of timeline entries by scan parameter.
|
TimelineEntry |
store(long sequenceId,
TimelineMessage message)
Store message to specified timeline queue whose sequence id is set manually.
|
TimelineEntry |
store(TimelineMessage message)
Store message into specified timeline queue with auto-generated sequence id.
|
Future<TimelineEntry> |
storeAsync(long sequenceId,
TimelineMessage message,
TimelineCallback callback)
Store message asynchronously with manually set sequence id.
|
Future<TimelineEntry> |
storeAsync(TimelineMessage message,
TimelineCallback callback)
Store message asynchronously with auto-generated sequence id.
|
TimelineEntry |
update(long sequenceId,
TimelineMessage message)
Update message with new content by sequence id.
|
Future<TimelineEntry> |
updateAsync(long sequenceId,
TimelineMessage message,
TimelineCallback callback)
Update message asynchronously with new content by sequence id.
|
TimelineIdentifier getIdentifier()
TimelineEntry store(TimelineMessage message)
message
- The content of the message to store.TimelineEntry store(long sequenceId, TimelineMessage message)
sequenceId
- The sequence id of the timeline, which should be unique and incremental.message
- The content of the message to store.Future<TimelineEntry> storeAsync(TimelineMessage message, TimelineCallback callback)
message
- The content of the message to store.callback
- The timeline callback, which deal with response.Future<TimelineEntry> storeAsync(long sequenceId, TimelineMessage message, TimelineCallback callback)
sequenceId
- The sequence id of the timeline, which should be unique and incremental.message
- The content of the message to store.callback
- The timeline callback, which deal with response.Future<TimelineEntry> batchStore(TimelineMessage message)
message
- The content of the message to store.Future<TimelineEntry> batchStore(long sequenceId, TimelineMessage message)
sequenceId
- The sequence id of the timeline, which should be unique and incremental.message
- The content of the message to store.Future<TimelineEntry> batchStore(TimelineMessage message, TimelineCallback callback)
message
- The content of the message to store.callback
- Timeline callback, which deal with single message response.Future<TimelineEntry> batchStore(long sequenceId, TimelineMessage message, TimelineCallback callback)
sequenceId
- The sequence id of the timeline, which should be unique and incremental.message
- The content of the message to store.callback
- Timeline callback, which deal with single message response.TimelineEntry update(long sequenceId, TimelineMessage message)
sequenceId
- The sequence id of the timeline to update.message
- New content of the message to update.Future<TimelineEntry> updateAsync(long sequenceId, TimelineMessage message, TimelineCallback callback)
sequenceId
- The sequence id of the timeline to update.message
- New content of the message to update.callback
- Timeline callback to deal with response.TimelineEntry get(long sequenceId)
sequenceId
- The sequence id of the timeline to get.void delete(long sequenceId)
sequenceId
- The sequence id of the timeline to delete.Iterator<TimelineEntry> scan(ScanParameter parameter)
parameter
- The parameter of scan range.long getLatestSequenceId()
TimelineEntry getLatestTimelineEntry()
void flush()
void close()
Copyright © 2019. All Rights Reserved.