mockhbstream

Documentation

Index

• type HeartbeatStream
  • func NewHeartbeatStream() HeartbeatStream
  • func (s HeartbeatStream) Recv() *schedulerpb.RegionHeartbeatResponse
  • func (s HeartbeatStream) Send(m *schedulerpb.RegionHeartbeatResponse) error
  • func (s HeartbeatStream) SendMsg(region *core.RegionInfo, msg *schedulerpb.RegionHeartbeatResponse)
• type HeartbeatStreams
  • func NewHeartbeatStreams(clusterID uint64) *HeartbeatStreams
  • func (mhs *HeartbeatStreams) MsgCh() chan *schedulerpb.RegionHeartbeatResponse
  • func (mhs *HeartbeatStreams) SendMsg(region *core.RegionInfo, msg *schedulerpb.RegionHeartbeatResponse)

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() *schedulerpb.RegionHeartbeatResponse

Recv mocks method.

func (HeartbeatStream) Send

func (s HeartbeatStream) Send(m *schedulerpb.RegionHeartbeatResponse) error

Send mocks method.

func (HeartbeatStream) SendMsg

func (s HeartbeatStream) SendMsg(region *core.RegionInfo, msg *schedulerpb.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) MsgCh

func (mhs *HeartbeatStreams) MsgCh() chan *schedulerpb.RegionHeartbeatResponse

MsgCh returns the internal channel which contains the heartbeat responses from PD. It can be used to inspect the content of a PD response

func (*HeartbeatStreams) SendMsg

func (mhs *HeartbeatStreams) SendMsg(region *core.RegionInfo, msg *schedulerpb.RegionHeartbeatResponse)

SendMsg is used to send the message.