libp2p

Documentation

Index

• Constants
• func MakeAddrsFactory(announceAddrs []multiaddr.Multiaddr) (basichost.AddrsFactory, error)
• func NewDealProvider(ctx context.Context, db *harmonydb.DB, cfg *config.CurioConfig, ...)
• func Router(mux *chi.Mux, rp *Redirector)
• func SafeHandle(h network.StreamHandler) network.StreamHandler
• type DealProvider
  • func (p *DealProvider) Start(ctx context.Context, host host.Host)
• type PublicAddrs
  • func NewLibp2pHost(ctx context.Context, db *harmonydb.DB, cfg *config.CurioConfig, machine string) (host.Host, *PublicAddrs, error)
• type Redirector
  • func NewRedirector(db *harmonydb.DB) *Redirector

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"

const TransportsProtocolID = "/fil/retrieval/transports/1.0.0"

Functions

func MakeAddrsFactory

func MakeAddrsFactory(announceAddrs []multiaddr.Multiaddr) (basichost.AddrsFactory, error)

func NewDealProvider

func NewDealProvider(ctx context.Context, db *harmonydb.DB, cfg *config.CurioConfig, prov *mk12.MK12, api mk12libp2pAPI, sender *message.Sender, miners []address.Address, machine string, shutdownChan chan struct{})

func Router

func Router(mux *chi.Mux, rp *Redirector)

Router sets up the route for the WebSocket connection

func SafeHandle

func SafeHandle(h network.StreamHandler) network.StreamHandler

Types

type DealProvider

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

DealProvider listens for incoming deal proposals over libp2p

func (*DealProvider) Start

func (p *DealProvider) Start(ctx context.Context, host host.Host)

type PublicAddrs

type PublicAddrs struct {
	Libp2pAddr multiaddr.Multiaddr
	HttpAddr   multiaddr.Multiaddr
}

func NewLibp2pHost

func NewLibp2pHost(ctx context.Context, db *harmonydb.DB, cfg *config.CurioConfig, machine string) (host.Host, *PublicAddrs, error)

type Redirector

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

Redirector struct with a database connection

func NewRedirector

func NewRedirector(db *harmonydb.DB) *Redirector

NewRedirector creates a new Redirector with a database connection