stream

package

v0.2.511 Latest Latest Go to latest Published: May 27, 2025 License: GPL-2.0, GPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Warp-net/warpnet

Links

Open Source Insights

Documentation ¶

Index ¶

func IsValidRoute(route WarpRoute) bool
func NewStreamPool(ctx context.Context, n NodeStreamer) *streamPool
type NodeStreamer
type WarpRoute
- func FromPrIDToRoute(prID warpnet.WarpProtocolID) WarpRoute
type WarpRoutes
- func FromProtocolIDToRoutes(prIDs []warpnet.WarpProtocolID) WarpRoutes
- func (rs WarpRoutes) FromRoutesToPrIDs() []warpnet.WarpProtocolID

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func IsValidRoute ¶

func IsValidRoute(route WarpRoute) bool

func NewStreamPool ¶

func NewStreamPool(
	ctx context.Context,
	n NodeStreamer,
) *streamPool

Types ¶

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) IsGet ¶

func (r WarpRoute) IsGet() bool

func (WarpRoute) IsPrivate ¶

func (r WarpRoute) IsPrivate() bool

func (WarpRoute) ProtocolID ¶

func (r WarpRoute) ProtocolID() warpnet.WarpProtocolID

func (WarpRoute) String ¶

func (r WarpRoute) String() string

type WarpRoutes ¶

type WarpRoutes []WarpRoute

func FromProtocolIDToRoutes ¶

func FromProtocolIDToRoutes(prIDs []warpnet.WarpProtocolID) WarpRoutes

func (WarpRoutes) FromRoutesToPrIDs ¶

func (rs WarpRoutes) FromRoutesToPrIDs() []warpnet.WarpProtocolID

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL