heartbeat

Documentation

Index

• type HeartBeatTask
  • func NewHeartBeat(store *storage.YigFsStorage) (resp *HeartBeatTask, err error)
  • func (h *HeartBeatTask) CheckAndInsertMachine(req *types.GetIncompleteUploadSegsStore)
  • func (h *HeartBeatTask) InsertOrUpdateHeartBeatMsg(msg *types.GetIncompleteUploadSegsStore)
  • func (h *HeartBeatTask) RunHeartBeatTask()
  • func (h *HeartBeatTask) Stop()

Types

type HeartBeatTask

type HeartBeatTask struct {
	Store        *storage.YigFsStorage
	StopTaskChan chan struct{}

	HeartBeatMap *common.ConcurrentMap
	// contains filtered or unexported fields
}

func NewHeartBeat

func NewHeartBeat(store *storage.YigFsStorage) (resp *HeartBeatTask, err error)

func (*HeartBeatTask) CheckAndInsertMachine

func (h *HeartBeatTask) CheckAndInsertMachine(req *types.GetIncompleteUploadSegsStore)

func (*HeartBeatTask) InsertOrUpdateHeartBeatMsg

func (h *HeartBeatTask) InsertOrUpdateHeartBeatMsg(msg *types.GetIncompleteUploadSegsStore)

func (*HeartBeatTask) RunHeartBeatTask

func (h *HeartBeatTask) RunHeartBeatTask()

func (*HeartBeatTask) Stop

func (h *HeartBeatTask) Stop()