discovery

Oct 30, 2019

Changes in this version

+ func FullJitter(duration, min, max time.Duration, rng *rand.Rand) time.Duration

+ func NewBackoffDiscovery(disc discovery.Discovery, stratFactory BackoffFactory, ...) (discovery.Discovery, error)

+ func NoJitter(duration, min, max time.Duration, rng *rand.Rand) time.Duration

+ 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 DiscoveryRouting struct

+ 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 Jitter func(duration, min, max time.Duration, rng *rand.Rand) time.Duration

Mar 2, 2019

Changes in this version

+ func Advertise(ctx context.Context, a Advertiser, ns string)

+ func FindPeers(ctx context.Context, d Discoverer, ns string, limit int) ([]pstore.PeerInfo, error)

+ type Advertiser interface

+ Advertise func(ctx context.Context, ns string, opts ...Option) (time.Duration, error)

+ type Discoverer interface

+ FindPeers func(ctx context.Context, ns string, opts ...Option) (<-chan pstore.PeerInfo, error)

+ type Discovery interface

+ type Option func(opts *Options) error

+ func Limit(limit int) Option

+ func TTL(ttl time.Duration) Option

+ type Options struct

+ Limit int

+ Other map[interface{}]interface{}

+ Ttl time.Duration

+ func (opts *Options) Apply(options ...Option) 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 pstore.PeerInfo, error)