task

Documentation

Index

• type Manager
  • func NewManager(cfg *config.Config, peerMgr mgr.PeerMgr, dfgetTaskMgr mgr.DfgetTaskMgr, ...) (*Manager, error)
  • func (tm *Manager) CheckTaskStatus(ctx context.Context, taskID string) (bool, error)
  • func (tm *Manager) Delete(ctx context.Context, taskID string) error
  • func (tm *Manager) Get(ctx context.Context, taskID string) (*types.TaskInfo, error)
  • func (tm *Manager) GetPieces(ctx context.Context, taskID, clientID string, req *types.PiecePullRequest) (bool, interface{}, error)
  • func (tm *Manager) List(ctx context.Context, filter map[string]string) ([]*types.TaskInfo, error)
  • func (tm *Manager) Register(ctx context.Context, req *types.TaskCreateRequest) (taskCreateResponse *types.TaskCreateResponse, err error)
  • func (tm *Manager) Update(ctx context.Context, taskID string, taskInfo *types.TaskInfo) error
  • func (tm *Manager) UpdatePieceStatus(ctx context.Context, taskID, pieceRange string, ...) error

Types

type Manager

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

Manager is an implementation of the interface of TaskMgr.

func NewManager

func NewManager(cfg *config.Config, peerMgr mgr.PeerMgr, dfgetTaskMgr mgr.DfgetTaskMgr,
	progressMgr mgr.ProgressMgr, cdnMgr mgr.CDNMgr, schedulerMgr mgr.SchedulerMgr) (*Manager, error)

NewManager returns a new Manager Object.

func (*Manager) CheckTaskStatus

func (tm *Manager) CheckTaskStatus(ctx context.Context, taskID string) (bool, error)

CheckTaskStatus check the task status.

func (*Manager) Delete

func (tm *Manager) Delete(ctx context.Context, taskID string) error

Delete deletes a task.

func (*Manager) Get

func (tm *Manager) Get(ctx context.Context, taskID string) (*types.TaskInfo, error)

Get a task info according to specified taskID.

func (*Manager) GetPieces

func (tm *Manager) GetPieces(ctx context.Context, taskID, clientID string, req *types.PiecePullRequest) (bool, interface{}, error)

GetPieces get the pieces to be downloaded based on the scheduling result.

func (*Manager) List

func (tm *Manager) List(ctx context.Context, filter map[string]string) ([]*types.TaskInfo, error)

List returns a list of tasks with filter. TODO: implement it.

func (*Manager) Register

func (tm *Manager) Register(ctx context.Context, req *types.TaskCreateRequest) (taskCreateResponse *types.TaskCreateResponse, err error)

Register will not only register a task.

func (*Manager) Update

func (tm *Manager) Update(ctx context.Context, taskID string, taskInfo *types.TaskInfo) error

Update the info of task.

func (*Manager) UpdatePieceStatus

func (tm *Manager) UpdatePieceStatus(ctx context.Context, taskID, pieceRange string, pieceUpdateRequest *types.PieceUpdateRequest) error

UpdatePieceStatus update the piece status with specified parameters.