task

Documentation

Index

• Constants
• type Manager
  • func NewManager(cfg *config.Config, cdnMgr daemon.CDNMgr, progressMgr daemon.SeedProgressMgr) (*Manager, error)
  • func (tm Manager) Delete(taskID string) error
  • func (tm *Manager) GC() error
  • func (tm Manager) Get(taskID string) (*types.SeedTask, error)
  • func (tm Manager) GetAccessTime() (*syncmap.SyncMap, 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)

Constants

const (
	IllegalSourceFileLen = -100
)

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 daemon.CDNMgr, progressMgr daemon.SeedProgressMgr) (*Manager, error)

NewManager returns a new Manager Object.

func (Manager) Delete

func (tm Manager) Delete(taskID string) error

func (*Manager) GC

func (tm *Manager) GC() error

func (Manager) Get

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

func (Manager) GetAccessTime

func (tm Manager) GetAccessTime() (*syncmap.SyncMap, 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)