# Functions
CloseRocksMQ is used to close global rocksmq.
DeleteMessages in rocksdb by range of [startID, endID).
DeserializeRmqID is used to deserialize a message ID from byte array.
InitRocksMQ init global rocksmq single instance.
NewMockRocksMQ creates a new instance of MockRocksMQ.
NewRocksMQ step: 1.
SerializeRmqID is used to serialize a message ID to byte array.
# Constants
acked_ts/topicName/pageId, record the latest ack ts of each page, will be purged on retention or destroy of the topic.
Const variable that will be used in rocksmqs.
Const value that used to convert unit.
message_size/topicName record the current page message size, once current message size > RocksMq size, reset this value and open a new page TODO should be cached.
page_message_size/topicName/pageId record the endId of each page, it will be purged either in retention or the destroy of topic.
page_ts/topicName/pageId, record the page last ts, used for TTL functionality.
Const variable that will be used in rocksmqs.
RmqStateHealthy state stands for healthy `Rocksmq` instance.
RmqStateStopped state stands for just created or stopped `Rocksmq` instance.
topic_begin_id/topicName topic begin id record a topic is valid, create when topic is created, cleaned up on destroy topic.
# Variables
Rmq is global rocksmq instance that will be initialized only once.
No description provided by the author
RocksDB cache size limitation(TODO config it).
# Structs
Consumer is rocksmq consumer.
ConsumerMessage that consumed from rocksdb.
MockRocksMQ is an autogenerated mock type for the RocksMQ type.
MockRocksMQ_CheckTopicValid_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckTopicValid'.
MockRocksMQ_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'.
MockRocksMQ_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'.
MockRocksMQ_CreateConsumerGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateConsumerGroup'.
MockRocksMQ_CreateTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTopic'.
MockRocksMQ_DestroyConsumerGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DestroyConsumerGroup'.
MockRocksMQ_DestroyTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DestroyTopic'.
MockRocksMQ_ExistConsumerGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExistConsumerGroup'.
No description provided by the author
MockRocksMQ_GetLatestMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestMsg'.
MockRocksMQ_Notify_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Notify'.
MockRocksMQ_Produce_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Produce'.
MockRocksMQ_RegisterConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterConsumer'.
MockRocksMQ_Seek_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Seek'.
MockRocksMQ_SeekToLatest_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SeekToLatest'.
ProducerMessage that will be written to rocksdb.
rmqID wraps message ID for rocksmq.
# Interfaces
RocksMQ is an interface thatmay be implemented by the application to do message queue operations based on rocksdb.