mgr

package

Go to main page

Versions in this module

v0

v0.4.1

Jul 9, 2019

v0.4.0

Jun 20, 2019

Changes in this version

+ var PieceStatusMap = map[string]int

type CDNMgr

+ GetHTTPPath func(ctx context.Context, taskID string) (path string, err error)

type DfgetTaskMgr

+ GetCIDByPeerIDAndTaskID func(ctx context.Context, peerID, taskID string) (string, error)

+ type PeerState struct

+ ClientErrorCount *cutil.AtomicInt

+ PeerID string

+ ProducerLoad *cutil.AtomicInt

+ ServiceDownTime *int64

+ ServiceErrorCount *cutil.AtomicInt

+ type PieceResult struct

+ DstPID string

+ PieceNum int

+ TaskID string

type ProgressMgr

+ DeletePeerIDByPieceNum func(ctx context.Context, taskID string, pieceNum int, peerID string) error

+ DeletePeerStateByPeerID func(ctx context.Context, peerID string) error

+ DeletePieceProgressByCID func(ctx context.Context, taskID, clientID string) (err error)

+ GetBlackInfoByPeerID func(ctx context.Context, peerID string) (dstPIDMap *cutil.SyncMap, err error)

+ GetPeerIDsByPieceNum func(ctx context.Context, taskID string, pieceNum int) (peerIDs []string, err error)

+ GetPeerStateByPeerID func(ctx context.Context, peerID string) (peerState *PeerState, err error)

+ GetPeersByTaskID func(ctx context.Context, taskID string) (peersInfo []*types.PeerInfo, err error)

+ GetPieceProgressByCID func(ctx context.Context, taskID, clientID, filter string) (pieceNums []int, err error)

+ UpdateClientProgress func(ctx context.Context, taskID, srcCID, dstPID string, pieceNum, pieceStatus int) error

type TaskMgr

+ Delete func(ctx context.Context, taskID string) error

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

v0.3.1

Jun 6, 2019

v0.3.0

Mar 4, 2019

Changes in this version

+ type CDNMgr interface

+ Delete func(ctx context.Context, taskID string) error

+ GetStatus func(ctx context.Context, taskID string) (cdnStatus string, err error)

+ TriggerCDN func(ctx context.Context, taskInfo *types.TaskInfo) error

+ type DfgetTaskMgr interface

+ Add func(ctx context.Context, dfgetTask *types.DfGetTask) error

+ Delete func(ctx context.Context, clientID string) error

+ Get func(ctx context.Context, clientID string) (dfgetTask *types.DfGetTask, err error)

+ List func(ctx context.Context, filter map[string]string) (dfgetTaskList []*types.DfGetTask, err error)

+ UpdateStatus func(ctx context.Context, clientID string, status string) error

+ type PeerMgr interface

+ DeRegister func(ctx context.Context, peerID string) error

+ Get func(ctx context.Context, peerID string) (*types.PeerInfo, error)

+ List func(ctx context.Context, filter map[string]string) (peerList []*types.PeerInfo, err error)

+ Register func(ctx context.Context, peerInfo *types.PeerInfo) (peerID string, err error)

+ Update func(ctx context.Context, peerID string, peerInfo *types.PeerInfo) error

+ type ProgressMgr interface

+ GetPeersByPieceRange func(ctx context.Context, taskID, pieceRange string) (peersInfo []*types.PeerInfo, err error)

+ GetPeersBytaskID func(ctx context.Context, taskID string) (peersInfo []*types.PeerInfo, err error)

+ GetPiecesByCid func(ctx context.Context, clientID string) (pieceRanges []string, err error)

+ InitProgress func(ctx context.Context, taskID, clientID string) error

+ UpdateProgress func(ctx context.Context, taskID, srcCid, dstCid string, pieceRange string, ...) error

+ type SchedulerMgr interface

+ Schedule func(ctx context.Context, taskID, clientID string) ([]*types.PieceInfo, error)

+ type TaskMgr interface

+ CheckTaskStatus func(ctx context.Context, taskID string) (bool, error)

+ DeleteTask func(ctx context.Context, taskID string) error

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

+ GetPieces func(ctx context.Context, taskID, clientID string) ([]*types.PieceInfo, error)

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

+ Register func(ctx context.Context, task *types.TaskInfo) (taskID string, err error)

+ UpdatePieceStatus func(ctx context.Context, taskID, pieceRange, clientID string) error

+ UpdateTaskInfo func(ctx context.Context, taskID string, taskInfo *types.TaskInfo) error

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