node

type DiscoveryHandler interface {
	DiscoveryHandlerStream(pi warpnet.WarpAddrInfo)
	Run(n discovery.DiscoveryInfoStorer) error
	Event() <-chan warpnet.PeerEvent
	Close()
}

type DistributedHashTableCloser interface {
	FindProvidersAsync(ctx context.Context, key warpnet.WarpCID, count int) (ch <-chan warpnet.WarpAddrInfo)
	Close()
}

type PeerRater interface {
	Listen(sources ...<-chan warpnet.PeerEvent)
	View(peerID warpnet.WarpPeerID) (domain.NodeRating, error)
	Own() (domain.NodeRating, error)
	Close() error
}

type PeersRatings interface {
	Rate(peerID warpnet.WarpPeerID, tier rating.Tier)
	ConnTag(peerID warpnet.WarpPeerID) int
	GossipScore(peerID warpnet.WarpPeerID) float64
	RateMultiplier(peerID warpnet.WarpPeerID) float64
	IsAllowedInDHT(peerID warpnet.WarpPeerID) bool
}

type PubSubProvider interface {
	Run(m pubsub.PubsubServerNodeConnector)
	Gossip() *corePubsub.Gossip
	Close() error
	OwnerID() string
}

type RatingProvider interface {
	Get(ctx context.Context, key ds.Key) ([]byte, error)
	Has(ctx context.Context, key ds.Key) (bool, error)
	GetSize(ctx context.Context, key ds.Key) (int, error)
	Query(ctx context.Context, q ds.Query) (ds.Results, error)
	Put(ctx context.Context, key ds.Key, value []byte) error
	Delete(ctx context.Context, key ds.Key) error
	Sync(ctx context.Context, prefix ds.Key) error
	Close() error
}

type RatingStorer interface {
	Put(rec domain.RatingRecord) error
	List(peerID string) ([]domain.RatingRecord, error)
	PeerIDs() ([]string, error)
	DeleteExpired(dimension string, beforeBucket int64) error
	OnPut(hook func(domain.RatingRecord))
	OnDelete(hook func(domain.RatingRecord))
	Close() error
}

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