From 9c807cc4dfdf89fac34ca261508bbb8dce53a1a5 Mon Sep 17 00:00:00 2001 From: neza2017 Date: Wed, 4 Nov 2020 17:23:18 +0800 Subject: [PATCH] Update doc and add context Signed-off-by: neza2017 --- docs/developer_guides/developer_guides.md | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/docs/developer_guides/developer_guides.md b/docs/developer_guides/developer_guides.md index bddcb20fbc..f4245815db 100644 --- a/docs/developer_guides/developer_guides.md +++ b/docs/developer_guides/developer_guides.md @@ -1137,6 +1137,7 @@ type softTimeTickBarrier struct { lastTt Timestamp outTt chan Timestamp ttStream *MsgStream + ctx context.Context } func (ttBarrier *softTimeTickBarrier) GetTimeTick() Timestamp @@ -1156,6 +1157,7 @@ type hardTimeTickBarrier struct { peer2Tt map[UniqueId]List outTt chan Timestamp ttStream *MsgStream + ctx context.Context } func (ttBarrier *hardTimeTickBarrier) GetTimeTick() Timestamp @@ -1180,6 +1182,8 @@ type timeSyncMsgProducer struct { insertSyncStream *MsgStream deleteSyncStream *MsgStream k2sSyncStream *MsgStream + + ctx context.Context } func (syncMsgProducer* timeSyncMsgProducer) SetProxyTtStreams(proxyTt *MsgStream, proxyIds []UniqueId) @@ -1189,7 +1193,7 @@ func (syncMsgProducer* timeSyncMsgProducer) SetInsertSyncStream(insertSync *MsgS func (syncMsgProducer* timeSyncMsgProducer) SetDeleteSyncStream(deleteSync *MsgStream) func (syncMsgProducer* timeSyncMsgProducer) SetK2sSyncStream(k2sSync *MsgStream) -func (syncMsgProducer* timeSyncMsgProducer) Start(ctx context.Context) error +func (syncMsgProducer* timeSyncMsgProducer) Start() error func (syncMsgProducer* timeSyncMsgProducer) Close() error ```