net

type Dialer interface {
	DialPipe() (Pipe, error)
}

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

type ListenConfig struct {
	Url       string // Note: We only use the [scheme]://[host] portion of this
	TlsConfig *tls.Config

	HttpServer     *http.Server // TODO - For Websockets only, maybe split up? - Note we have to wrap their Handler with our own handler!
	OriginPatterns []string
	IceServers     []string
	// contains filtered or unexported fields
}

type Listener interface {
	// Accept waits for and returns the next connection to the listener.
	Accept() (Socket, error)

	// Close closes the listener.
	// Any blocked Accept operations will be unblocked and return errors.
	Close() error

	// Addr returns the listener's network address.
	Addr() net.Addr
}

type Pipe interface {
	Read([]byte) (int, error)
	Write([]byte) (int, error)
	Close() error
}

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

type SimSocket struct {
	Socket

	Packetloss float64       // This is the probability that the packet will be lossed for every send/recv
	MinDelay   time.Duration // This is the min delay added to every packet sent or recved
	MaxDelay   time.Duration // This is the max delay added to every packet sent or recved
	// contains filtered or unexported fields
}

type Socket interface {
	Read([]byte) (int, error)
	Write([]byte) (int, error)

	Close() error

	Connected() bool
	Closed() bool

	// Reads and clears the number egress bytes
	ReadEgress() int64
	// Reads and clears the number ingress bytes
	ReadIngress() int64
}

type TcpDialer struct {
	Url string
}

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

type WebRtcDialer struct {
	Url               string
	TlsConfig         *tls.Config
	Ordered           bool
	IceServers        []string
	WebsocketFallback bool
}

type WebsocketDialer struct {
	Url       string
	TlsConfig *tls.Config
}

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