network

Documentation

Index

• type DealStream
  • func (d *DealStream) Close() error
  • func (d *DealStream) ReadDealPayment() (retrievalmarket.DealPayment, error)
  • func (d *DealStream) ReadDealProposal() (retrievalmarket.DealProposal, error)
  • func (d *DealStream) ReadDealResponse() (retrievalmarket.DealResponse, error)
  • func (d *DealStream) Receiver() peer.ID
  • func (d *DealStream) WriteDealPayment(dpy retrievalmarket.DealPayment) error
  • func (d *DealStream) WriteDealProposal(dp retrievalmarket.DealProposal) error
  • func (d *DealStream) WriteDealResponse(dr retrievalmarket.DealResponse) error
• type QueryStream
  • func (qs *QueryStream) Close() error
  • func (qs *QueryStream) ReadQuery() (retrievalmarket.Query, error)
  • func (qs *QueryStream) ReadQueryResponse() (retrievalmarket.QueryResponse, error)
  • func (qs *QueryStream) WriteQuery(q retrievalmarket.Query) error
  • func (qs *QueryStream) WriteQueryResponse(qr retrievalmarket.QueryResponse) error
• type RetrievalDealStream
• type RetrievalMarketNetwork
  • func NewFromLibp2pHost(h host.Host) RetrievalMarketNetwork
• type RetrievalQueryStream
• type RetrievalReceiver

Types

type DealStream

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

func (*DealStream) Close

func (d *DealStream) Close() error

func (*DealStream) ReadDealPayment

func (d *DealStream) ReadDealPayment() (retrievalmarket.DealPayment, error)

func (*DealStream) ReadDealProposal

func (d *DealStream) ReadDealProposal() (retrievalmarket.DealProposal, error)

func (*DealStream) ReadDealResponse

func (d *DealStream) ReadDealResponse() (retrievalmarket.DealResponse, error)

func (*DealStream) Receiver

func (d *DealStream) Receiver() peer.ID

func (*DealStream) WriteDealPayment

func (d *DealStream) WriteDealPayment(dpy retrievalmarket.DealPayment) error

func (*DealStream) WriteDealProposal

func (d *DealStream) WriteDealProposal(dp retrievalmarket.DealProposal) error

func (*DealStream) WriteDealResponse

func (d *DealStream) WriteDealResponse(dr retrievalmarket.DealResponse) error

type QueryStream

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

func (*QueryStream) Close

func (qs *QueryStream) Close() error

func (*QueryStream) ReadQuery

func (qs *QueryStream) ReadQuery() (retrievalmarket.Query, error)

func (*QueryStream) ReadQueryResponse

func (qs *QueryStream) ReadQueryResponse() (retrievalmarket.QueryResponse, error)

func (*QueryStream) WriteQuery

func (qs *QueryStream) WriteQuery(q retrievalmarket.Query) error

func (*QueryStream) WriteQueryResponse

func (qs *QueryStream) WriteQueryResponse(qr retrievalmarket.QueryResponse) error

type RetrievalDealStream

type RetrievalDealStream interface {
	ReadDealProposal() (retrievalmarket.DealProposal, error)
	WriteDealProposal(retrievalmarket.DealProposal) error
	ReadDealResponse() (retrievalmarket.DealResponse, error)
	WriteDealResponse(retrievalmarket.DealResponse) error
	ReadDealPayment() (retrievalmarket.DealPayment, error)
	WriteDealPayment(retrievalmarket.DealPayment) error
	Receiver() peer.ID
	Close() error
}

type RetrievalMarketNetwork

type RetrievalMarketNetwork interface {
	NewQueryStream(peer.ID) (RetrievalQueryStream, error)
	NewDealStream(peer.ID) (RetrievalDealStream, error)
	SetDelegate(RetrievalReceiver) error
	StopHandlingRequests() error
}

func NewFromLibp2pHost

func NewFromLibp2pHost(h host.Host) RetrievalMarketNetwork

type RetrievalQueryStream

type RetrievalQueryStream interface {
	ReadQuery() (retrievalmarket.Query, error)
	WriteQuery(retrievalmarket.Query) error
	ReadQueryResponse() (retrievalmarket.QueryResponse, error)
	WriteQueryResponse(retrievalmarket.QueryResponse) error
	Close() error
}

type RetrievalReceiver

type RetrievalReceiver interface {
	HandleQueryStream(RetrievalQueryStream)
	HandleDealStream(RetrievalDealStream)
}