torrentfs

May 8, 2020

Changes in this version

+ func ProgressBar(x, y int64, desc string) string

+ type ChainIndex struct

+ CheckPoint uint64

+ LastListenBlockNumber uint64

+ func NewChainIndex(config *Config) (*ChainIndex, error)

+ func (fs *ChainIndex) AddBlock(b *types.Block) error

+ func (fs *ChainIndex) Blocks() []*types.Block

+ func (fs *ChainIndex) Close() error

+ func (fs *ChainIndex) Files() []*types.FileInfo

+ func (fs *ChainIndex) Flush() error

+ func (fs *ChainIndex) GetBlockByNumber(blockNum uint64) *types.Block

+ func (fs *ChainIndex) GetFileByAddr(addr common.Address) *types.FileInfo

+ func (fs *ChainIndex) GetRootByNumber(number uint64) (root []byte)

+ func (fs *ChainIndex) ID() uint64

+ func (fs *ChainIndex) Metrics() time.Duration

+ func (fs *ChainIndex) NewFileInfo(Meta *types.FileMeta) *types.FileInfo

+ func (fs *ChainIndex) Reset() error

+ func (fs *ChainIndex) Root() common.Hash

+ func (fs *ChainIndex) Txs() uint64

+ func (fs *ChainIndex) UpdateFile(x *types.FileInfo) (uint64, bool, error)

+ func (fs *ChainIndex) Version() string

type Config

+ Metrics bool

+ type StorageAPI interface

+ Available func(ih string, raw int64) (bool, error)

+ Close func() error

+ GetFile func(infohash string, subpath string) ([]byte, error)

+ GetTorrent func(ih metainfo.Hash) *Torrent

+ Metrics func() time.Duration

+ Start func() error

+ UpdateTorrent func(interface{}) error

type TorrentManager

+ Updates time.Duration

+ func (fs *TorrentManager) Available(infohash string, rawSize int64) (bool, error)

+ func (fs *TorrentManager) GetFile(infohash string, subpath string) ([]byte, error)

+ func (fs *TorrentManager) Metrics() time.Duration

Apr 23, 2020

Changes in this version

+ const NumberOfMessageCodes

+ const ProtocolName

+ const ProtocolVersion

+ const ProtocolVersionStr

+ var GoodFiles = map[string]bool

type Config

+ DownloadRate int

+ UploadRate int

+ type Peer struct

+ func (p *Peer) Start() error

+ func (p *Peer) Stop() error

+ func (peer *Peer) ID() []byte

+ type PublicTorrentAPI struct

+ func NewPublicTorrentAPI(w *TorrentFS) *PublicTorrentAPI

type TorrentFS

+ func (tfs *TorrentFS) HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error

+ func (tfs *TorrentFS) MaxMessageSize() uint64

+ func (tfs *TorrentFS) Version() uint

type TorrentManager

+ func (tm *TorrentManager) SearchAndDownload(hex string, request int64)

Mar 20, 2020

Changes in this version

+ var BadFiles = map[string]bool

+ type BlockContent struct

+ func (t BlockContent) CalculateHash() ([]byte, error)

+ func (t BlockContent) Equals(other types.Content) (bool, error)

type CVMStorage

+ Stop func() error

type Config

+ Boost bool

+ DisableTCP bool

+ FullSeed bool

+ Quiet bool

type FileStorage

+ CheckPoint uint64

+ func (fs *FileStorage) Blocks() []*types.Block

+ func (fs *FileStorage) Files() []*types.FileInfo

+ func (fs *FileStorage) Flush() error

+ func (fs *FileStorage) GetRootByNumber(number uint64) (root []byte)

+ func (fs *FileStorage) ID() uint64

+ func (fs *FileStorage) Reset() error

+ func (fs *FileStorage) Root() common.Hash

+ func (fs *FileStorage) Txs() uint64

+ func (fs *FileStorage) UpdateFile(x *types.FileInfo) (uint64, bool, error)

+ func (fs *FileStorage) Version() string

type Torrent

+ func (t *Torrent) BoostOff()

+ func (t *Torrent) Finished() bool

type TorrentManager

+ func (tm *TorrentManager) GetLimitation(value int64) int64

+ func (tm *TorrentManager) UpdateDynamicTrackers(trackers []string)

type TorrentManagerAPI

+ GetTorrent func(ih metainfo.Hash) *Torrent

Jun 26, 2019

Changes in this version

+ var ErrBlockHash = errors.New("block or parent block hash invalid")

+ var ErrReadDataFromBoltDB = errors.New("Bolt DB Read Error")

+ var Str404NotFound []byte = []byte

+ var TorrentAPIAvailable sync.Mutex

+ func Available(infohash string, rawSize int64) bool

+ func Exist(infohash string) bool

+ func ExistTorrent(infohash string) bool

+ func GetFile(infohash string, path string) ([]byte, error)

+ func GetMagnetURI(infohash metainfo.Hash) string

+ func SetConnection(clientURI string) (*rpc.Client, error)

+ type ActiveTorrentList []*Torrent

+ func (s ActiveTorrentList) Len() int

+ func (s ActiveTorrentList) Less(i, j int) bool

+ func (s ActiveTorrentList) Swap(i, j int)

+ type BoostDataFetcher struct

+ func NewBoostDataFetcher(nodes []string) *BoostDataFetcher

+ func (f *BoostDataFetcher) GetFile(ih, subpath string) ([]byte, error)

+ func (f *BoostDataFetcher) GetTorrent(ih string) ([]byte, error)

+ type CVMStorage interface

+ Available func(infohash string, rawSize int64) bool

+ GetFile func(infohash string, path string) ([]byte, error)

+ var Torrentfs_handle CVMStorage

+ func CreateStorage(storage_type string, config Config) CVMStorage

+ func GetStorage() CVMStorage

type Config

+ BoostNodes []string

+ DisableDHT bool

+ DisableUTP bool

+ MaxActiveNum int

+ MaxSeedingNum int

+ func GetConfig() *Config

+ func InitConfig() *Config

type FileInfo

+ Index uint64

type FileMeta

+ Name string

type FileStorage

+ LastFileIndex uint64

+ LastListenBlockNumber uint64

+ func (fs *FileStorage) AddCachedFile(x *FileInfo) error

+ func (fs *FileStorage) Close() error

+ func (fs *FileStorage) GetBlockByNumber(blockNum uint64) *Block

+ func (fs *FileStorage) GetFileByNumber(index uint64) *FileInfo

+ func (fs *FileStorage) NewFileInfo(Meta *FileMeta) *FileInfo

+ func (fs *FileStorage) WriteBlock(b *Block) error

+ func (fs *FileStorage) WriteFile(f *FileInfo) error

+ type InfoHashFileSystem struct

+ DataDir string

+ func (fs InfoHashFileSystem) Available(infohash string, rawSize int64) bool

+ func (fs InfoHashFileSystem) GetFile(infohash string, subpath string) ([]byte, error)

type Monitor

+ func (m *Monitor) Stop()

+ type MutexCounter int32

+ func (mc *MutexCounter) Decrease()

+ func (mc *MutexCounter) Increase()

+ func (mc *MutexCounter) IsZero() bool

type Torrent

+ func (t *Torrent) BytesLeft() int64

+ func (t *Torrent) GetFile(subpath string) ([]byte, error)

+ func (t *Torrent) HasTorrent() bool

+ func (t *Torrent) InfoHash() string

+ func (t *Torrent) IsAvailable() bool

+ func (t *Torrent) Length() int64

+ func (t *Torrent) NumPieces() int

+ func (t *Torrent) ReloadFile(files []string, datas [][]byte, tm *TorrentManager)

+ func (t *Torrent) ReloadTorrent(data []byte, tm *TorrentManager)

+ func (t *Torrent) SeedInQueue()

+ func (t *Torrent) WriteTorrent()

type TorrentFS

+ func GetTorrentInstance() *TorrentFS

+ func (fs TorrentFS) Available(infohash string, rawSize int64) bool

+ func (fs TorrentFS) GetFile(infohash string, subpath string) ([]byte, error)

+ func (t *TorrentFS) Config() *Config

+ func (t *TorrentFS) Monitor() *Monitor

type TorrentManager

+ var CurrentTorrentManager *TorrentManager = nil

+ func (tm *TorrentManager) AddInfoHash(ih metainfo.Hash, BytesRequested int64)

+ func (tm *TorrentManager) Close() error

+ func (tm *TorrentManager) CreateTorrent(t *torrent.Torrent, requested int64, status int, ih metainfo.Hash) *Torrent

+ func (tm *TorrentManager) GetTorrent(ih metainfo.Hash) *Torrent

+ func (tm *TorrentManager) SetTorrent(ih metainfo.Hash, torrent *Torrent)

+ func (tm *TorrentManager) Start() error

+ func (tm *TorrentManager) UpdateInfoHash(ih metainfo.Hash, BytesRequested int64)

type TorrentManagerAPI

+ Close func() error

+ Start func() error

type TxReceipt

+ GasUsed uint64

+ Status uint64

Oct 15, 2018

Changes in this version

+ var DefaultConfig = Config

+ var ErrBuildConn = errors.New("build internal-rpc connection failed")

+ var ErrGetLatestBlock = errors.New("get latest block failed")

+ var ErrNoDownloadManager = errors.New("no download manager")

+ var ErrNoRPCClient = errors.New("no rpc client")

+ func NewBoltDB(filePath string) *boltDBClient

+ type Block struct

+ Hash common.Hash

+ Number uint64

+ ParentHash common.Hash

+ Txs []Transaction

+ func (b *Block) UnmarshalJSON(input []byte) error

+ func (b Block) MarshalJSON() ([]byte, error)

+ type Config struct

+ DataDir string

+ DefaultTrackers string

+ Host string

+ IpcPath string

+ Port int

+ RpcURI string

