From deee8bb00c3c3ba44a75855d6db82ce0f9520daa Mon Sep 17 00:00:00 2001 From: yukun Date: Sun, 3 Oct 2021 21:40:14 +0800 Subject: [PATCH] [skip ci]Format messsage stream docs (#9164) Signed-off-by: fishpenguin --- docs/developer_guides/chap04_message_stream.md | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/docs/developer_guides/chap04_message_stream.md b/docs/developer_guides/chap04_message_stream.md index 3b15440d96..d6ccf0df14 100644 --- a/docs/developer_guides/chap04_message_stream.md +++ b/docs/developer_guides/chap04_message_stream.md @@ -215,11 +215,13 @@ type MsgStream interface { AsProducer(channels []string) AsConsumer(channels []string, subName string) SetRepackFunc(repackFunc RepackFunc) - - Produce(context.Context, *MsgPack) error - Broadcast(context.Context, *MsgPack) error - Consume() (*MsgPack, context.Context) - Seek(offset *MsgPosition) error + ComputeProduceChannelIndexes(tsMsgs []TsMsg) [][]int32 + GetProduceChannels() []string + Produce(*MsgPack) error + Broadcast(*MsgPack) error + BroadcastMark(*MsgPack) (map[string][]MessageID, error) + Consume() *MsgPack + Seek(offset []*MsgPosition) error } type MsgStreamFactory interface {