client

package
v0.0.0-...-0d2a5dc Latest Latest
Warning

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

Go to latest
Published: Oct 7, 2020 License: Apache-2.0, MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Market

type Market struct {
	ClientStartDeal           func(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)
	ClientListDeals           func(ctx context.Context) ([]api.DealInfo, error)
	ClientGetDealInfo         func(ctx context.Context, d cid.Cid) (*api.DealInfo, error)
	ClientHasLocal            func(ctx context.Context, root cid.Cid) (bool, error)
	ClientFindData            func(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)
	ClientMinerQueryOffer     func(ctx context.Context, miner address.Address, root cid.Cid, piece *cid.Cid) (api.QueryOffer, error)
	ClientImport              func(ctx context.Context, ref api.FileRef) (*api.ImportRes, error)
	ClientRemoveImport        func(ctx context.Context, importID int) error
	ClientImportLocal         func(ctx context.Context, f io.Reader) (cid.Cid, error)
	ClientListImports         func(ctx context.Context) ([]api.Import, error)
	ClientRetrieve            func(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error
	ClientQueryAsk            func(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.SignedStorageAsk, error)
	ClientCalcCommP           func(ctx context.Context, inpath string, miner address.Address) (*api.CommPRet, error)
	ClientGenCar              func(ctx context.Context, ref api.FileRef, outputPath string) error
	ClientListDataTransfers   func(ctx context.Context) ([]api.DataTransferChannel, error)
	ClientDataTransferUpdates func(ctx context.Context) (<-chan api.DataTransferChannel, error)
}

func GetMarketAPI

func GetMarketAPI(ctx *cli.Context) (*Market, jsonrpc.ClientCloser, error)

func NewMarketClient

func NewMarketClient(addr string, requestHeader http.Header) (*Market, jsonrpc.ClientCloser, error)

type Miner

type Miner struct {
	SectorsStatus      func(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)
	SectorsList        func(context.Context) ([]abi.SectorNumber, error)
	SectorStartSealing func(context.Context, abi.SectorNumber) error
}

func GetMinerAPI

func GetMinerAPI(ctx *cli.Context) (*Miner, jsonrpc.ClientCloser, error)

func NewMinerClient

func NewMinerClient(addr string, requestHeader http.Header) (*Miner, jsonrpc.ClientCloser, error)

type RepoType

type RepoType int

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL