discoveryimpl

Documentation

Index

• func Multi(r discovery.PeerResolver) discovery.PeerResolver
• type Local
  • func NewLocal(ds datastore.Batching) (*Local, error)
  • func (l *Local) AddPeer(ctx context.Context, cid cid.Cid, peer retrievalmarket.RetrievalPeer) error
  • func (l *Local) GetPeers(payloadCID cid.Cid) ([]retrievalmarket.RetrievalPeer, error)
  • func (l *Local) OnReady(ready shared.ReadyFunc)
  • func (l *Local) Start(ctx context.Context) error

Functions

func Multi

func Multi(r discovery.PeerResolver) discovery.PeerResolver

Types

type Local

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

func NewLocal

func NewLocal(ds datastore.Batching) (*Local, error)

func (*Local) AddPeer

func (l *Local) AddPeer(ctx context.Context, cid cid.Cid, peer retrievalmarket.RetrievalPeer) error

func (*Local) GetPeers

func (l *Local) GetPeers(payloadCID cid.Cid) ([]retrievalmarket.RetrievalPeer, error)

func (*Local) OnReady

func (l *Local) OnReady(ready shared.ReadyFunc)

OnReady registers a listener for when the retrieval peers list has finished starting up

func (*Local) Start

func (l *Local) Start(ctx context.Context) error