lotusrepo

Documentation

Index

• type APIOpener
  • func NewAPIOpener(c *cli.Context) (*APIOpener, lens.APICloser, error)
  • func (o *APIOpener) Daemonized() bool
  • func (o *APIOpener) Open(ctx context.Context) (lens.API, lens.APICloser, error)
• type RepoAPI
  • func (ra *RepoAPI) ChainGetTipSetAfterHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, error)
  • func (ra *RepoAPI) ClientCalcCommP(ctx context.Context, inpath string) (*api.CommPRet, error)
  • func (ra *RepoAPI) ClientDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)
  • func (ra *RepoAPI) ClientDealSize(ctx context.Context, root cid.Cid) (api.DataSize, error)
  • func (ra *RepoAPI) ClientFindData(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)
  • func (ra *RepoAPI) ClientGenCar(ctx context.Context, ref api.FileRef, outputPath string) error
  • func (ra *RepoAPI) ClientGetDealInfo(ctx context.Context, d cid.Cid) (*api.DealInfo, error)
  • func (ra *RepoAPI) ClientGetDealUpdates(ctx context.Context) (<-chan api.DealInfo, error)
  • func (ra *RepoAPI) ClientHasLocal(ctx context.Context, root cid.Cid) (bool, error)
  • func (ra *RepoAPI) ClientImport(ctx context.Context, ref api.FileRef) (*api.ImportRes, error)
  • func (ra *RepoAPI) ClientImportLocal(ctx context.Context, f io.Reader) (cid.Cid, error)
  • func (ra *RepoAPI) ClientListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)
  • func (ra *RepoAPI) ClientListDeals(ctx context.Context) ([]api.DealInfo, error)
  • func (ra *RepoAPI) ClientListImports(ctx context.Context) ([]api.Import, error)
  • func (ra *RepoAPI) ClientMinerQueryOffer(ctx context.Context, miner address.Address, root cid.Cid, piece *cid.Cid) (api.QueryOffer, error)
  • func (ra *RepoAPI) ClientQueryAsk(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.StorageAsk, error)
  • func (ra *RepoAPI) ClientRemoveImport(ctx context.Context, importID multistore.StoreID) error
  • func (ra *RepoAPI) ClientRetrieve(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error
  • func (ra *RepoAPI) ClientRetrieveTryRestartInsufficientFunds(ctx context.Context, paymentChannel address.Address) error
  • func (ra *RepoAPI) ClientRetrieveWithEvents(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error)
  • func (ra *RepoAPI) ClientStartDeal(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)
  • func (ra *RepoAPI) GetExecutedAndBlockMessagesForTipset(ctx context.Context, ts, pts *types.TipSet) (*lens.TipSetMessages, error)
  • func (ra *RepoAPI) GetMessageExecutionsForTipSet(ctx context.Context, ts, pts *types.TipSet) ([]*lens.MessageExecution, error)
  • func (ra *RepoAPI) StateGetReceipt(ctx context.Context, msg cid.Cid, from types.TipSetKey) (*types.MessageReceipt, error)
  • func (ra *RepoAPI) Store() adt.Store

Types

type APIOpener

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

func NewAPIOpener

func NewAPIOpener(c *cli.Context) (*APIOpener, lens.APICloser, error)

func (*APIOpener) Daemonized

func (o *APIOpener) Daemonized() bool

func (*APIOpener) Open

func (o *APIOpener) Open(ctx context.Context) (lens.API, lens.APICloser, error)

type RepoAPI

type RepoAPI struct {
	impl.FullNodeAPI
	context.Context
	// contains filtered or unexported fields
}

func (*RepoAPI) ChainGetTipSetAfterHeight

func (ra *RepoAPI) ChainGetTipSetAfterHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, error)

func (*RepoAPI) ClientCalcCommP

func (ra *RepoAPI) ClientCalcCommP(ctx context.Context, inpath string) (*api.CommPRet, error)

func (*RepoAPI) ClientDataTransferUpdates

func (ra *RepoAPI) ClientDataTransferUpdates(ctx context.Context) (<-chan api.DataTransferChannel, error)

func (*RepoAPI) ClientDealSize

func (ra *RepoAPI) ClientDealSize(ctx context.Context, root cid.Cid) (api.DataSize, error)

func (*RepoAPI) ClientFindData

func (ra *RepoAPI) ClientFindData(ctx context.Context, root cid.Cid, piece *cid.Cid) ([]api.QueryOffer, error)

func (*RepoAPI) ClientGenCar

func (ra *RepoAPI) ClientGenCar(ctx context.Context, ref api.FileRef, outputPath string) error

func (*RepoAPI) ClientGetDealInfo

func (ra *RepoAPI) ClientGetDealInfo(ctx context.Context, d cid.Cid) (*api.DealInfo, error)

func (*RepoAPI) ClientGetDealUpdates

func (ra *RepoAPI) ClientGetDealUpdates(ctx context.Context) (<-chan api.DealInfo, error)

func (*RepoAPI) ClientHasLocal

func (ra *RepoAPI) ClientHasLocal(ctx context.Context, root cid.Cid) (bool, error)

func (*RepoAPI) ClientImport

func (ra *RepoAPI) ClientImport(ctx context.Context, ref api.FileRef) (*api.ImportRes, error)

func (*RepoAPI) ClientImportLocal

func (ra *RepoAPI) ClientImportLocal(ctx context.Context, f io.Reader) (cid.Cid, error)

func (*RepoAPI) ClientListDataTransfers

func (ra *RepoAPI) ClientListDataTransfers(ctx context.Context) ([]api.DataTransferChannel, error)

func (*RepoAPI) ClientListDeals

func (ra *RepoAPI) ClientListDeals(ctx context.Context) ([]api.DealInfo, error)

func (*RepoAPI) ClientListImports

func (ra *RepoAPI) ClientListImports(ctx context.Context) ([]api.Import, error)

func (*RepoAPI) ClientMinerQueryOffer

func (ra *RepoAPI) ClientMinerQueryOffer(ctx context.Context, miner address.Address, root cid.Cid, piece *cid.Cid) (api.QueryOffer, error)

func (*RepoAPI) ClientQueryAsk

func (ra *RepoAPI) ClientQueryAsk(ctx context.Context, p peer.ID, miner address.Address) (*storagemarket.StorageAsk, error)

func (*RepoAPI) ClientRemoveImport

func (ra *RepoAPI) ClientRemoveImport(ctx context.Context, importID multistore.StoreID) error

func (*RepoAPI) ClientRetrieve

func (ra *RepoAPI) ClientRetrieve(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) error

func (*RepoAPI) ClientRetrieveTryRestartInsufficientFunds

func (ra *RepoAPI) ClientRetrieveTryRestartInsufficientFunds(ctx context.Context, paymentChannel address.Address) error

func (*RepoAPI) ClientRetrieveWithEvents

func (ra *RepoAPI) ClientRetrieveWithEvents(ctx context.Context, order api.RetrievalOrder, ref *api.FileRef) (<-chan marketevents.RetrievalEvent, error)

func (*RepoAPI) ClientStartDeal

func (ra *RepoAPI) ClientStartDeal(ctx context.Context, params *api.StartDealParams) (*cid.Cid, error)

func (*RepoAPI) GetExecutedAndBlockMessagesForTipset

func (ra *RepoAPI) GetExecutedAndBlockMessagesForTipset(ctx context.Context, ts, pts *types.TipSet) (*lens.TipSetMessages, error)

func (*RepoAPI) GetMessageExecutionsForTipSet

func (ra *RepoAPI) GetMessageExecutionsForTipSet(ctx context.Context, ts, pts *types.TipSet) ([]*lens.MessageExecution, error)

func (*RepoAPI) StateGetReceipt

func (ra *RepoAPI) StateGetReceipt(ctx context.Context, msg cid.Cid, from types.TipSetKey) (*types.MessageReceipt, error)

func (*RepoAPI) Store

func (ra *RepoAPI) Store() adt.Store