Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

webrtc

package

Go to main page

Versions in this module

v0

v0.1.28

Mar 22, 2025

v0.1.25

Dec 22, 2024

v0.1.24

Dec 22, 2024

Changes in this version

+ const MessageSize

+ const RouterIdentity_PubSub

+ const RouterIdentity_Publisher

+ const RouterIdentity_Subscriber

+ const RouterType_Mcu

+ const RouterType_Mesh

+ const RouterType_Sfu

+ const WebrtcSignalType_Answer

+ const WebrtcSignalType_Candidate

+ const WebrtcSignalType_Join

+ const WebrtcSignalType_Offer

+ const WebrtcSignalType_Renegotiate

+ const WebrtcSignalType_Sdp

+ const WebrtcSignalType_TransceiverRequest

+ func Signal(webrtcSignal *WebrtcSignal, targetPeerId string) (interface{}, error)

+ type AdvancedPeerConnection struct

+ Room *MeetingRoom

+ func CreateAdvancedPeerConnection(peerId string, initiator bool, clientId string, name string, ...) *AdvancedPeerConnection

+ func (this *AdvancedPeerConnection) AddTrack(track webrtc.TrackLocal) (*webrtc.RTPSender, error)

+ func (this *AdvancedPeerConnection) Close()

+ func (this *AdvancedPeerConnection) CreateTrack(c *webrtc.RTPCodecCapability, trackId string, streamId string) (webrtc.TrackLocal, error)

+ func (this *AdvancedPeerConnection) GetSenders(streamId string) []*webrtc.RTPSender

+ func (this *AdvancedPeerConnection) GetTrackRemotes(streamId string) []*webrtc.TrackRemote

+ func (this *AdvancedPeerConnection) Id() string

+ func (this *AdvancedPeerConnection) Init(iceServers []webrtc.ICEServer) error

+ func (this *AdvancedPeerConnection) ReadRTP(track *webrtc.TrackRemote) (*rtp.Packet, error)

+ func (this *AdvancedPeerConnection) Send(data []byte) error

+ func (this *AdvancedPeerConnection) SendText(data string) error

+ func (this *AdvancedPeerConnection) WriteRTP(sender *webrtc.RTPSender, packet *rtp.Packet) error

+ type BasePeerConnection struct

+ func CreateBasePeerConnection(initiator bool) *BasePeerConnection

+ func (this *BasePeerConnection) AddTrack(track webrtc.TrackLocal) (*webrtc.RTPSender, error)

+ func (this *BasePeerConnection) BufferedAmount() uint64

+ func (this *BasePeerConnection) Close()

+ func (this *BasePeerConnection) Connected()

+ func (this *BasePeerConnection) CreateTrack(c *webrtc.RTPCodecCapability, trackId string, streamId string) (webrtc.TrackLocal, error)

+ func (this *BasePeerConnection) Emit(name WebrtcEventType, event *WebrtcEvent) (interface{}, error)

+ func (this *BasePeerConnection) GetReceiver(trackId string) (*webrtc.TrackRemote, *webrtc.RTPReceiver)

+ func (this *BasePeerConnection) GetSender(trackId string) *webrtc.RTPSender

+ func (this *BasePeerConnection) GetSenders(streamId string) []*webrtc.RTPSender

+ func (this *BasePeerConnection) GetSendersByKind(kind webrtc.RTPCodecType) []*webrtc.RTPSender

+ func (this *BasePeerConnection) GetTrackRemotes(streamId string) []*webrtc.TrackRemote

+ func (this *BasePeerConnection) GetTrackRemotesByKind(kind webrtc.RTPCodecType) []*webrtc.TrackRemote

+ func (this *BasePeerConnection) Init(extension *SignalExtension, localTracks []webrtc.TrackLocal) error

+ func (this *BasePeerConnection) On(name WebrtcEventType, fn func(event *WebrtcEvent) (interface{}, error))

+ func (this *BasePeerConnection) ReadRTP(track *webrtc.TrackRemote) (*rtp.Packet, error)

+ func (this *BasePeerConnection) RemoveStream(streamId string) error

+ func (this *BasePeerConnection) RemoveTrack(trackId string) error

+ func (this *BasePeerConnection) ReplaceTrack(oldTrack webrtc.TrackLocal, newTrack webrtc.TrackLocal) error

+ func (this *BasePeerConnection) Send(data []byte) error

+ func (this *BasePeerConnection) SendText(message string) error

+ func (this *BasePeerConnection) SetStatus(status PeerConnectionStatus)

+ func (this *BasePeerConnection) Status() PeerConnectionStatus

+ func (this *BasePeerConnection) StopReceiver(trackId string) error

+ func (this *BasePeerConnection) StopStream(streamId string) error

+ func (this *BasePeerConnection) Write(sender *webrtc.RTPSender, buf []byte) error

+ func (this *BasePeerConnection) WriteRTP(sender *webrtc.RTPSender, packet *rtp.Packet) error

+ type MeetingRoom struct

+ Action string

+ Id string

+ Identity string

+ RoomId string

+ Typ string

+ type MessageSlice struct

+ type NegotiateStatus string

+ const NegotiateStatus_negotiated

