[skip ci]Format messsage stream factory docs (#9165)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
pull/8968/head
yukun 2021-10-03 21:42:02 +08:00 committed by GitHub
parent deee8bb00c
commit 27c5dd299f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions

View File

@ -224,10 +224,11 @@ type MsgStream interface {
Seek(offset []*MsgPosition) error Seek(offset []*MsgPosition) error
} }
type MsgStreamFactory interface { type Factory interface {
SetParams(params map[string]interface{}) error SetParams(params map[string]interface{}) error
NewMsgStream(ctx context.Context) (MsgStream, error) NewMsgStream(ctx context.Context) (MsgStream, error)
NewTtMsgStream(ctx context.Context) (MsgStream, error) NewTtMsgStream(ctx context.Context) (MsgStream, error)
NewQueryMsgStream(ctx context.Context) (MsgStream, error)
} }
//TODO //TODO