endpoint

May 25, 2023

Changes in this version

+ var ErrInitiatorResponderRequired = errors.New(...)

Apr 24, 2023

Changes in this version

+ var ErrDataChannelClosed = errors.New("DataChannel state is closed")

+ var ErrInitiatorRequired = errors.New("first message initiator is required in webrtc sdp SessionInformation")

+ func WaitDC(dc *webrtc.DataChannel, timeout time.Duration) (err error)

+ type Hub interface

+ NewPeerConnection func() (*webrtc.PeerConnection, error)

+ type Inbound struct

+ func NewInbound(sess signaler.Session, pc *webrtc.PeerConnection) *Inbound

+ func (*Inbound) ClearSrc()

+ func (*Inbound) DstIP() netip.Addr

+ func (*Inbound) SrcIP() netip.Addr

+ func (*Inbound) SrcToString() string

+ func (ep *Inbound) DstToBytes() []byte

+ func (ep *Inbound) DstToString() string

+ func (ep *Inbound) ExtractInitiator() (initiator []byte, err error)

+ func (ep *Inbound) HandleConnect()

+ func (ep *Inbound) Message() (ch <-chan []byte)

+ func (ep *Inbound) Send(buf []byte) error

+ type Outbound struct

+ func NewOutbound(id string, hub Hub) *Outbound

+ func (*Outbound) ClearSrc()

+ func (*Outbound) DstIP() netip.Addr

+ func (*Outbound) SrcIP() netip.Addr

+ func (*Outbound) SrcToString() string

+ func (ep *Outbound) Close() (err error)

+ func (ep *Outbound) Connect(buf []byte)

+ func (ep *Outbound) DstToBytes() []byte

+ func (ep *Outbound) DstToString() string

+ func (ep *Outbound) Message() (ch <-chan []byte)

+ func (ep *Outbound) Send(buf []byte) (err error)

+ type Sender interface

+ Send func(buf []byte) error