transfer

Documentation

Index

• type Downloader
  • func NewDownloader(clients ...*node.Client) *Downloader
  • func (downloader *Downloader) Download(root, filename string, proof bool) error
• type SegmentDownloader
  • func NewSegmentDownloader(clients []*node.Client, file *download.DownloadingFile, withProof bool) (*SegmentDownloader, error)
  • func (downloader *SegmentDownloader) Download() error
  • func (downloader *SegmentDownloader) ParallelCollect(result *parallel.Result) error
  • func (downloader *SegmentDownloader) ParallelDo(routine, task int) (interface{}, error)
• type UploadOption
• type Uploader
  • func NewUploader(flow *contract.FlowContract, clients []*node.Client) *Uploader
  • func NewUploaderLight(clients []*node.Client) *Uploader
  • func (uploader *Uploader) BatchUpload(datas []core.IterableData, option ...[]UploadOption) error
  • func (uploader *Uploader) Upload(data core.IterableData, option ...UploadOption) error

Types

type Downloader

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

func NewDownloader

func NewDownloader(clients ...*node.Client) *Downloader

func (*Downloader) Download

func (downloader *Downloader) Download(root, filename string, proof bool) error

type SegmentDownloader

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

func NewSegmentDownloader

func NewSegmentDownloader(clients []*node.Client, file *download.DownloadingFile, withProof bool) (*SegmentDownloader, error)

func (*SegmentDownloader) Download

func (downloader *SegmentDownloader) Download() error

Download downloads segments in parallel.

func (*SegmentDownloader) ParallelCollect

func (downloader *SegmentDownloader) ParallelCollect(result *parallel.Result) error

ParallelCollect implements the parallel.Interface interface.

func (*SegmentDownloader) ParallelDo

func (downloader *SegmentDownloader) ParallelDo(routine, task int) (interface{}, error)

ParallelDo implements the parallel.Interface interface.

type UploadOption

type UploadOption struct {
	Tags     []byte // for kv operations
	Force    bool   // for kv to upload same file
	Disperse bool   // disperse files to different nodes
}

type Uploader

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

func NewUploader

func NewUploader(flow *contract.FlowContract, clients []*node.Client) *Uploader

func NewUploaderLight

func NewUploaderLight(clients []*node.Client) *Uploader

func (*Uploader) BatchUpload

func (uploader *Uploader) BatchUpload(datas []core.IterableData, option ...[]UploadOption) error

upload data(batchly in 1 blockchain transaction if there are more than one files)

func (*Uploader) Upload

func (uploader *Uploader) Upload(data core.IterableData, option ...UploadOption) error