rendezvous

Documentation

Index

• Constants
• type DB
  • 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
• type Rendezvous
  • 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()

Constants

const RendezvousID = rvs.RendezvousProto

Types

type DB

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

func NewDB

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

func (*DB) Close

func (db *DB) Close() error

func (*DB) CountRegistrations

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

func (*DB) Discover

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

func (*DB) Register

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

func (*DB) Start

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

func (*DB) Unregister

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

func (*DB) ValidCookie

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

type PeerConnector

type PeerConnector interface {
	PeerChannel() chan<- peer.AddrInfo
}

type Rendezvous

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

func NewRendezvous

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

func (*Rendezvous) Start

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

func (*Rendezvous) Stop

func (r *Rendezvous) Stop()