deals

package

Go to main page

Versions in this module

v0

v0.1.6

Jan 8, 2020 GO-2022-0905

GO-2022-0905: BLS Signature "Malleability" in github.com/filecoin-project/lotus

v0.1.5

Dec 20, 2019 GO-2022-0905

GO-2022-0905: BLS Signature "Malleability" in github.com/filecoin-project/lotus

v0.1.1

Dec 12, 2019 GO-2022-0905

GO-2022-0905: BLS Signature "Malleability" in github.com/filecoin-project/lotus

v0.1.0

Dec 11, 2019 GO-2022-0905

GO-2022-0905: BLS Signature "Malleability" in github.com/filecoin-project/lotus

Changes in this version

+ const AskProtocolID

+ const DealProtocolID

+ var DataTransferStates = []api.DealState

+ var ErrDataTransferFailed = errors.New("deal data transfer failed")

+ var ErrInacceptableDealState = errors.New("deal is not a in a state where deals are accepted.")

+ var ErrNoDeal = errors.New("no deal found for this proposal.")

+ var ErrNoPullAccepted = errors.New("provider should not send data for a storage deal.")

+ var ErrNoPushAccepted = errors.New("client should not receive data for a storage deal.")

+ var ErrWrongPeer = errors.New("data Transfer peer id and Deal peer id do not match.")

+ var ErrWrongPiece = errors.New("base CID for deal does not match CID for piece.")

+ var ErrWrongVoucherType = errors.New("cannot validate voucher type.")

+ var ProviderDsPrefix = "/deals/provider"

+ type AskRequest struct

+ Miner address.Address

+ func (t *AskRequest) MarshalCBOR(w io.Writer) error

+ func (t *AskRequest) UnmarshalCBOR(r io.Reader) error

+ type AskResponse struct

+ Ask *types.SignedStorageAsk

+ func (t *AskResponse) MarshalCBOR(w io.Writer) error

+ func (t *AskResponse) UnmarshalCBOR(r io.Reader) error

+ type Client struct

+ func NewClient(sm *stmgr.StateManager, chain *store.ChainStore, h host.Host, w *wallet.Wallet, ...) *Client

+ func (c *Client) GetDeal(d cid.Cid) (*ClientDeal, error)

+ func (c *Client) List() ([]ClientDeal, error)

+ func (c *Client) QueryAsk(ctx context.Context, p peer.ID, a address.Address) (*types.SignedStorageAsk, error)

+ func (c *Client) Run(ctx context.Context)

+ func (c *Client) Start(ctx context.Context, p ClientDealProposal) (cid.Cid, error)

+ func (c *Client) Stop()

+ type ClientDeal struct

+ DealID uint64

+ Miner peer.ID

+ MinerWorker address.Address

+ Proposal actors.StorageDealProposal

+ ProposalCid cid.Cid

+ PublishMessage *types.SignedMessage

+ State api.DealState

+ func (t *ClientDeal) MarshalCBOR(w io.Writer) error

+ func (t *ClientDeal) UnmarshalCBOR(r io.Reader) error

+ type ClientDealProposal struct

+ Client address.Address

+ Data cid.Cid

+ Duration uint64

+ MinerID peer.ID

+ MinerWorker address.Address

+ PricePerEpoch types.BigInt

+ ProposalExpiration uint64

+ ProviderAddress address.Address

+ func (t *ClientDealProposal) MarshalCBOR(w io.Writer) error

+ func (t *ClientDealProposal) UnmarshalCBOR(r io.Reader) error

+ type ClientRequestValidator struct

+ func NewClientRequestValidator(deals dtypes.ClientDealStore) *ClientRequestValidator

+ func (c *ClientRequestValidator) ValidatePull(receiver peer.ID, voucher datatransfer.Voucher, baseCid cid.Cid, ...) error

+ func (c *ClientRequestValidator) ValidatePush(sender peer.ID, voucher datatransfer.Voucher, baseCid cid.Cid, ...) error

+ type MinerDeal struct

+ Client peer.ID

+ DealID uint64

+ Proposal actors.StorageDealProposal

+ ProposalCid cid.Cid

+ Ref cid.Cid

+ SectorID uint64

+ State api.DealState

+ func (t *MinerDeal) MarshalCBOR(w io.Writer) error

+ func (t *MinerDeal) UnmarshalCBOR(r io.Reader) error

+ type Proposal struct

+ DealProposal *actors.StorageDealProposal

+ Piece cid.Cid

+ func (t *Proposal) MarshalCBOR(w io.Writer) error

+ func (t *Proposal) UnmarshalCBOR(r io.Reader) error

+ type Provider struct

+ func NewProvider(ds dtypes.MetadataDS, sminer *storage.Miner, secb *sectorblocks.SectorBlocks, ...) (*Provider, error)

+ func (p *Provider) HandleAskStream(s inet.Stream)

+ func (p *Provider) HandleStream(s inet.Stream)

+ func (p *Provider) Run(ctx context.Context)

+ func (p *Provider) SetPrice(price types.BigInt, ttlsecs int64) error

+ func (p *Provider) Stop()

+ type ProviderRequestValidator struct

+ func NewProviderRequestValidator(deals dtypes.ProviderDealStore) *ProviderRequestValidator

+ func (m *ProviderRequestValidator) ValidatePull(receiver peer.ID, voucher datatransfer.Voucher, baseCid cid.Cid, ...) error

+ func (m *ProviderRequestValidator) ValidatePush(sender peer.ID, voucher datatransfer.Voucher, baseCid cid.Cid, ...) error

+ type Response struct

+ Message string

+ Proposal cid.Cid

+ State api.DealState

+ StorageDealSubmission *types.SignedMessage

+ func (t *Response) MarshalCBOR(w io.Writer) error

+ func (t *Response) UnmarshalCBOR(r io.Reader) error

+ type SignedResponse struct

+ Response Response

+ Signature *types.Signature

+ func (r *SignedResponse) Verify(addr address.Address) error

+ func (t *SignedResponse) MarshalCBOR(w io.Writer) error

+ func (t *SignedResponse) UnmarshalCBOR(r io.Reader) error

+ type StorageDataTransferVoucher struct

+ DealID uint64

+ Proposal cid.Cid

+ func (dv *StorageDataTransferVoucher) FromBytes(raw []byte) error

+ func (dv *StorageDataTransferVoucher) Identifier() string

+ func (dv *StorageDataTransferVoucher) ToBytes() ([]byte, error)

+ func (t *StorageDataTransferVoucher) MarshalCBOR(w io.Writer) error

+ func (t *StorageDataTransferVoucher) UnmarshalCBOR(r io.Reader) error

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