mirror of https://github.com/milvus-io/milvus.git
parent
0f65b845d2
commit
d2d7ac85b1
|
@ -252,7 +252,23 @@ type RmsFactory struct {
|
|||
|
||||
```go
|
||||
|
||||
|
||||
// mqMsgStream
|
||||
type mqMsgStream struct {
|
||||
ctx context.Context
|
||||
client mqclient.Client
|
||||
producers map[string]mqclient.Producer
|
||||
producerChannels []string
|
||||
consumers map[string]mqclient.Consumer
|
||||
consumerChannels []string
|
||||
repackFunc RepackFunc
|
||||
unmarshal UnmarshalDispatcher
|
||||
receiveBuf chan *MsgPack
|
||||
wait *sync.WaitGroup
|
||||
streamCancel func()
|
||||
bufSize int64
|
||||
producerLock *sync.Mutex
|
||||
consumerLock *sync.Mutex
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue