supervisor

package
v2.0.2-alpha.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 15, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsResourcesLacked added in v2.0.2

func IsResourcesLacked(err error) bool

Types

type CDNService added in v2.0.2

type CDNService interface {
	// RegisterSeedTask registers seed task
	RegisterSeedTask(ctx context.Context, clientAddr string, registerTask *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 added in v2.0.2

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

Directories

Path Synopsis
cdn
storage/mock
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
mocks
cdn
Package cdn is a generated GoMock package.
Package cdn is a generated GoMock package.
progress
Package progress is a generated GoMock package.
Package progress is a generated GoMock package.
task
Package task is a generated GoMock package.
Package task is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL