mirror of https://github.com/milvus-io/milvus.git
[skip ci]Add comment for rocksmq reader_impl (#13442)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/13437/merge
parent
bb4ae9879d
commit
cf5d07dc66
|
@ -24,6 +24,7 @@ type reader struct {
|
|||
subscriptionRolePrefix string
|
||||
}
|
||||
|
||||
// newReader create a rocksmq reader from reader options
|
||||
func newReader(c *client, readerOptions *ReaderOptions) (*reader, error) {
|
||||
if c == nil {
|
||||
return nil, newError(InvalidConfiguration, "client is nil")
|
||||
|
|
Loading…
Reference in New Issue