Versions in this module Expand all Collapse all v0 v0.0.2-rc1 Jan 27, 2020 v0.0.1 Jan 24, 2020 Changes in this version + func Advertise(ctx context.Context, a Advertiser, ns string, opts ...Option) + func FindPeers(ctx context.Context, d Discoverer, ns string, opts ...Option) ([]peer.AddrInfo, error) + func FullJitter(duration, min, max time.Duration, rng *rand.Rand) time.Duration + func Limit(limit int) core.Option + func NewBackoffDiscovery(disc discovery.Discovery, stratFactory BackoffFactory, ...) (discovery.Discovery, error) + func NoJitter(duration, min, max time.Duration, rng *rand.Rand) time.Duration + func TTL(ttl time.Duration) core.Option + type Advertiser = core.Advertiser + type BackoffConnector struct + func NewBackoffConnector(h host.Host, cacheSize int, connectionTryDuration time.Duration, ...) (*BackoffConnector, error) + func (c *BackoffConnector) Connect(ctx context.Context, peerCh <-chan peer.AddrInfo) + type BackoffDiscovery struct + func (d *BackoffDiscovery) Advertise(ctx context.Context, ns string, opts ...discovery.Option) (time.Duration, error) + func (d *BackoffDiscovery) FindPeers(ctx context.Context, ns string, opts ...discovery.Option) (<-chan peer.AddrInfo, error) + type BackoffDiscoveryOption func(*BackoffDiscovery) error + func WithBackoffDiscoveryReturnedChannelSize(size int) BackoffDiscoveryOption + func WithBackoffDiscoverySimultaneousQueryBufferSize(size int) BackoffDiscoveryOption + type BackoffFactory func() BackoffStrategy + func NewExponentialBackoff(min, max time.Duration, jitter Jitter, timeUnits time.Duration, base float64, ...) BackoffFactory + func NewExponentialDecorrelatedJitter(min, max time.Duration, base float64, rng *rand.Rand) BackoffFactory + func NewFixedBackoff(delay time.Duration) BackoffFactory + func NewPolynomialBackoff(min, max time.Duration, jitter Jitter, timeUnits time.Duration, ...) BackoffFactory + type BackoffStrategy interface + Delay func() time.Duration + Reset func() + type Discoverer = core.Discoverer + type Discovery = core.Discovery + type Jitter func(duration, min, max time.Duration, rng *rand.Rand) time.Duration + type Option = core.Option + type Options = core.Options + type Routing struct + func NewDiscoveryRouting(disc discovery.Discovery, opts ...discovery.Option) *Routing + func (r *Routing) FindProvidersAsync(ctx context.Context, c cid.Cid, limit int) <-chan peer.AddrInfo + func (r *Routing) Provide(ctx context.Context, c cid.Cid, bcast bool) error + type RoutingDiscovery struct + func NewRoutingDiscovery(router routing.ContentRouting) *RoutingDiscovery + func (d *RoutingDiscovery) Advertise(ctx context.Context, ns string, opts ...Option) (time.Duration, error) + func (d *RoutingDiscovery) FindPeers(ctx context.Context, ns string, opts ...Option) (<-chan peer.AddrInfo, error)