Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + type HeartbeatStream struct + func NewHeartbeatStream() HeartbeatStream + func (s HeartbeatStream) BindStream(storeID uint64, stream hbstream.HeartbeatStream) + func (s HeartbeatStream) Recv() *pdpb.RegionHeartbeatResponse + func (s HeartbeatStream) Send(m *pdpb.RegionHeartbeatResponse) error + func (s HeartbeatStream) SendMsg(region *core.RegionInfo, msg *pdpb.RegionHeartbeatResponse)
Go to main page