Versions in this module Expand all Collapse all v2 v2.5.6 Mar 5, 2025 v2.5.5 Feb 25, 2025 Changes in this version + const AckedTsTitle + const DefaultMessageID + const MB + const MessageSizeTitle + const PageMsgSizeTitle + const PageTsTitle + const RmqNotServingErrMsg + const TopicIDTitle + var Rmq *rocksmq + var RocksDBLRUCacheMaxCapacity = uint64(4 << 30) + var RocksDBLRUCacheMinCapacity = uint64(1 << 29) + func CloseRocksMQ() + func DeleteMessages(db *gorocksdb.DB, topic string, startID, endID UniqueID) error + func DeserializeRmqID(messageID []byte) int64 + func InitRocksMQ(path string) error + func NewRocksMQ(name string) (*rocksmq, error) + func SerializeRmqID(messageID int64) []byte + type Consumer struct + GroupName string + MsgMutex chan struct{} + Topic string + type ConsumerMessage struct + MsgID UniqueID + Payload []byte + type MockRocksMQ struct + func NewMockRocksMQ(t mockConstructorTestingTNewMockRocksMQ) *MockRocksMQ + func (_m *MockRocksMQ) CheckTopicValid(topicName string) error + func (_m *MockRocksMQ) Close() + func (_m *MockRocksMQ) Consume(topicName string, groupName string, n int) ([]ConsumerMessage, error) + func (_m *MockRocksMQ) CreateConsumerGroup(topicName string, groupName string) error + func (_m *MockRocksMQ) CreateTopic(topicName string) error + func (_m *MockRocksMQ) DestroyConsumerGroup(topicName string, groupName string) error + func (_m *MockRocksMQ) DestroyTopic(topicName string) error + func (_m *MockRocksMQ) EXPECT() *MockRocksMQ_Expecter + func (_m *MockRocksMQ) ExistConsumerGroup(topicName string, groupName string) (bool, *Consumer, error) + func (_m *MockRocksMQ) GetLatestMsg(topicName string) (int64, error) + func (_m *MockRocksMQ) Notify(topicName string, groupName string) + func (_m *MockRocksMQ) Produce(topicName string, messages []ProducerMessage) ([]int64, error) + func (_m *MockRocksMQ) RegisterConsumer(consumer *Consumer) error + func (_m *MockRocksMQ) Seek(topicName string, groupName string, msgID int64) error + func (_m *MockRocksMQ) SeekToLatest(topicName string, groupName string) error + type MockRocksMQ_CheckTopicValid_Call struct + func (_c *MockRocksMQ_CheckTopicValid_Call) Return(_a0 error) *MockRocksMQ_CheckTopicValid_Call + func (_c *MockRocksMQ_CheckTopicValid_Call) Run(run func(topicName string)) *MockRocksMQ_CheckTopicValid_Call + type MockRocksMQ_Close_Call struct + func (_c *MockRocksMQ_Close_Call) Return() *MockRocksMQ_Close_Call + func (_c *MockRocksMQ_Close_Call) Run(run func()) *MockRocksMQ_Close_Call + type MockRocksMQ_Consume_Call struct + func (_c *MockRocksMQ_Consume_Call) Return(_a0 []ConsumerMessage, _a1 error) *MockRocksMQ_Consume_Call + func (_c *MockRocksMQ_Consume_Call) Run(run func(topicName string, groupName string, n int)) *MockRocksMQ_Consume_Call + type MockRocksMQ_CreateConsumerGroup_Call struct + func (_c *MockRocksMQ_CreateConsumerGroup_Call) Return(_a0 error) *MockRocksMQ_CreateConsumerGroup_Call + func (_c *MockRocksMQ_CreateConsumerGroup_Call) Run(run func(topicName string, groupName string)) *MockRocksMQ_CreateConsumerGroup_Call + type MockRocksMQ_CreateTopic_Call struct + func (_c *MockRocksMQ_CreateTopic_Call) Return(_a0 error) *MockRocksMQ_CreateTopic_Call + func (_c *MockRocksMQ_CreateTopic_Call) Run(run func(topicName string)) *MockRocksMQ_CreateTopic_Call + type MockRocksMQ_DestroyConsumerGroup_Call struct + func (_c *MockRocksMQ_DestroyConsumerGroup_Call) Return(_a0 error) *MockRocksMQ_DestroyConsumerGroup_Call + func (_c *MockRocksMQ_DestroyConsumerGroup_Call) Run(run func(topicName string, groupName string)) *MockRocksMQ_DestroyConsumerGroup_Call + type MockRocksMQ_DestroyTopic_Call struct + func (_c *MockRocksMQ_DestroyTopic_Call) Return(_a0 error) *MockRocksMQ_DestroyTopic_Call + func (_c *MockRocksMQ_DestroyTopic_Call) Run(run func(topicName string)) *MockRocksMQ_DestroyTopic_Call + type MockRocksMQ_ExistConsumerGroup_Call struct + func (_c *MockRocksMQ_ExistConsumerGroup_Call) Return(_a0 bool, _a1 *Consumer, _a2 error) *MockRocksMQ_ExistConsumerGroup_Call + func (_c *MockRocksMQ_ExistConsumerGroup_Call) Run(run func(topicName string, groupName string)) *MockRocksMQ_ExistConsumerGroup_Call + type MockRocksMQ_Expecter struct + func (_e *MockRocksMQ_Expecter) CheckTopicValid(topicName interface{}) *MockRocksMQ_CheckTopicValid_Call + func (_e *MockRocksMQ_Expecter) Close() *MockRocksMQ_Close_Call + func (_e *MockRocksMQ_Expecter) Consume(topicName interface{}, groupName interface{}, n interface{}) *MockRocksMQ_Consume_Call + func (_e *MockRocksMQ_Expecter) CreateConsumerGroup(topicName interface{}, groupName interface{}) *MockRocksMQ_CreateConsumerGroup_Call + func (_e *MockRocksMQ_Expecter) CreateTopic(topicName interface{}) *MockRocksMQ_CreateTopic_Call + func (_e *MockRocksMQ_Expecter) DestroyConsumerGroup(topicName interface{}, groupName interface{}) *MockRocksMQ_DestroyConsumerGroup_Call + func (_e *MockRocksMQ_Expecter) DestroyTopic(topicName interface{}) *MockRocksMQ_DestroyTopic_Call + func (_e *MockRocksMQ_Expecter) ExistConsumerGroup(topicName interface{}, groupName interface{}) *MockRocksMQ_ExistConsumerGroup_Call + func (_e *MockRocksMQ_Expecter) GetLatestMsg(topicName interface{}) *MockRocksMQ_GetLatestMsg_Call + func (_e *MockRocksMQ_Expecter) Notify(topicName interface{}, groupName interface{}) *MockRocksMQ_Notify_Call + func (_e *MockRocksMQ_Expecter) Produce(topicName interface{}, messages interface{}) *MockRocksMQ_Produce_Call + func (_e *MockRocksMQ_Expecter) RegisterConsumer(consumer interface{}) *MockRocksMQ_RegisterConsumer_Call + func (_e *MockRocksMQ_Expecter) Seek(topicName interface{}, groupName interface{}, msgID interface{}) *MockRocksMQ_Seek_Call + func (_e *MockRocksMQ_Expecter) SeekToLatest(topicName interface{}, groupName interface{}) *MockRocksMQ_SeekToLatest_Call + type MockRocksMQ_GetLatestMsg_Call struct + func (_c *MockRocksMQ_GetLatestMsg_Call) Return(_a0 int64, _a1 error) *MockRocksMQ_GetLatestMsg_Call + func (_c *MockRocksMQ_GetLatestMsg_Call) Run(run func(topicName string)) *MockRocksMQ_GetLatestMsg_Call + type MockRocksMQ_Notify_Call struct + func (_c *MockRocksMQ_Notify_Call) Return() *MockRocksMQ_Notify_Call + func (_c *MockRocksMQ_Notify_Call) Run(run func(topicName string, groupName string)) *MockRocksMQ_Notify_Call + type MockRocksMQ_Produce_Call struct + func (_c *MockRocksMQ_Produce_Call) Return(_a0 []int64, _a1 error) *MockRocksMQ_Produce_Call + func (_c *MockRocksMQ_Produce_Call) Run(run func(topicName string, messages []ProducerMessage)) *MockRocksMQ_Produce_Call + type MockRocksMQ_RegisterConsumer_Call struct + func (_c *MockRocksMQ_RegisterConsumer_Call) Return(_a0 error) *MockRocksMQ_RegisterConsumer_Call + func (_c *MockRocksMQ_RegisterConsumer_Call) Run(run func(consumer *Consumer)) *MockRocksMQ_RegisterConsumer_Call + type MockRocksMQ_SeekToLatest_Call struct + func (_c *MockRocksMQ_SeekToLatest_Call) Return(_a0 error) *MockRocksMQ_SeekToLatest_Call + func (_c *MockRocksMQ_SeekToLatest_Call) Run(run func(topicName string, groupName string)) *MockRocksMQ_SeekToLatest_Call + type MockRocksMQ_Seek_Call struct + func (_c *MockRocksMQ_Seek_Call) Return(_a0 error) *MockRocksMQ_Seek_Call + func (_c *MockRocksMQ_Seek_Call) Run(run func(topicName string, groupName string, msgID int64)) *MockRocksMQ_Seek_Call + type ProducerMessage struct + Payload []byte + type RmqID struct + MessageID UniqueID + func (rid *RmqID) AtEarliestPosition() bool + func (rid *RmqID) Equal(msgID []byte) (bool, error) + func (rid *RmqID) LessOrEqualThan(msgID []byte) (bool, error) + func (rid *RmqID) Serialize() []byte + type RmqState = int64 + const RmqStateHealthy + const RmqStateStopped + type RocksMQ interface + CheckTopicValid func(topicName string) error + Close func() + Consume func(topicName string, groupName string, n int) ([]ConsumerMessage, error) + CreateConsumerGroup func(topicName string, groupName string) error + CreateTopic func(topicName string) error + DestroyConsumerGroup func(topicName string, groupName string) error + DestroyTopic func(topicName string) error + ExistConsumerGroup func(topicName string, groupName string) (bool, *Consumer, error) + GetLatestMsg func(topicName string) (int64, error) + Notify func(topicName, groupName string) + Produce func(topicName string, messages []ProducerMessage) ([]UniqueID, error) + RegisterConsumer func(consumer *Consumer) error + Seek func(topicName string, groupName string, msgID UniqueID) error + SeekToLatest func(topicName, groupName string) error + type UniqueID = typeutil.UniqueID
Go to main page