tinder

package

v2.38.0 Latest Latest Go to latest Published: Apr 1, 2020 License: Apache-2.0, MIT Imports: 13 Imported by: 0

Details

View Source

const ScheduleKey = "Schedule"

This section is empty.

func Schedule(t time.Time) p2p_discovery.Option

Schedule advertise at the given time

type Driver interface {
	p2p_discovery.Discovery
	Unregisterer
}

Driver is a Discovery with a unregister method

func ComposeDriver(advertiser p2p_discovery.Advertiser, discover p2p_discovery.Discoverer, unregister Unregisterer) Driver

func NewDHTDriver(cr p2p_routing.ContentRouting) Driver

func NewMockedDriverClient(host p2p_host.Host, server *MockDriverServer) Driver

func NewMultiDriver(drivers ...Driver) Driver

func NewRendezvousDiscovery(host host.Host, rdvPeer peer.ID, rng *mrand.Rand) Driver

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

func NewMockedDriverServer() *MockDriverServer

func (s *MockDriverServer) Advertise(ns string, info p2p_peer.AddrInfo, ttl time.Duration) (time.Duration, error)

func (s *MockDriverServer) FindPeers(ns string, limit int) (<-chan p2p_peer.AddrInfo, error)

func (s *MockDriverServer) HasPeerRecord(ns string, pid p2p_peer.ID) bool

func (s *MockDriverServer) Reset()

func (s *MockDriverServer) Unregister(ns string, pid p2p_peer.ID)

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

MultiDriver is a simple driver manager, that forward request across multiple driver

func (md *MultiDriver) Advertise(ctx context.Context, ns string, opts ...p2p_discovery.Option) (time.Duration, error)

Advertise simply dispatch Advertise request across all the drivers

func (md *MultiDriver) FindPeers(ctx context.Context, ns string, opts ...p2p_discovery.Option) (<-chan p2p_peer.AddrInfo, error)

FindPeers for MultiDriver doesn't care about duplicate peers, his only job here is to dispatch FindPeers request across all the drivers.

func (md *MultiDriver) Unregister(ctx context.Context, ns string) error

type Service interface {
	Driver
}

Tinder service is a simple driver backed by a cache,

func NewService(drivers []Driver, stratFactory p2p_discovery.BackoffFactory, opts ...p2p_discovery.BackoffDiscoveryOption) (Service, error)

type Unregisterer interface {
	Unregister(ctx context.Context, ns string) error
}

var NoopUnregisterer Unregisterer = &noopUnregisterer{}