node

type BackoffEnabler interface {
	IsBackoffEnabled(id warpnet.WarpPeerID) bool
	Reset(id warpnet.WarpPeerID)
}

type Blocklister interface {
	IsBlocklisted(peerId string) bool
}

type OfflineOutbox interface {
	Enqueue(nodeIdStr string, route stream.WarpRoute, payload []byte) error
	NotifyOnline(nodeIdStr string)
	Close()
}

type PeersRatings interface {
	ConnTag(peerID warpnet.WarpPeerID) int
}

type Prioritizer interface {
	SetPriority(pid warpnet.WarpPeerID, r warpnet.WarpReachability)
	SetRatingPriority(pid warpnet.WarpPeerID, tag int)
	SetMinPriority(pid warpnet.WarpPeerID)
	SetMaxPriority(pid warpnet.WarpPeerID)
}

type ReservationRefuser interface {
	RefuseReservation(dest, src warpnet.WarpPeerID) error
}

type StreamMiddleware func(next warpnet.WarpHandlerFunc) warpnet.WarpHandlerFunc

type Streamer interface {
	Send(peerAddr warpnet.WarpAddrInfo, r stream.WarpRoute, data []byte) ([]byte, error)
	SetStreamable(id warpnet.WarpPeerID)
	SetUnstreamable(id warpnet.WarpPeerID)
}

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