Current state: Under Discussion
...
Keywords: etcd, datacoord, datanode
Released:
Summary
DataCoord register channels on etcd and DataNode watch etcd to do watch/release operations.
Motivation
There are several problems when DataCoord sends the WatchDmChannel to the DataNode through grpc:
...
ChanelInfo contains State,StartTime, SeekPosition. VchannelInfo:
- State is a enum whose values are Unwatched, Watched. This means whether datanode watch it successfully.
- StartTime is the watch event start time.
- VchannelInfo contains all info needed to restore the channel.
If there is a new channel registration, datacoord updates channel / [nodeid] / [channelname]
...