engine

Documentation

Index

• Constants
• func NewNodeRouter() *gin.Engine
• func NewTrackerRouter() *gin.Engine
• func ReSortNodes(nodes []string) func(i, j int)
• func ReportToTracker(tracker string, pieceId string, task *models.DownloadTask) bool
• type CleanerWorker
  • func NewCleanerWorker() *CleanerWorker
  • func (worker *CleanerWorker) Start()
  • func (worker *CleanerWorker) Stop()
• type DownloadWorker
  • func NewDownloadWorker() *DownloadWorker
  • func (worker *DownloadWorker) Start()
  • func (worker *DownloadWorker) Stop()
• type HeartBeatWorker
  • func NewHeartBeatWorker(tracker string) *HeartBeatWorker
  • func (worker *HeartBeatWorker) SendHeartBeat()
  • func (worker *HeartBeatWorker) Start()
  • func (worker *HeartBeatWorker) Stop()
• type NodeWebServer
  • func NewNodeWebServer() *NodeWebServer
  • func (worker *NodeWebServer) Start()
  • func (worker *NodeWebServer) Stop()
• type TrackerWebServer
  • func NewTrackerWebServer() *TrackerWebServer
  • func (worker *TrackerWebServer) Start()
  • func (worker *TrackerWebServer) Stop()

Constants

const BuffSize = 1024

Functions

func NewNodeRouter

func NewNodeRouter() *gin.Engine

func NewTrackerRouter

func NewTrackerRouter() *gin.Engine

func ReSortNodes

func ReSortNodes(nodes []string) func(i, j int)

func ReportToTracker

func ReportToTracker(tracker string, pieceId string, task *models.DownloadTask) bool

Types

type CleanerWorker

type CleanerWorker struct {
	RunningFlag bool // 是否运行 true:运行 false:停止
	ExitedFlag  bool //  已经退出的标识
	ExitChan    chan struct{}
}

func NewCleanerWorker

func NewCleanerWorker() *CleanerWorker

func (*CleanerWorker) Start

func (worker *CleanerWorker) Start()

func (*CleanerWorker) Stop

func (worker *CleanerWorker) Stop()

type DownloadWorker

type DownloadWorker struct {
	RunningFlag bool // 是否运行 true:运行 false:停止
	ExitedFlag  bool //  已经退出的标识
	ExitChan    chan struct{}
}

func NewDownloadWorker

func NewDownloadWorker() *DownloadWorker

func (*DownloadWorker) Start

func (worker *DownloadWorker) Start()

func (*DownloadWorker) Stop

func (worker *DownloadWorker) Stop()

type HeartBeatWorker

type HeartBeatWorker struct {
	RunningFlag bool // 是否运行 true:运行 false:停止
	ExitedFlag  bool //  已经退出的标识
	ExitChan    chan struct{}
	// contains filtered or unexported fields
}

func NewHeartBeatWorker

func NewHeartBeatWorker(tracker string) *HeartBeatWorker

func (*HeartBeatWorker) SendHeartBeat

func (worker *HeartBeatWorker) SendHeartBeat()

func (*HeartBeatWorker) Start

func (worker *HeartBeatWorker) Start()

func (*HeartBeatWorker) Stop

func (worker *HeartBeatWorker) Stop()

type NodeWebServer

type NodeWebServer struct {
	Server *http.Server
}

func NewNodeWebServer

func NewNodeWebServer() *NodeWebServer

func (*NodeWebServer) Start

func (worker *NodeWebServer) Start()

func (*NodeWebServer) Stop

func (worker *NodeWebServer) Stop()

type TrackerWebServer

type TrackerWebServer struct {
	Server *http.Server
}

func NewTrackerWebServer

func NewTrackerWebServer() *TrackerWebServer

func (*TrackerWebServer) Start

func (worker *TrackerWebServer) Start()

func (*TrackerWebServer) Stop

func (worker *TrackerWebServer) Stop()