rendezvous

Sep 17, 2023

Changes in this version

+ const RegisterDefaultTTL

+ func ShardToNamespace(cluster uint16, shard uint16) string

type PeerConnector

+ Subscribe func(context.Context, <-chan peermanager.PeerData)

type Rendezvous

+ func (r *Rendezvous) Discover(ctx context.Context, rp *RendezvousPoint, numPeers int)

+ func (r *Rendezvous) DiscoverShard(ctx context.Context, rp *RendezvousPoint, cluster uint16, shard uint16, ...)

+ func (r *Rendezvous) DiscoverWithNamespace(ctx context.Context, namespace string, rp *RendezvousPoint, numPeers int)

+ func (r *Rendezvous) Register(ctx context.Context, rendezvousPoints []*RendezvousPoint)

+ func (r *Rendezvous) RegisterRelayShards(ctx context.Context, rs protocol.RelayShards, ...)

+ func (r *Rendezvous) RegisterShard(ctx context.Context, cluster uint16, shard uint16, ...)

+ func (r *Rendezvous) RegisterWithNamespace(ctx context.Context, namespace string, rendezvousPoints []*RendezvousPoint)

+ type RendezvousPoint struct

+ func NewRendezvousPoint(peerID peer.ID) *RendezvousPoint

+ func (rp *RendezvousPoint) Delay()

+ func (rp *RendezvousPoint) NextTry() time.Time

+ func (rp *RendezvousPoint) SetSuccess(cookie []byte)

+ type RendezvousPointIterator struct

+ func NewRendezvousPointIterator(rendezvousPoints []multiaddr.Multiaddr) *RendezvousPointIterator

+ func (r *RendezvousPointIterator) Next(ctx context.Context) <-chan *RendezvousPoint

+ func (r *RendezvousPointIterator) RendezvousPoints() []*RendezvousPoint

May 12, 2023

Changes in this version

type Rendezvous

+ func (r *Rendezvous) SetHost(h host.Host)

Mar 14, 2023

Changes in this version

+ const RendezvousID

+ type DB struct

+ func NewDB(ctx context.Context, db *sql.DB, logger *zap.Logger) *DB

+ func (db *DB) Close() error

+ func (db *DB) CountRegistrations(p peer.ID) (int, error)

+ func (db *DB) Discover(ns string, cookie []byte, limit int) ([]dbi.RegistrationRecord, []byte, error)

+ func (db *DB) Register(p peer.ID, ns string, addrs [][]byte, ttl int) (uint64, error)

+ func (db *DB) Start(ctx context.Context) error

+ func (db *DB) Unregister(p peer.ID, ns string) error

+ func (db *DB) ValidCookie(ns string, cookie []byte) bool

+ type PeerConnector interface

+ PeerChannel func() chan<- peer.AddrInfo

+ type Rendezvous struct

+ func NewRendezvous(host host.Host, db *DB, peerConnector PeerConnector, log *zap.Logger) *Rendezvous

+ func (r *Rendezvous) Start(ctx context.Context) error

+ func (r *Rendezvous) Stop()