mockhbstream

Documentation

Index

• type HeartbeatStream
  • func NewHeartbeatStream() HeartbeatStream
  • func NewHeartbeatStreamWithTimeout(timeout time.Duration) HeartbeatStream
  • func (s HeartbeatStream) BindStream(containerID uint64, stream opt.HeartbeatStream)
  • func (s HeartbeatStream) Recv() *rpcpb.ResourceHeartbeatRsp
  • func (s HeartbeatStream) Send(m *rpcpb.ResourceHeartbeatRsp) error
  • func (s HeartbeatStream) SendMsg(res *core.CachedResource, msg *rpcpb.ResourceHeartbeatRsp)

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 NewHeartbeatStreamWithTimeout

func NewHeartbeatStreamWithTimeout(timeout time.Duration) HeartbeatStream

NewHeartbeatStreamWithTimeout creates a new HeartbeatStream.

func (HeartbeatStream) BindStream

func (s HeartbeatStream) BindStream(containerID uint64, stream opt.HeartbeatStream)

BindStream mock method.

func (HeartbeatStream) Recv

func (s HeartbeatStream) Recv() *rpcpb.ResourceHeartbeatRsp

Recv mocks method.

func (HeartbeatStream) Send

func (s HeartbeatStream) Send(m *rpcpb.ResourceHeartbeatRsp) error

Send mocks method.

func (HeartbeatStream) SendMsg

func (s HeartbeatStream) SendMsg(res *core.CachedResource, msg *rpcpb.ResourceHeartbeatRsp)

SendMsg is used to send the message.