package routing

import "github.com/libp2p/go-libp2p/p2p/discovery/routing"

Index ¶

• type DiscoveryRouting
• func NewDiscoveryRouting(disc discovery.Discovery, opts ...discovery.Option) *DiscoveryRouting
• func (r *DiscoveryRouting) FindProvidersAsync(ctx context.Context, c cid.Cid, limit int) <-chan peer.AddrInfo
• func (r *DiscoveryRouting) Provide(ctx context.Context, c cid.Cid, bcast bool) error
• type RoutingDiscovery
• func NewRoutingDiscovery(router routing.ContentRouting) *RoutingDiscovery
• func (d *RoutingDiscovery) Advertise(ctx context.Context, ns string, opts ...discovery.Option) (time.Duration, error)
• func (d *RoutingDiscovery) FindPeers(ctx context.Context, ns string, opts ...discovery.Option) (<-chan peer.AddrInfo, error)

Types ¶

type DiscoveryRouting ¶

type DiscoveryRouting struct {
	discovery.Discovery
	// contains filtered or unexported fields
}

func NewDiscoveryRouting ¶

func NewDiscoveryRouting(disc discovery.Discovery, opts ...discovery.Option) *DiscoveryRouting

func (*DiscoveryRouting) FindProvidersAsync ¶

func (r *DiscoveryRouting) FindProvidersAsync(ctx context.Context, c cid.Cid, limit int) <-chan peer.AddrInfo

func (*DiscoveryRouting) Provide ¶

func (r *DiscoveryRouting) Provide(ctx context.Context, c cid.Cid, bcast bool) error

type RoutingDiscovery ¶

type RoutingDiscovery struct {
	routing.ContentRouting
}

RoutingDiscovery is an implementation of discovery using ContentRouting. Namespaces are translated to Cids using the SHA256 hash.

func NewRoutingDiscovery ¶

func NewRoutingDiscovery(router routing.ContentRouting) *RoutingDiscovery

func (*RoutingDiscovery) Advertise ¶

func (d *RoutingDiscovery) Advertise(ctx context.Context, ns string, opts ...discovery.Option) (time.Duration, error)

func (*RoutingDiscovery) FindPeers ¶

func (d *RoutingDiscovery) FindPeers(ctx context.Context, ns string, opts ...discovery.Option) (<-chan peer.AddrInfo, error)

Source Files ¶

routing.go