Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsValidRoute ¶
func NewStreamPool ¶
func NewStreamPool( ctx context.Context, n NodeStreamer, mastodonPseudoNode MastodonPseudoStreamer, ) *streamPool
Types ¶
type MastodonPseudoStreamer ¶ added in v0.3.21
type MastodonPseudoStreamer interface {
ID() warpnet.WarpPeerID
IsMastodonID(id warpnet.WarpPeerID) bool
Addrs() []warpnet.WarpAddress
Route(r WarpRoute, data []byte) (_ []byte, err error)
}
type NodeStreamer ¶
type NodeStreamer interface {
NewStream(ctx context.Context, p warpnet.WarpPeerID, pids ...warpnet.WarpProtocolID) (warpnet.WarpStream, error)
Network() network.Network
}
type WarpRoute ¶
type WarpRoute string
func FromPrIDToRoute ¶
func FromPrIDToRoute(prID warpnet.WarpProtocolID) WarpRoute
func (WarpRoute) ProtocolID ¶
func (r WarpRoute) ProtocolID() warpnet.WarpProtocolID
type WarpRoutes ¶
type WarpRoutes []WarpRoute
func FromProtocolIDToRoutes ¶
func FromProtocolIDToRoutes(prIDs []warpnet.WarpProtocolID) WarpRoutes
func (WarpRoutes) FromRoutesToPrIDs ¶
func (rs WarpRoutes) FromRoutesToPrIDs() []warpnet.WarpProtocolID
Source Files
Click to show internal directories.
Click to hide internal directories.