streamer

package
v0.0.0-...-bab7392 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 24, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ResolveAndConnect

func ResolveAndConnect(mesh *mesh.Mesh, target string) (*peer.AddrInfo, error)

Types

type Streamer

type Streamer struct {
	Context   context.Context
	RequestId []byte
	LocalNode host.Host

	OutData      []byte
	ActiveStream network.Stream
	TargetAddr   peer.AddrInfo

	//	DoneInDataChan chan uint32
	InData []byte
}

func (*Streamer) AddStream

func (rc *Streamer) AddStream(current *wire.Packet, stream network.Stream)

func (*Streamer) ReceiveData

func (rc *Streamer) ReceiveData() error

func (*Streamer) SendData

func (rc *Streamer) SendData() error

Jump to

Keyboard shortcuts

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