supervisor

Documentation

Index

• func IsResourcesLacked(err error) bool
• type CDNService
  • func NewCDNService(taskManager task.Manager, cdnManager cdn.Manager, ...) (CDNService, error)

Functions

func IsResourcesLacked

func IsResourcesLacked(err error) bool

Types

type CDNService

type CDNService interface {
	// RegisterSeedTask registers seed task
	RegisterSeedTask(ctx context.Context, clientAddr string, registerTask *task.SeedTask) (*task.SeedTask, <-chan *task.PieceInfo, error)

	// GetSeedPieces returns pieces associated with taskID, which are sorted by pieceNum
	GetSeedPieces(taskID string) (pieces []*task.PieceInfo, err error)

	// GetSeedTask returns seed task associated with taskID
	GetSeedTask(taskID string) (seedTask *task.SeedTask, err error)
}

func NewCDNService

func NewCDNService(taskManager task.Manager, cdnManager cdn.Manager, progressManager progress.Manager) (CDNService, error)