discoveryimpl

package
v1.2.12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 8, 2021 License: Apache-2.0, MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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(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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL