torrentfs

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2018 License: GPL-3.0, GPL-3.0 Imports: 39 Imported by: 0

README

torrentfs

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrBuildConn         = errors.New("build internal-rpc connection failed")
	ErrGetLatestBlock    = errors.New("get latest block failed")
	ErrNoRPCClient       = errors.New("no rpc client")
	ErrNoDownloadManager = errors.New("no download manager")
)

Errors that are used throughout the Torrent API.

View Source 
var DefaultConfig = Config{
	Host:            "localhost",
	Port:            8085,
	DefaultTrackers: "http://47.52.39.170:5008/announce",
	SyncMode:        "full",
	TestMode:        false,
}

DefaultConfig contains default settings for the storage.

Functions

func NewBoltDB 

func NewBoltDB(filePath string) *boltDBClient

NewBoltDB ...

Types

type Block 

type Block struct {
	Number     uint64        `json:"number"           gencodec:"required"`
	Hash       common.Hash   `json:"Hash"             gencodec:"required"`
	ParentHash common.Hash   `json:"parentHash"       gencodec:"required"`
	Txs        []Transaction `json:"Transactions"     gencodec:"required"`
}

gencodec -type Block -field-override blockMarshaling -out gen_block_json.go Block ... block struct

func (Block) MarshalJSON 

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

MarshalJSON marshals as JSON.

func (*Block) UnmarshalJSON 

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

UnmarshalJSON unmarshals from JSON.

type Config 

type Config struct {
	DataDir string `toml:",omitempty"`
	RpcURI  string `toml:",omitempty"`
	IpcPath string `toml:",omitempty"`
	// Host is the host interface on which to start the storage server. If this
	// field is empty, no storage will be started.
	Host string `toml:",omitempty"`
	// Port is the TCP port number on which to start the storage server. The
	// default zero value is/ valid and will pick a port number randomly.
	Port            int    `toml:",omitempty"`
	DefaultTrackers string `toml:",omitempty"`
	SyncMode        string `toml:",omitempty"`
	TestMode        bool   `toml:",omitempty"`
}

Config ...

type FileInfo 

type FileInfo struct {
	Meta *FileMeta
	// Transaction hash
	TxHash *common.Hash
	// Contract Address
	ContractAddr *common.Address
	LeftSize     uint64
}

FileInfo ...

func NewFileInfo 

func NewFileInfo(Meta *FileMeta) *FileInfo

NewFileInfo ...

func (FileInfo) MarshalJSON 

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

MarshalJSON marshals as JSON.

func (*FileInfo) UnmarshalJSON 

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

UnmarshalJSON unmarshals from JSON.

type FileMeta 

type FileMeta struct {
	// Author Address
	AuthorAddr *common.Address
	// Download InfoHash, should be in magnetURI format
	URI string
	// The raw size of the file counted in bytes
	RawSize  uint64
	BlockNum uint64
}

FileMeta ...

func (*FileMeta) DisplayName 

func (m *FileMeta) DisplayName() string

DisplayName ...

func (*FileMeta) InfoHash 

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

InfoHash ...

func (FileMeta) MarshalJSON 

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

MarshalJSON marshals as JSON.

func (*FileMeta) UnmarshalJSON 

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

UnmarshalJSON unmarshals from JSON.

type FileStorage 

type FileStorage struct {
	LatestBlockNumber uint64
	// contains filtered or unexported fields
}

FileStorage ...

func NewFileStorage 

func NewFileStorage(config *Config) *FileStorage

NewFileStorage ...

func (*FileStorage) AddBlock 

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

AddBlock ...

func (*FileStorage) AddFile 

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

AddFile ...

func (*FileStorage) GetBlock 

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

GetBlock ...

func (*FileStorage) GetFileByAddr 

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

GetFileByAddr ...

func (*FileStorage) GetFileByInfoHash 

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

GetFileByInfoHash ...

func (*FileStorage) HasBlock 

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

HasBlock ...

func (*FileStorage) IsBlockChecked 

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

IsBlockChecked ...

func (*FileStorage) SetBlockChecked 

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

SetBlockChecked ...

type FlowControlMeta 

type FlowControlMeta struct {
	InfoHash       metainfo.Hash
	BytesRequested uint64
}

FlowControlMeta ...

type GeneralMessage 

type GeneralMessage struct {
	Version string `json:"version,omitempty"`
	Commit  string `json:"commit,omitempty"`
}

type HTTPMonitor 

type HTTPMonitor struct {
	Addr string
	// contains filtered or unexported fields
}

HTTPMonitor ... Monitor for serving http services.

func NewHTTPMonitor 

func NewHTTPMonitor(addr string) *HTTPMonitor

NewHTTPMonitor ... Create a http monitor instance.

func (*HTTPMonitor) Finalize 

func (m *HTTPMonitor) Finalize()

func (*HTTPMonitor) Initilize 

func (m *HTTPMonitor) Initilize()

func (*HTTPMonitor) ServeHTTP 

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

