The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HeartbeatStream ¶
type HeartbeatStream struct {
// contains filtered or unexported fields
}
HeartbeatStream is used to mock HeartbeatStream for test use.
func NewHeartbeatStream ¶
func NewHeartbeatStream() HeartbeatStream
NewHeartbeatStream creates a new HeartbeatStream.
func (HeartbeatStream) Recv ¶
func (s HeartbeatStream) Recv() *pdpb.RegionHeartbeatResponse
Recv mocks method.
func (HeartbeatStream) Send ¶
func (s HeartbeatStream) Send(m *pdpb.RegionHeartbeatResponse) error
Send mocks method.
func (HeartbeatStream) SendMsg ¶
func (s HeartbeatStream) SendMsg(region *core.RegionInfo, msg *pdpb.RegionHeartbeatResponse)
SendMsg is used to send the message.
type HeartbeatStreams ¶
type HeartbeatStreams struct {
// contains filtered or unexported fields
}
HeartbeatStreams is used to mock heartbeatstreams for test use.
func NewHeartbeatStreams ¶
func NewHeartbeatStreams(clusterID uint64) *HeartbeatStreams
NewHeartbeatStreams creates a new HeartbeatStreams.
func (*HeartbeatStreams) SendMsg ¶
func (mhs *HeartbeatStreams) SendMsg(region *core.RegionInfo, msg *pdpb.RegionHeartbeatResponse)
SendMsg is used to send the message.
Source Files
Click to show internal directories.
Click to hide internal directories.