mirror of https://github.com/milvus-io/milvus.git
[skip ci]Format message stream doc (#9021)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/9033/head
parent
98d449551e
commit
413ba12f50
|
@ -247,19 +247,19 @@ func (rmsf *RmqMsgStreamFactory) NewTtMsgStream() *MsgStream
|
||||||
// PulsarMsgStream
|
// PulsarMsgStream
|
||||||
|
|
||||||
type PulsarMsgStream struct {
|
type PulsarMsgStream struct {
|
||||||
ctx context.Context
|
ctx context.Context
|
||||||
client pulsar.Client
|
client pulsar.Client
|
||||||
producers []Producer
|
producers []Producer
|
||||||
consumers []Consumer
|
consumers []Consumer
|
||||||
consumerChannels []string
|
consumerChannels []string
|
||||||
repackFunc RepackFunc
|
repackFunc RepackFunc
|
||||||
unmarshal UnmarshalDispatcher
|
unmarshal UnmarshalDispatcher
|
||||||
receiveBuf chan *MsgPack
|
receiveBuf chan *MsgPack
|
||||||
wait *sync.WaitGroup
|
wait *sync.WaitGroup
|
||||||
streamCancel func()
|
streamCancel func()
|
||||||
pulsarBufSize int64
|
pulsarBufSize int64
|
||||||
consumerLock *sync.Mutex
|
consumerLock *sync.Mutex
|
||||||
consumerReflects []reflect.SelectCase
|
consumerReflects []reflect.SelectCase
|
||||||
|
|
||||||
scMap *sync.Map
|
scMap *sync.Map
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue