Versions in this module Expand all Collapse all v0 v0.1.1 Jan 11, 2022 Changes in this version + func DecodeNode(defnode *cbg.Deferred) (ipld.Node, error) + func TransportConfigurer(thisPeer peer.ID, storeGetter StoreGetter) datatransfer.TransportConfigurer + type Client struct + func (c *Client) Retrieve(ctx context.Context, root cid.Cid, params deal.Params, ...) (deal.ID, error) + func (c *Client) SubscribeToEvents(subscriber client.Subscriber) Unsubscribe + func (c *Client) TryRestartInsufficientFunds(chAddr address.Address) error + type Manager interface + Client func() *Client + Provider func() *Provider + func New(ctx context.Context, ms *multistore.MultiStore, ds datastore.Batching, ...) (Manager, error) + type OfferManager interface + GetOfferForCid func(cid.Cid) deal.Offer + SetOfferForCid func(cid.Cid, deal.Offer) error + type Provider struct + func (p *Provider) SubscribeToEvents(subscriber provider.Subscriber) Unsubscribe + type ProviderRequestValidator struct + func NewProviderRequestValidator(env ValidationEnvironment) *ProviderRequestValidator + func (rv *ProviderRequestValidator) ValidatePull(isRestart bool, chid datatransfer.ChannelID, receiver peer.ID, ...) (datatransfer.VoucherResult, error) + func (rv *ProviderRequestValidator) ValidatePush(isRestart bool, chid datatransfer.ChannelID, sender peer.ID, ...) (datatransfer.VoucherResult, error) + type ProviderRevalidator struct + func NewProviderRevalidator(env RevalidatorEnvironment) *ProviderRevalidator + func (pr *ProviderRevalidator) OnComplete(chid datatransfer.ChannelID) (bool, datatransfer.VoucherResult, error) + func (pr *ProviderRevalidator) OnPullDataSent(chid datatransfer.ChannelID, additionalBytesSent uint64) (bool, datatransfer.VoucherResult, error) + func (pr *ProviderRevalidator) OnPushDataReceived(chid datatransfer.ChannelID, additionalBytesReceived uint64) (bool, datatransfer.VoucherResult, error) + func (pr *ProviderRevalidator) Revalidate(channelID datatransfer.ChannelID, voucher datatransfer.Voucher) (datatransfer.VoucherResult, error) + func (pr *ProviderRevalidator) TrackChannel(d deal.ProviderState) + func (pr *ProviderRevalidator) UntrackChannel(d deal.ProviderState) + type Retrieval struct + func (r *Retrieval) Client() *Client + func (r *Retrieval) Provider() *Provider + type RevalidatorEnvironment interface + Get func(dealID deal.ProviderDealIdentifier) (deal.ProviderState, error) + Payments func() payments.Manager + SendEvent func(dealID deal.ProviderDealIdentifier, evt provider.Event, args ...interface{}) error + type StoreConfigurableTransport interface + UseStore func(datatransfer.ChannelID, ipld.LinkSystem) error + type StoreGetter interface + Get func(otherPeer peer.ID, dealID deal.ID) (*multistore.Store, error) + type StoreIDGetter interface + GetStoreID func(cid.Cid) (multistore.StoreID, error) + type Unsubscribe func() + type ValidationEnvironment interface + BeginTracking func(pds deal.ProviderState) error + CheckDealParams func(deal.ProviderState) error + GetStoreID func(cid.Cid) (multistore.StoreID, error) + NextStoreID func() (multistore.StoreID, error)
Go to main page