+ SyncMode string

+ TestMode bool

+ type FileInfo struct

+ ContractAddr *common.Address

+ LeftSize uint64

+ Meta *FileMeta

+ TxHash *common.Hash

+ func NewFileInfo(Meta *FileMeta) *FileInfo

+ func (f *FileInfo) UnmarshalJSON(input []byte) error

+ func (f FileInfo) MarshalJSON() ([]byte, error)

+ type FileMeta struct

+ AuthorAddr *common.Address

+ BlockNum uint64

+ RawSize uint64

+ URI string

+ func (f *FileMeta) UnmarshalJSON(input []byte) error

+ func (f FileMeta) MarshalJSON() ([]byte, error)

+ func (m *FileMeta) DisplayName() string

+ func (m *FileMeta) InfoHash() *metainfo.Hash

+ type FileStorage struct

+ LatestBlockNumber uint64

+ func NewFileStorage(config *Config) *FileStorage

+ func (fs *FileStorage) AddBlock(b *Block) error

+ func (fs *FileStorage) AddFile(x *FileInfo) error

+ func (fs *FileStorage) GetBlock(blockNum uint64) *Block

+ func (fs *FileStorage) GetFileByAddr(addr common.Address) *FileInfo

+ func (fs *FileStorage) GetFileByInfoHash(ih metainfo.Hash) *FileInfo

+ func (fs *FileStorage) HasBlock(blockNum uint64) bool

+ func (fs *FileStorage) IsBlockChecked(blockNum uint64) bool

+ func (fs *FileStorage) SetBlockChecked(blockNum uint64) error

+ type FlowControlMeta struct

+ BytesRequested uint64

+ InfoHash metainfo.Hash

+ type GeneralMessage struct

+ Commit string

+ Version string

+ type HTTPMonitor struct

+ Addr string

+ func NewHTTPMonitor(addr string) *HTTPMonitor

+ func (m *HTTPMonitor) Finalize()

+ func (m *HTTPMonitor) Initilize()

+ func (m *HTTPMonitor) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (m *HTTPMonitor) Update(path string, value interface{})

+ type Monitor struct

+ func NewMonitor(flag *Config) *Monitor

+ func (m *Monitor) Call(result interface{}, method string, args ...interface{}) error

+ func (m *Monitor) SetConnection(clientURI string) (e error)

+ func (m *Monitor) SetDownloader(dl TorrentManagerAPI) error

+ func (m *Monitor) Start() error

+ func (m *Monitor) Terminate() chan<- struct{}

+ type Torrent struct

+ func (t *Torrent) Pause()

+ func (t *Torrent) Paused() bool

+ func (t *Torrent) Pending() bool

+ func (t *Torrent) Run()

+ func (t *Torrent) Running() bool

+ func (t *Torrent) Seed()

+ func (t *Torrent) Seeding() bool

+ type TorrentFS struct

+ func New(config *Config, commit string) *TorrentFS

+ func (db *TorrentFS) APIs() []rpc.API

+ func (db *TorrentFS) Protocols() []p2p.Protocol

+ func (db *TorrentFS) Start(server *p2p.Server) error

+ func (db *TorrentFS) Stop() error

+ type TorrentManager struct

+ DataDir string

+ TmpDataDir string

+ func NewTorrentManager(config *Config) *TorrentManager

+ func (tm *TorrentManager) AddMagnet(uri string)

+ func (tm *TorrentManager) AddTorrent(filePath string)

+ func (tm *TorrentManager) CloseAll(input struct{}) error

+ func (tm *TorrentManager) DropMagnet(uri string) bool

+ func (tm *TorrentManager) NewTorrent(input string) error

+ func (tm *TorrentManager) RemoveTorrent(input string) error

+ func (tm *TorrentManager) SetTrackers(trackers []string)

+ func (tm *TorrentManager) UpdateMagnet(ih metainfo.Hash, BytesRequested int64)

+ func (tm *TorrentManager) UpdateTorrent(input interface{}) error

+ type TorrentManagerAPI interface

+ CloseAll func(struct{}) error

+ NewTorrent func(string) error

+ RemoveTorrent func(string) error

+ UpdateTorrent func(interface{}) error

+ type Transaction struct

+ Amount *big.Int

+ From *common.Address

+ GasLimit uint64

+ Hash *common.Hash

+ Payload []byte

+ Price *big.Int

+ Receipt *TxReceipt

+ Recipient *common.Address

+ func (t *Transaction) Data() []byte

+ func (t *Transaction) IsFlowControl() bool

+ func (t *Transaction) Op() (op int)

+ func (t *Transaction) Parse() *FileMeta

+ func (t *Transaction) UnmarshalJSON(input []byte) error

+ func (t Transaction) MarshalJSON() ([]byte, error)

+ type TxReceipt struct

+ ContractAddr *common.Address

+ TxHash *common.Hash

+ func (r *TxReceipt) UnmarshalJSON(input []byte) error

+ func (r TxReceipt) MarshalJSON() ([]byte, error)