mockhbstream

Documentation

Index

• type HeartbeatStream
  • 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)

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) BindStream

func (s HeartbeatStream) BindStream(storeID uint64, stream hbstream.HeartbeatStream)

BindStream mock method.

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.