hbstream

Documentation

Index

• type HeartbeatStream
• type HeartbeatStreams
  • func NewHeartbeatStreams(ctx context.Context, clusterID uint64, storeInformer core.StoreSetInformer) *HeartbeatStreams
  • func NewTestHeartbeatStreams(ctx context.Context, clusterID uint64, storeInformer core.StoreSetInformer, ...) *HeartbeatStreams
  • func (s *HeartbeatStreams) BindStream(storeID uint64, stream HeartbeatStream)
  • func (s *HeartbeatStreams) Close()
  • func (s *HeartbeatStreams) Drain(count int) error
  • func (s *HeartbeatStreams) MsgLength() int
  • func (s *HeartbeatStreams) SendErr(errType pdpb.ErrorType, errMsg string, targetPeer *metapb.Peer)
  • func (s *HeartbeatStreams) SendMsg(region *core.RegionInfo, msg *pdpb.RegionHeartbeatResponse)

Types

type HeartbeatStream

type HeartbeatStream interface {
	Send(*pdpb.RegionHeartbeatResponse) error
}

HeartbeatStream is an interface.

type HeartbeatStreams

type HeartbeatStreams struct {
	// contains filtered or unexported fields
}

HeartbeatStreams is the bridge of communication with TIKV instance.

func NewHeartbeatStreams

func NewHeartbeatStreams(ctx context.Context, clusterID uint64, storeInformer core.StoreSetInformer) *HeartbeatStreams

NewHeartbeatStreams creates a new HeartbeatStreams which enable background running by default.

func NewTestHeartbeatStreams

func NewTestHeartbeatStreams(ctx context.Context, clusterID uint64, storeInformer core.StoreSetInformer, needRun bool) *HeartbeatStreams

NewTestHeartbeatStreams creates a new HeartbeatStreams for test purpose only. Please use NewHeartbeatStreams for other usage.

func (*HeartbeatStreams) BindStream

func (s *HeartbeatStreams) BindStream(storeID uint64, stream HeartbeatStream)

BindStream binds a stream with a specified store.

func (*HeartbeatStreams) Close

func (s *HeartbeatStreams) Close()

Close closes background running.

func (*HeartbeatStreams) Drain

func (s *HeartbeatStreams) Drain(count int) error

Drain consumes message from msgCh when disable background running. For test only.

func (*HeartbeatStreams) MsgLength

func (s *HeartbeatStreams) MsgLength() int

MsgLength gets the length of msgCh. For test only.

func (*HeartbeatStreams) SendErr

func (s *HeartbeatStreams) SendErr(errType pdpb.ErrorType, errMsg string, targetPeer *metapb.Peer)

SendErr sends a error message to related store.

func (*HeartbeatStreams) SendMsg

func (s *HeartbeatStreams) SendMsg(region *core.RegionInfo, msg *pdpb.RegionHeartbeatResponse)

SendMsg sends a message to related store.