+ const NegotiateStatus_negotiating

+ const NegotiateStatus_none

+ type PeerConnectionPool struct

+ func GetPeerConnectionPool() *PeerConnectionPool

+ func (this *PeerConnectionPool) Close(peerId string, clientId string) bool

+ func (this *PeerConnectionPool) Emit(name WebrtcEventType, event *WebrtcEvent) (interface{}, error)

+ func (this *PeerConnectionPool) On(name WebrtcEventType, fn func(event *WebrtcEvent) (interface{}, error))

+ type PeerConnectionStatus string

+ const PeerConnectionStatus_closed

+ const PeerConnectionStatus_connected

+ const PeerConnectionStatus_created

+ const PeerConnectionStatus_failed

+ const PeerConnectionStatus_init

+ const PeerConnectionStatus_none

+ const PeerConnectionStatus_reconnecting

+ type Sfu struct

+ func Create(sfuId string) *Sfu

+ type SfuPool struct

+ func GetSfuPool() *SfuPool

+ func (this *SfuPool) Destroy(roomId string) error

+ func (this *SfuPool) Get(roomId string) *Sfu

+ func (this *SfuPool) Join(peerConnection *AdvancedPeerConnection) (*Sfu, error)

+ func (this *SfuPool) Leave(peerConnection *AdvancedPeerConnection) error

+ type SignalExtension struct

+ ClientId string

+ IceServers []webrtc.ICEServer

+ Name string

+ PeerId string

+ Room *MeetingRoom

+ type SignalType string

+ type WebrtcEvent struct

+ ClientId string

+ ConnectPeerId string

+ ConnectSessionId string

+ Data interface{}

+ Name string

+ PeerId string

+ type WebrtcEventType string

+ const WebrtcEventType_addTrack

+ const WebrtcEventType_closed

+ const WebrtcEventType_connected

+ const WebrtcEventType_connectionState

+ const WebrtcEventType_created

+ const WebrtcEventType_dataChannelState

+ const WebrtcEventType_error

+ const WebrtcEventType_iceCandidate

+ const WebrtcEventType_iceCompleted

+ const WebrtcEventType_iceConnectionState

+ const WebrtcEventType_iceGatheringState

+ const WebrtcEventType_message

+ const WebrtcEventType_onSignal

+ const WebrtcEventType_removeStream

+ const WebrtcEventType_removeTrack

+ const WebrtcEventType_signal

+ const WebrtcEventType_signalingState

+ const WebrtcEventType_status

+ const WebrtcEventType_stream

+ const WebrtcEventType_track

+ type WebrtcSignal struct

+ Candidates []*webrtc.ICECandidateInit

+ Renegotiate bool

+ Sdp *webrtc.SessionDescription

+ SignalExtension *SignalExtension

+ SignalType string

+ TransceiverRequest map[string]interface{}

+ func Transform(payload map[string]interface{}) *WebrtcSignal

v0.0.3

Oct 23, 2021

v0.0.2

Aug 26, 2021

v0.0.1

Apr 16, 2021

Changes in this version

+ const CHANNEL_CLOSING_TIMEOUT

+ const ERR_ADD_ICE_CANDIDATE

+ const ERR_ADD_TRANSCEIVER

+ const ERR_CONNECTION_FAILURE

+ const ERR_CREATE_ANSWER

+ const ERR_CREATE_OFFER

+ const ERR_DATA_CHANNEL

+ const ERR_ICE_CONNECTION_CLOSED

+ const ERR_REMOVE_TRACK

+ const ERR_SENDER_ALREADY_ADDED

+ const ERR_SENDER_REMOVED

+ const ERR_SET_LOCAL_DESCRIPTION

+ const ERR_SET_REMOTE_DESCRIPTION

+ const ERR_SIGNALING

+ const ERR_TRACK_ALREADY_ADDED

+ const ERR_TRACK_NOT_ADDED

+ const ERR_UNSUPPORTED_REPLACETRACK

+ const EVENT_CLOSE

+ const EVENT_CONNECT

+ const EVENT_DATA

+ const EVENT_ERROR

+ const EVENT_FINISH

+ const EVENT_ICE_COMPLETE

+ const EVENT_ICE_STATE_CHANGE

+ const EVENT_ICE_TIMEOUT

+ const EVENT_NEGOTIATED

+ const EVENT_SIGNAL

+ const EVENT_SIGNALING_STATE_CHANGE

+ const EVENT_STREAM

+ const EVENT_TRACK

+ const ICECOMPLETE_TIMEOUT

+ const MAX_BUFFERED_AMOUNT

+ func GetICEServers() []webrtc.ICEServer

+ type PeerEvent struct

+ Data interface{}

+ Name string

+ type WebrtcOption struct

+ AllowHalfOpen bool

+ AllowHalfTrickle bool

+ AnswerOptions *webrtc.AnswerOptions

+ ChannelConfig *webrtc.DataChannelInit

+ ChannelName string

+ Config *webrtc.Configuration

+ IceCompleteTimeout uint64

+ Initiator bool

+ ObjectMode bool

+ OfferOptions *webrtc.OfferOptions

+ SdpTransform func(sdp string) string

+ Trickle bool