Versions in this module Expand all Collapse all v0 v0.4.1 Jul 9, 2019 v0.4.0 Jun 20, 2019 Changes in this version + const PieceAvailable + const PieceRunning + const PieceSuccess + type Manager struct + func NewManager(cfg *config.Config) (*Manager, error) + func (pm *Manager) DeletePeerIDByPieceNum(ctx context.Context, taskID string, pieceNum int, peerID string) error + func (pm *Manager) DeletePeerStateByPeerID(ctx context.Context, peerID string) error + func (pm *Manager) DeletePieceProgressByCID(ctx context.Context, taskID, clientID string) (err error) + func (pm *Manager) GetBlackInfoByPeerID(ctx context.Context, peerID string) (dstPIDMap *cutil.SyncMap, err error) + func (pm *Manager) GetPeerIDsByPieceNum(ctx context.Context, taskID string, pieceNum int) (peerIDs []string, err error) + func (pm *Manager) GetPeerStateByPeerID(ctx context.Context, peerID string) (*mgr.PeerState, error) + func (pm *Manager) GetPeersByTaskID(ctx context.Context, taskID string) (peersInfo []*types.PeerInfo, err error) + func (pm *Manager) GetPieceProgressByCID(ctx context.Context, taskID, clientID, pieceStatus string) (pieceNums []int, err error) + func (pm *Manager) InitProgress(ctx context.Context, taskID, peerID, clientID string) (err error) + func (pm *Manager) UpdateClientProgress(ctx context.Context, taskID, srcCID, dstPID string, pieceNum, pieceStatus int) error + func (pm *Manager) UpdateProgress(ctx context.Context, taskID, srcCID, srcPID, dstPID string, ...) error
Go to main page