p2p

type ActivePiece struct {
	// contains filtered or unexported fields
}

type Bitset struct {
	// contains filtered or unexported fields
}

type CacheProvider interface {
	NewCache(infohash string, numPieces int, pieceLength int, totalSize int64) FileCache
}

type DispatchTask struct {
	TaskID    string     `json:"taskId"`
	MetaInfo  *MetaInfo  `json:"metaInfo"`
	LinkChain *LinkChain `json:"linkChain"`
	Speed     int64      `json:"speed"`
}

type File interface {
	io.ReaderAt
	io.WriterAt
	io.Closer
}

type FileCache interface {

	//Marks a piece as committed to permanent storage.
	MarkCommitted(piece int)
	//Close the cache and free all the things
	Close()
	// contains filtered or unexported methods
}

type FileDict struct {
	Length int64  `json:"length"`
	Path   string `json:"path"`
	Name   string `json:"name"`
	Sum    string `json:"sum" `
}

type FileStore interface {
	io.ReaderAt
	io.WriterAt
	io.Closer
	SetCache(FileCache)
	Commit(int, []byte, int64)
}

type FileSystem interface {
	Open(name []string, length int64) (file File, err error)
	io.Closer
}

type FsProvider interface {
	NewFS() (FileSystem, error)
}

type LinkChain struct {
	// 软件分发的路径，要求服务端的地址排在第一个
	DispatchAddrs []string `json:"dispatchAddrs"`
	// 服务端管理接口，用于上报状态
	ServerAddr string `json:"serverAddr"`
}

type MetaInfo struct {
	Length   int64       `json:"length"`
	PieceLen int64       `json:"PieceLen"`
	Pieces   []byte      `json:"pieces"`
	Files    []*FileDict `json:"files"`
}

type OsFsProvider struct{}

type PHeader struct {
	Len      int32
	TaskID   string
	Username string
	Password string
	Salt     string
}

type PeerConn struct {
	// contains filtered or unexported fields
}

type RAMCache struct {
	// contains filtered or unexported fields
}

type RAMCacheProvider struct {
	// contains filtered or unexported fields
}

type StartTask struct {
	TaskID    string     `json:"taskId"`
	LinkChain *LinkChain `json:"linkChain"`
}

type StatusReport struct {
	TaskID          string  `json:"taskId"`
	IP              string  `json:"�ip"`
	PercentComplete float32 `json:"percentComplete"`
}

type TaskSession struct {
	// contains filtered or unexported fields
}

type TaskSessionMgnt struct {
	// contains filtered or unexported fields
}