libp2p

package

v1.0.0 Latest Latest Go to latest Published: Jan 28, 2026 License: MIT Imports: 8 Imported by: 3

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type Libp2pConnector struct {
	Host          host.Host
	ServerAddress *multiaddr.Multiaddr
	Peer          *peer.AddrInfo
}

func NewLibp2pConnector(serverAddress string, opts ...libp2p.Option) (*Libp2pConnector, error)

func (lc *Libp2pConnector) Connect(ctx context.Context) error

func (lc *Libp2pConnector) Disconnect() error

func (lc *Libp2pConnector) OpenStream(ctx context.Context, protocolID string) (types.Stream, error)

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

func New(stream network.Stream, ctx context.Context) *Libp2pStream

func (ls *Libp2pStream) Close() error

func (ls *Libp2pStream) Context() context.Context

func (ls *Libp2pStream) Read(msg []byte) (int, error)

func (ls *Libp2pStream) Write(msg []byte) (int, error)