webrtc

README

StateChange

1. offer = pc.CreateOffer()
2. pc.SetLocalDescription(offer)
3. OnICEGatheringStateChange: gathering
4. OnSignalingStateChange: have-local-offer *. OnICEGatheringStateChange: complete
5. pc.SetRemoteDescription(answer)
6. OnSignalingStateChange: stable
7. OnICEConnectionStateChange: checking
8. OnICEConnectionStateChange: connected

Documentation

Index

• Constants
• func CandidateManualHostTCPPassive(host, port string, offset int) string
• func CandidateManualHostUDP(host, port string, offset int) string
• func GetCachedPublicIP() (net.IP, error)
• func GetPublicIP() (net.IP, error)
• func IsIP(host string) bool
• func LookupIP(address string) (string, error)
• func MimeType(codec *core.Codec) string
• func NewAPI() (*webrtc.API, error)
• func NewCandidate(network, address string) (string, error)
• func NewServerAPI(address, network string, candidateHost []string) (*webrtc.API, error)
• func RegisterDefaultCodecs(m *webrtc.MediaEngine) error
• func UnmarshalICEServers(b []byte) ([]webrtc.ICEServer, error)
• func UnmarshalMedias(descriptions []*sdp.MediaDescription) (medias []*core.Media)
• func WithResampling(medias []*core.Media) []*core.Media
• type Conn
  • func NewConn(pc *webrtc.PeerConnection) *Conn
  • func (c *Conn) AddCandidate(candidate string) error
  • func (c *Conn) AddTrack(media *core.Media, codec *core.Codec, track *core.Receiver) error
  • func (c *Conn) Close() error
  • func (c *Conn) CreateCompleteOffer(medias []*core.Media) (string, error)
  • func (c *Conn) CreateOffer(medias []*core.Media) (string, error)
  • func (c *Conn) GetAnswer() (answer string, err error)
  • func (c *Conn) GetCompleteAnswer() (answer string, err error)
  • func (c *Conn) GetMedias() []*core.Media
  • func (c *Conn) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error)
  • func (c *Conn) MarshalJSON() ([]byte, error)
  • func (c *Conn) SetAnswer(answer string) (err error)
  • func (c *Conn) SetOffer(offer string) (err error)
  • func (c *Conn) Start() error
  • func (c *Conn) Stop() error
• type Track
  • func NewTrack(kind string) *Track
  • func (t *Track) Bind(context webrtc.TrackLocalContext) (webrtc.RTPCodecParameters, error)
  • func (t *Track) ID() string
  • func (t *Track) Kind() webrtc.RTPCodecType
  • func (t *Track) RID() string
  • func (t *Track) StreamID() string
  • func (t *Track) Unbind(context webrtc.TrackLocalContext) error
  • func (t *Track) WriteRTP(payloadType uint8, packet *rtp.Packet) error

Constants

const PriorityComponentRTP = 1 * int(256-ice.ComponentRTP)

const PriorityLocalTCPPassive = (1 << 8) * int((1<<13)*4+8191)

const PriorityLocalUDP = (1 << 8) * int(65535)

const PriorityTypeHostTCP = (1 << 24) * int(126-27)

const PriorityTypeHostUDP = (1 << 24) * int(126)

const ReceiveMTU = 1472

ReceiveMTU = Ethernet MTU (1500) - IP Header (20) - UDP Header (8) https://ffmpeg.org/ffmpeg-all.html#Muxer

Functions

func CandidateManualHostTCPPassive

func CandidateManualHostTCPPassive(host, port string, offset int) string

func CandidateManualHostUDP

func CandidateManualHostUDP(host, port string, offset int) string

func GetCachedPublicIP

func GetCachedPublicIP() (net.IP, error)

func GetPublicIP

func GetPublicIP() (net.IP, error)

GetPublicIP example from https://github.com/pion/stun

func IsIP

func IsIP(host string) bool

func LookupIP

func LookupIP(address string) (string, error)

func MimeType

func MimeType(codec *core.Codec) string

func NewAPI

func NewAPI() (*webrtc.API, error)

func NewCandidate

func NewCandidate(network, address string) (string, error)

func NewServerAPI

func NewServerAPI(address, network string, candidateHost []string) (*webrtc.API, error)

func RegisterDefaultCodecs

func RegisterDefaultCodecs(m *webrtc.MediaEngine) error

func UnmarshalICEServers

func UnmarshalICEServers(b []byte) ([]webrtc.ICEServer, error)

func UnmarshalMedias

func UnmarshalMedias(descriptions []*sdp.MediaDescription) (medias []*core.Media)

func WithResampling

func WithResampling(medias []*core.Media) []*core.Media

WithResampling - will add for consumer: PCMA/0, PCMU/0, PCM/0, PCML/0 so it can add resampling for PCMA/PCMU and repack for PCM/PCML

Types

type Conn

type Conn struct {
	core.Listener

	UserAgent string
	Desc      string
	Mode      core.Mode
	// contains filtered or unexported fields
}

func NewConn

func NewConn(pc *webrtc.PeerConnection) *Conn

func (*Conn) AddCandidate

func (c *Conn) AddCandidate(candidate string) error

func (*Conn) AddTrack

func (c *Conn) AddTrack(media *core.Media, codec *core.Codec, track *core.Receiver) error

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) CreateCompleteOffer

func (c *Conn) CreateCompleteOffer(medias []*core.Media) (string, error)

func (*Conn) CreateOffer

func (c *Conn) CreateOffer(medias []*core.Media) (string, error)

func (*Conn) GetAnswer

func (c *Conn) GetAnswer() (answer string, err error)

func (*Conn) GetCompleteAnswer

func (c *Conn) GetCompleteAnswer() (answer string, err error)

func (*Conn) GetMedias

func (c *Conn) GetMedias() []*core.Media

func (*Conn) GetTrack

func (c *Conn) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error)

func (*Conn) MarshalJSON

func (c *Conn) MarshalJSON() ([]byte, error)

func (*Conn) SetAnswer

func (c *Conn) SetAnswer(answer string) (err error)

func (*Conn) SetOffer

func (c *Conn) SetOffer(offer string) (err error)

func (*Conn) Start

func (c *Conn) Start() error

func (*Conn) Stop

func (c *Conn) Stop() error

type Track

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

func NewTrack

func NewTrack(kind string) *Track

func (*Track) Bind

func (t *Track) Bind(context webrtc.TrackLocalContext) (webrtc.RTPCodecParameters, error)

func (*Track) ID

func (t *Track) ID() string

func (*Track) Kind

func (t *Track) Kind() webrtc.RTPCodecType

func (*Track) RID

func (t *Track) RID() string

func (*Track) StreamID

func (t *Track) StreamID() string

func (*Track) Unbind

func (t *Track) Unbind(context webrtc.TrackLocalContext) error

func (*Track) WriteRTP

func (t *Track) WriteRTP(payloadType uint8, packet *rtp.Packet) error