rtc

Documentation

Index

• Constants
• type ICEServerConfig
  • func (c ICEServerConfig) IsSTUN() bool
  • func (c ICEServerConfig) IsTURN() bool
  • func (c ICEServerConfig) IsValid() error
• type ICEServers
  • func GenTURNConfigs(turnServers ICEServers, username, secret string, expiryMinutes int) (ICEServers, error)
  • func (s *ICEServers) Decode(value string) error
  • func (s ICEServers) IsValid() error
  • func (s *ICEServers) UnmarshalTOML(data interface{}) error
• type Message
  • func (m *Message) IsValid() error
• type MessageType
• type Metrics
• type RateMonitor
  • func NewRateMonitor(samplingSize time.Duration, now func() time.Time) (*RateMonitor, error)
  • func (m *RateMonitor) GetRate() (int, time.Duration)
  • func (m *RateMonitor) GetSamplesDuration() time.Duration
  • func (m *RateMonitor) PushSample(size int)
• type Server
  • func NewServer(cfg ServerConfig, log mlog.LoggerIFace, metrics Metrics) (*Server, error)
  • func (s *Server) CloseSession(sessionID string) error
  • func (s *Server) InitSession(cfg SessionConfig, closeCb func() error) error
  • func (s *Server) ReceiveCh() <-chan Message
  • func (s *Server) Send(msg Message) error
  • func (s *Server) Start() error
  • func (s *Server) Stop() error
• type ServerConfig
  • func (c ServerConfig) IsValid() error
• type SessionConfig
  • func (c SessionConfig) IsValid() error
• type TURNConfig
  • func (c TURNConfig) IsValid() error

Constants

const (
	SimulcastLevelHigh    = "h"
	SimulcastLevelLow     = "l"
	SimulcastLevelDefault = SimulcastLevelLow
)

const MaxTURNCredentialsExpiration = 7 * 24 * 60 // 1 week in minutes

Types

type ICEServerConfig

type ICEServerConfig struct {
	URLs       []string `toml:"urls" json:"urls"`
	Username   string   `toml:"username,omitempty" json:"username,omitempty"`
	Credential string   `toml:"credential,omitempty" json:"credential,omitempty"`
}

func (ICEServerConfig) IsSTUN

func (c ICEServerConfig) IsSTUN() bool

func (ICEServerConfig) IsTURN

func (c ICEServerConfig) IsTURN() bool

func (ICEServerConfig) IsValid

func (c ICEServerConfig) IsValid() error

type ICEServers

type ICEServers []ICEServerConfig

func GenTURNConfigs

func GenTURNConfigs(turnServers ICEServers, username, secret string, expiryMinutes int) (ICEServers, error)

func (*ICEServers) Decode

func (s *ICEServers) Decode(value string) error

func (ICEServers) IsValid

func (s ICEServers) IsValid() error

func (*ICEServers) UnmarshalTOML

func (s *ICEServers) UnmarshalTOML(data interface{}) error

type Message

type Message struct {
	GroupID   string      `msgpack:"group_id"`
	UserID    string      `msgpack:"user_id"`
	SessionID string      `msgpack:"session_id"`
	CallID    string      `msgpack:"call_id"`
	Type      MessageType `msgpack:"type"`
	Data      []byte      `msgpack:"data,omitempty"`
}

func (*Message) IsValid

func (m *Message) IsValid() error

type MessageType

type MessageType int

const (
	ICEMessage MessageType = iota + 1
	SDPMessage
	MuteMessage
	UnmuteMessage
	ScreenOnMessage
	ScreenOffMessage
	VoiceOnMessage
	VoiceOffMessage
)

type Metrics

type Metrics interface {
	IncRTCSessions(groupID string, callID string)
	DecRTCSessions(groupID string, callID string)
	IncRTCConnState(state string)
	IncRTCErrors(groupID string, errType string)
	IncRTPTracks(groupID string, callID, direction, trackType string)
	DecRTPTracks(groupID string, callID, direction, trackType string)
}

type RateMonitor

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

func NewRateMonitor

func NewRateMonitor(samplingSize time.Duration, now func() time.Time) (*RateMonitor, error)

func (*RateMonitor) GetRate

func (m *RateMonitor) GetRate() (int, time.Duration)

func (*RateMonitor) GetSamplesDuration

func (m *RateMonitor) GetSamplesDuration() time.Duration

func (*RateMonitor) PushSample

func (m *RateMonitor) PushSample(size int)

type Server

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

func NewServer

func NewServer(cfg ServerConfig, log mlog.LoggerIFace, metrics Metrics) (*Server, error)

func (*Server) CloseSession

func (s *Server) CloseSession(sessionID string) error

func (*Server) InitSession

func (s *Server) InitSession(cfg SessionConfig, closeCb func() error) error

func (*Server) ReceiveCh

func (s *Server) ReceiveCh() <-chan Message

func (*Server) Send

func (s *Server) Send(msg Message) error

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop() error

type ServerConfig

type ServerConfig struct {
	// ICEAddressUDP specifies the UDP address the RTC service should listen on.
	ICEAddressUDP string `toml:"ice_address_udp"`
	// ICEPortUDP specifies the UDP port the RTC service should listen to.
	ICEPortUDP int `toml:"ice_port_udp"`
	// ICEAddressTCP specifies the TCP address the RTC service should listen on.
	ICEAddressTCP string `toml:"ice_address_tcp"`
	// ICEPortTCP specifies the TCP port the RTC service should listen to.
	ICEPortTCP int `toml:"ice_port_tcp"`
	// ICEHostOverride optionally specifies an IP address (or hostname)
	// to be used as the main host ICE candidate.
	ICEHostOverride string `toml:"ice_host_override"`
	// A list of ICE server (STUN/TURN) configurations to use.
	ICEServers ICEServers `toml:"ice_servers"`
	TURNConfig TURNConfig `toml:"turn"`
	// EnableIPv6 specifies whether or not IPv6 should be used.
	EnableIPv6 bool `toml:"enable_ipv6"`
}

func (ServerConfig) IsValid

func (c ServerConfig) IsValid() error

type SessionConfig

type SessionConfig struct {
	// GroupID specifies the id of the group the session should belong to.
	GroupID string
	// CallID specifies the id of the call the session should belong to.
	CallID string
	// UserID specifies the id of the user the session belongs to.
	UserID string
	// SessionID specifies the unique identifier for the session.
	SessionID string
}

func (SessionConfig) IsValid

func (c SessionConfig) IsValid() error

type TURNConfig

type TURNConfig struct {
	// The secret key used to generate TURN short-lived authentication
	// credentials.
	StaticAuthSecret string `toml:"static_auth_secret"`
	// The number of minutes that the generated TURN credentials will be valid for.
	CredentialsExpirationMinutes int `toml:"credentials_expiration_minutes"`
}

func (TURNConfig) IsValid

func (c TURNConfig) IsValid() error