mirror of https://github.com/milvus-io/milvus.git
[skip ci]Format message_stream docs (#8248)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/8255/head
parent
21f15d66bb
commit
158c64f01b
|
@ -357,11 +357,11 @@ type IDAllocator interface {
|
|||
|
||||
// Every collection has its RocksMQ
|
||||
type RocksMQ struct {
|
||||
store *gorocksdb.DB
|
||||
kv kv.Base
|
||||
store *gorocksdb.DB
|
||||
kv kv.Base
|
||||
idAllocator IDAllocator
|
||||
produceMu sync.Mutex
|
||||
consumeMu sync.Mutex
|
||||
produceMu sync.Mutex
|
||||
consumeMu sync.Mutex
|
||||
}
|
||||
|
||||
func (rmq *RocksMQ) CreateChannel(channelName string) error
|
||||
|
|
Loading…
Reference in New Issue