stream

package

v1.0.0 Latest Latest Go to latest Published: Jul 20, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 23 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 NewLoopbackStream(nodeId warpnet.WarpPeerID, proto warpnet.WarpProtocolID) (r warpnet.WarpStream, w warpnet.WarpStream)
func NewStreamPool(ctx context.Context, n NodeStreamer) (*streamPool, error)
type LoopbackConn
type LoopbackStream
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 NewLoopbackStream ¶ added in v0.3.118

func NewLoopbackStream(
	nodeId warpnet.WarpPeerID, proto warpnet.WarpProtocolID,
) (r warpnet.WarpStream, w warpnet.WarpStream)

func NewStreamPool ¶

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

Types ¶

type LoopbackConn ¶ added in v0.3.115

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

func (*LoopbackConn) Close ¶ added in v0.3.115

func (c *LoopbackConn) Close() error

func (*LoopbackConn) CloseWithError ¶ added in v0.3.115

func (c *LoopbackConn) CloseWithError(_ network.ConnErrorCode) error

func (*LoopbackConn) ConnState ¶ added in v0.3.115

func (c *LoopbackConn) ConnState() network.ConnectionState

func (*LoopbackConn) GetStreams ¶ added in v0.3.115

func (c *LoopbackConn) GetStreams() []network.Stream

func (*LoopbackConn) ID ¶ added in v0.3.115

func (c *LoopbackConn) ID() string

func (*LoopbackConn) IsClosed ¶ added in v0.3.115

func (c *LoopbackConn) IsClosed() bool

func (*LoopbackConn) LocalMultiaddr ¶ added in v0.3.115

func (c *LoopbackConn) LocalMultiaddr() multiaddr.Multiaddr

func (*LoopbackConn) LocalPeer ¶ added in v0.3.115

func (c *LoopbackConn) LocalPeer() peer.ID

func (*LoopbackConn) NewStream ¶ added in v0.3.115

func (c *LoopbackConn) NewStream(_ context.Context) (network.Stream, error)

func (*LoopbackConn) RemoteMultiaddr ¶ added in v0.3.115

func (c *LoopbackConn) RemoteMultiaddr() multiaddr.Multiaddr

func (*LoopbackConn) RemotePeer ¶ added in v0.3.115

func (c *LoopbackConn) RemotePeer() peer.ID

func (*LoopbackConn) RemotePublicKey ¶ added in v0.3.115

func (c *LoopbackConn) RemotePublicKey() p2pCrypto.PubKey

func (*LoopbackConn) Scope ¶ added in v0.3.115

func (c *LoopbackConn) Scope() network.ConnScope

func (*LoopbackConn) Stat ¶ added in v0.3.115

func (c *LoopbackConn) Stat() network.ConnStats

type LoopbackStream ¶ added in v0.3.115

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

func (*LoopbackStream) Close ¶ added in v0.3.115

func (s *LoopbackStream) Close() error

func (*LoopbackStream) CloseRead ¶ added in v0.3.115

func (s *LoopbackStream) CloseRead() error

func (*LoopbackStream) CloseWrite ¶ added in v0.3.115

func (s *LoopbackStream) CloseWrite() error

func (*LoopbackStream) Conn ¶ added in v0.3.115

func (s *LoopbackStream) Conn() network.Conn

func (*LoopbackStream) ID ¶ added in v0.3.115

func (s *LoopbackStream) ID() string

func (*LoopbackStream) Protocol ¶ added in v0.3.115

func (s *LoopbackStream) Protocol() protocol.ID

func (*LoopbackStream) Read ¶ added in v0.3.115

func (s *LoopbackStream) Read(p []byte) (int, error)

func (*LoopbackStream) Reset ¶ added in v0.3.115

func (s *LoopbackStream) Reset() error

func (*LoopbackStream) ResetWithError ¶ added in v0.3.115

func (s *LoopbackStream) ResetWithError(err network.StreamErrorCode) error

func (*LoopbackStream) Scope ¶ added in v0.3.115

func (s *LoopbackStream) Scope() network.StreamScope

func (*LoopbackStream) SetDeadline ¶ added in v0.3.115

func (s *LoopbackStream) SetDeadline(t time.Time) error

func (*LoopbackStream) SetProtocol ¶ added in v0.3.115

func (s *LoopbackStream) SetProtocol(p protocol.ID) error

func (*LoopbackStream) SetReadDeadline ¶ added in v0.3.115

func (s *LoopbackStream) SetReadDeadline(t time.Time) error

func (*LoopbackStream) SetWriteDeadline ¶ added in v0.3.115

func (s *LoopbackStream) SetWriteDeadline(t time.Time) error

func (*LoopbackStream) Stat ¶ added in v0.3.115

func (s *LoopbackStream) Stat() network.Stats

func (*LoopbackStream) Write ¶ added in v0.3.115

func (s *LoopbackStream) Write(p []byte) (int, error)

type NodeStreamer ¶

type NodeStreamer interface {
	NewStream(ctx context.Context, p warpnet.WarpPeerID, pids ...warpnet.WarpProtocolID) (warpnet.WarpStream, error)
	Network() network.Network
	ID() warpnet.WarpPeerID
}

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