lp2pimpl

Documentation

Index

• Constants
• type DealClient
  • func NewDealClient(h host.Host, addr address.Address, walletApi api.Wallet, ...) *DealClient
  • func (c *DealClient) SendDealProposal(ctx context.Context, id peer.ID, params types.DealParams) (*types.DealResponse, error)
  • func (c *DealClient) SendDealStatusRequest(ctx context.Context, id peer.ID, dealUUID uuid.UUID) (*types.DealStatusResponse, error)
• type DealClientOption
  • func RetryParameters(minDuration time.Duration, maxDuration time.Duration, attempts float64, ...) DealClientOption
• type DealProvider
  • func NewDealProvider(h host.Host, prov *storagemarket.Provider, fullNodeApi v1api.FullNode, ...) *DealProvider
  • func (p *DealProvider) Start(ctx context.Context)
  • func (p *DealProvider) Stop()

Constants

const DealProtocolv120ID = "/fil/storage/mk/1.2.0"

const DealProtocolv121ID = "/fil/storage/mk/1.2.1"

const DealStatusV12ProtocolID = "/fil/storage/status/1.2.0"

Types

type DealClient

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

DealClient sends deal proposals over libp2p

func NewDealClient

func NewDealClient(h host.Host, addr address.Address, walletApi api.Wallet, options ...DealClientOption) *DealClient

func (*DealClient) SendDealProposal

func (c *DealClient) SendDealProposal(ctx context.Context, id peer.ID, params types.DealParams) (*types.DealResponse, error)

SendDealProposal sends a deal proposal over a libp2p stream to the peer

func (*DealClient) SendDealStatusRequest

func (c *DealClient) SendDealStatusRequest(ctx context.Context, id peer.ID, dealUUID uuid.UUID) (*types.DealStatusResponse, error)

type DealClientOption

type DealClientOption func(*DealClient)

DealClientOption is an option for configuring the libp2p storage deal client

func RetryParameters

func RetryParameters(minDuration time.Duration, maxDuration time.Duration, attempts float64, backoffFactor float64) DealClientOption

RetryParameters changes the default parameters around connection reopening

type DealProvider

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

DealProvider listens for incoming deal proposals over libp2p

func NewDealProvider

func NewDealProvider(h host.Host, prov *storagemarket.Provider, fullNodeApi v1api.FullNode, plDB *db.ProposalLogsDB, spApi sealingpipeline.API) *DealProvider

func (*DealProvider) Start

func (p *DealProvider) Start(ctx context.Context)

func (*DealProvider) Stop

func (p *DealProvider) Stop()