task

Documentation

Index

• type Manager
  • func NewManager(cfg *config.Config, cdnMgr supervisor.CDNMgr, ...) (*Manager, error)
  • func (tm Manager) Delete(taskID string) error
  • func (tm Manager) Exist(taskID string) (*types.SeedTask, bool)
  • func (tm *Manager) GC() error
  • func (tm Manager) Get(taskID string) (*types.SeedTask, error)
  • func (tm *Manager) GetPieces(ctx context.Context, taskID string) (pieces []*types.SeedPiece, err error)
  • func (tm *Manager) Register(ctx context.Context, req *types.TaskRegisterRequest) (pieceChan <-chan *types.SeedPiece, err 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, cdnMgr supervisor.CDNMgr, progressMgr supervisor.SeedProgressMgr) (*Manager, error)

NewManager returns a new Manager Object.

func (Manager) Delete

func (tm Manager) Delete(taskID string) error

func (Manager) Exist

func (tm Manager) Exist(taskID string) (*types.SeedTask, bool)

func (*Manager) GC

func (tm *Manager) GC() error

func (Manager) Get

func (tm Manager) Get(taskID string) (*types.SeedTask, error)

func (*Manager) GetPieces

func (tm *Manager) GetPieces(ctx context.Context, taskID string) (pieces []*types.SeedPiece, err error)

func (*Manager) Register

func (tm *Manager) Register(ctx context.Context, req *types.TaskRegisterRequest) (pieceChan <-chan *types.SeedPiece, err error)