Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

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:

  1. State is a enum whose values are Unwatched, Watched. This means whether datanode watch it successfully.
  2. StartTime is the watch event start time.
  3. VchannelInfo contains all info needed to restore the channel.

If there is a new channel registration, datacoord updates channel / [nodeid] / [channelname]

...