lp2ptransports

Documentation

Index

• Constants
• Variables
• type Protocol
• type QueryResponse
• type TransportsClient
  • func NewTransportsClient(h host.Host) *TransportsClient
  • func (c *TransportsClient) SendQuery(ctx context.Context, id peer.ID) (*QueryResponse, error)

Constants

const TransportsProtocolID = protocol.ID("/fil/retrieval/transports/1.0.0")

TransportsProtocolID is the protocol for querying which retrieval transports the Storage Provider supports (http, libp2p, etc)

Variables

var BindnodeRegistry = bindnoderegistry.NewRegistry()

Types

type Protocol

type Protocol struct {
	// The name of the transport protocol eg "libp2p" or "http"
	Name string
	// The address of the endpoint in multiaddr format
	Addresses []multiaddr.Multiaddr
}

type QueryResponse

type QueryResponse struct {
	Protocols []Protocol
}

type TransportsClient

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

TransportsClient sends retrieval queries over libp2p

func NewTransportsClient

func NewTransportsClient(h host.Host) *TransportsClient

NewTransportsClient creates a new query over libp2p

func (*TransportsClient) SendQuery

func (c *TransportsClient) SendQuery(ctx context.Context, id peer.ID) (*QueryResponse, error)

SendQuery sends a retrieval query over a libp2p stream to the peer