func (*HTTPMonitor) Update 

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

type Monitor 

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

Monitor observes the data changes on the blockchain and synchronizes. cl for ipc/rpc communication, dl for download manager, and fs for data storage.

func NewMonitor 

func NewMonitor(flag *Config) *Monitor

NewMonitor creates a new instance of monitor. Once Ipcpath is settle, this method prefers to build socket connection in order to get higher communicating performance. IpcPath is unavailable on windows.

func (*Monitor) Call 

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

func (*Monitor) SetConnection 

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

SetConnection method builds connection to remote or local communicator.

func (*Monitor) SetDownloader 

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

SetDownloader ...

func (*Monitor) Start 

func (m *Monitor) Start() error

Start ... start ListenOn on the rpc port of a blockchain full node

func (*Monitor) Terminate 

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

type Torrent 

type Torrent struct {
	*torrent.Torrent
	// contains filtered or unexported fields
}

Torrent ...

func (*Torrent) Pause 

func (t *Torrent) Pause()

Pause ...

func (*Torrent) Paused 

func (t *Torrent) Paused() bool

Paused ...

func (*Torrent) Pending 

func (t *Torrent) Pending() bool

Pending ...

func (*Torrent) Run 

func (t *Torrent) Run()

Run ...

func (*Torrent) Running 

func (t *Torrent) Running() bool

Running ...

func (*Torrent) Seed 

func (t *Torrent) Seed()

func (*Torrent) Seeding 

func (t *Torrent) Seeding() bool

type TorrentFS 

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

TorrentFS contains the torrent file system internals.

func New 

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

New creates a new dashboard instance with the given configuration.

func (*TorrentFS) APIs 

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

APIs implements the node.Service interface.

func (*TorrentFS) Protocols 

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

Protocols implements the node.Service interface.

func (*TorrentFS) Start 

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

Start starts the data collection thread and the listening server of the dashboard. Implements the node.Service interface.

func (*TorrentFS) Stop 

func (db *TorrentFS) Stop() error

Stop stops the data collection thread and the connection listener of the dashboard. Implements the node.Service interface.

type TorrentManager 

type TorrentManager struct {
	DataDir    string
	TmpDataDir string
	// contains filtered or unexported fields
}

TorrentManager ...

func NewTorrentManager 

func NewTorrentManager(config *Config) *TorrentManager

NewTorrentManager ...

func (*TorrentManager) AddMagnet 

func (tm *TorrentManager) AddMagnet(uri string)

AddMagnet ...

func (*TorrentManager) AddTorrent 

func (tm *TorrentManager) AddTorrent(filePath string)

AddTorrent ...

func (*TorrentManager) CloseAll 

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

func (*TorrentManager) DropMagnet 

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

DropMagnet ...

func (*TorrentManager) NewTorrent 

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

func (*TorrentManager) RemoveTorrent 

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

func (*TorrentManager) SetTrackers 

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

SetTrackers ...

func (*TorrentManager) UpdateMagnet 

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

UpdateMagnet ...

func (*TorrentManager) UpdateTorrent 

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

type TorrentManagerAPI 

type TorrentManagerAPI interface {
	CloseAll(struct{}) error
	NewTorrent(string) error
	RemoveTorrent(string) error
	UpdateTorrent(interface{}) error
}

type Transaction 

type Transaction struct {
	Price     *big.Int        `json:"gasPrice" gencodec:"required"`
	Amount    *big.Int        `json:"value"    gencodec:"required"`
	GasLimit  uint64          `json:"gas"      gencodec:"required"`
	Payload   []byte          `json:"input"    gencodec:"required"`
	From      *common.Address `json:"from"     gencodec:"required"`
	Recipient *common.Address `json:"to"       rlp:"nil"` // nil means contract creation
	Hash      *common.Hash    `json:"hash"     gencodec:"required"`
	Receipt   *TxReceipt      `json:"receipt"  rlp:"nil"`
}

Transaction ... Tx struct

func (*Transaction) Data 

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

Data ...

func (*Transaction) IsFlowControl 

func (t *Transaction) IsFlowControl() bool

IsFlowControl ...

func (Transaction) MarshalJSON 

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

MarshalJSON marshals as JSON.

func (*Transaction) Op 

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

Op ...

func (*Transaction) Parse 

func (t *Transaction) Parse() *FileMeta

Parse ...

func (*Transaction) UnmarshalJSON 

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

UnmarshalJSON unmarshals from JSON.

type TxReceipt 

type TxReceipt struct {
	// Contract Address
	ContractAddr *common.Address `json:"ContractAddress"  gencodec:"required"`
	// Transaction Hash
	TxHash *common.Hash `json:"TransactionHash"  gencodec:"required"`
}

TxReceipt ...

func (TxReceipt) MarshalJSON 

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

MarshalJSON marshals as JSON.

func (*TxReceipt) UnmarshalJSON 

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

UnmarshalJSON unmarshals from JSON.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.