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(address string, port int) string
• func CandidateManualHostUDP(host string, port 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(address string) (*webrtc.API, error)
• func NewCandidate(network, address string) (string, error)
• func RegisterDefaultCodecs(m *webrtc.MediaEngine) error
• func UnmarshalMedias(descriptions []*sdp.MediaDescription) (medias []*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 = uint32(256 - ice.ComponentRTP)

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

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

const PriorityManualHost = (1 << 24) * uint32(120)

const ReceiveMTU = 1472

ReceiveMTU = Ethernet MTU (1500) - IP Header (20) - UDP Header (8)

Functions

func CandidateManualHostTCPPassive

func CandidateManualHostTCPPassive(address string, port int) string

func CandidateManualHostUDP

func CandidateManualHostUDP(host string, port 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(address string) (*webrtc.API, error)

func NewCandidate

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

func RegisterDefaultCodecs

func RegisterDefaultCodecs(m *webrtc.MediaEngine) error

func UnmarshalMedias

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

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