Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

lksdk

package module

Go to main page

Versions in this module

v2

v2.1.12

Jun 26, 2024

v2.1.11

Jun 26, 2024

v2.1.10

Jun 26, 2024

v2.1.9

Jun 26, 2024

v2.1.8

Jun 26, 2024

v2.1.7

Jun 26, 2024

v2.1.6

Jun 25, 2024

v2.1.5

Jun 25, 2024

v2.1.4

Jun 25, 2024

Changes in this version

+ const PROTOCOL

+ const ParticipantAgent

+ const ParticipantEgress

+ const ParticipantIngress

+ const ParticipantSIP

+ const ParticipantStandard

+ const SimulateSpeakerUpdateInterval

+ const Version

+ var ErrCannotConnectSignal = errors.New("could not establish signal connection")

+ var ErrCannotDetermineMime = errors.New("cannot determine mimetype from file extension")

+ var ErrCannotDialSignal = errors.New("could not dial signal connection")

+ var ErrCannotFindTrack = errors.New("could not find the track")

+ var ErrConnectionTimeout = errors.New("could not connect after timeout")

+ var ErrInvalidParameter = errors.New("invalid parameter")

+ var ErrInvalidSimulcastTrack = errors.New("simulcast track was not initiated correctly")

+ var ErrNoPeerConnection = errors.New("peer connection not established")

+ var ErrTrackPublishTimeout = errors.New("timed out publishing track")

+ var ErrURLNotProvided = errors.New("URL was not provided")

+ var ErrUnsupportedFileType = errors.New("ReaderSampleProvider does not support this mime type")

+ var ErrUnsupportedSimulcastKind = errors.New("simulcast is only supported for video")

+ func FromProtoIceServers(iceservers []*livekit.ICEServer) []webrtc.ICEServer

+ func FromProtoSessionDescription(sd *livekit.SessionDescription) webrtc.SessionDescription

+ func FromProtoTrickle(trickle *livekit.TrickleRequest) webrtc.ICECandidateInit

+ func ReaderTrackWithFrameDuration(duration time.Duration) func(provider *ReaderSampleProvider)

+ func ReaderTrackWithMime(mime string) func(provider *ReaderSampleProvider)

+ func ReaderTrackWithOnWriteComplete(f func()) func(provider *ReaderSampleProvider)

+ func ReaderTrackWithRTCPHandler(f func(rtcp.Packet)) func(provider *ReaderSampleProvider)

+ func ReaderTrackWithSampleOptions(opts ...LocalTrackOptions) func(provider *ReaderSampleProvider)

+ func SetLogger(l protoLogger.Logger)

+ func ToHttpURL(url string) string

+ func ToProtoSessionDescription(sd webrtc.SessionDescription) *livekit.SessionDescription

+ func ToProtoTrickle(candidateInit webrtc.ICECandidateInit, target livekit.SignalTarget) *livekit.TrickleRequest

+ func ToWebsocketURL(url string) string

+ type AudioSampleProvider interface

+ CurrentAudioLevel func() uint8

+ type BaseSampleProvider struct

+ func (p *BaseSampleProvider) Close() error

+ func (p *BaseSampleProvider) OnBind() error

+ func (p *BaseSampleProvider) OnUnbind() error

+ type ConnectInfo struct

+ APIKey string

+ APISecret string

+ ParticipantIdentity string

+ ParticipantKind ParticipantKind

+ ParticipantMetadata string

+ ParticipantName string

+ RoomName string

+ type ConnectOption func(*connectParams)

+ func WithAutoSubscribe(val bool) ConnectOption

+ func WithICETransportPolicy(iceTransportPolicy webrtc.ICETransportPolicy) ConnectOption

+ func WithInterceptors(interceptors []interceptor.Factory) ConnectOption

+ func WithPacer(pacer pacer.Factory) ConnectOption

+ func WithRetransmitBufferSize(val uint16) ConnectOption

+ type ConnectionState string

+ const ConnectionStateConnected

+ const ConnectionStateDisconnected

+ const ConnectionStateReconnecting

+ type DataPacket interface

+ ToProto func() *livekit.DataPacket

+ type DataPublishOption func(*dataPublishOptions)

+ func WithDataPublishDestination(identities []string) DataPublishOption

+ func WithDataPublishReliable(reliable bool) DataPublishOption

+ func WithDataPublishTopic(topic string) DataPublishOption

+ type DataReceiveParams struct

+ Sender *RemoteParticipant

+ SenderIdentity string

+ Topic string

+ type DisconnectionReason string

+ const Failed

+ const LeaveRequested

+ type EgressClient struct

+ func NewEgressClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *EgressClient

+ func (c *EgressClient) ListEgress(ctx context.Context, req *livekit.ListEgressRequest) (*livekit.ListEgressResponse, error)

+ func (c *EgressClient) StartParticipantEgress(ctx context.Context, req *livekit.ParticipantEgressRequest) (*livekit.EgressInfo, error)

+ func (c *EgressClient) StartRoomCompositeEgress(ctx context.Context, req *livekit.RoomCompositeEgressRequest) (*livekit.EgressInfo, error)

+ func (c *EgressClient) StartTrackCompositeEgress(ctx context.Context, req *livekit.TrackCompositeEgressRequest) (*livekit.EgressInfo, error)

+ func (c *EgressClient) StartTrackEgress(ctx context.Context, req *livekit.TrackEgressRequest) (*livekit.EgressInfo, error)

+ func (c *EgressClient) StartWebEgress(ctx context.Context, req *livekit.WebEgressRequest) (*livekit.EgressInfo, error)

+ func (c *EgressClient) StopEgress(ctx context.Context, req *livekit.StopEgressRequest) (*livekit.EgressInfo, error)

+ func (c *EgressClient) UpdateLayout(ctx context.Context, req *livekit.UpdateLayoutRequest) (*livekit.EgressInfo, error)

+ func (c *EgressClient) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)

+ type IngressClient struct

+ func NewIngressClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *IngressClient

+ func (c *IngressClient) CreateIngress(ctx context.Context, in *livekit.CreateIngressRequest) (*livekit.IngressInfo, error)

+ func (c *IngressClient) DeleteIngress(ctx context.Context, in *livekit.DeleteIngressRequest) (*livekit.IngressInfo, error)

+ func (c *IngressClient) ListIngress(ctx context.Context, in *livekit.ListIngressRequest) (*livekit.ListIngressResponse, error)

+ func (c *IngressClient) UpdateIngress(ctx context.Context, in *livekit.UpdateIngressRequest) (*livekit.IngressInfo, error)

+ type LocalParticipant struct

+ func (p *LocalParticipant) AudioLevel() float32

+ func (p *LocalParticipant) GetPublisherPeerConnection() *webrtc.PeerConnection

+ func (p *LocalParticipant) GetSubscriberPeerConnection() *webrtc.PeerConnection

+ func (p *LocalParticipant) GetTrackPublication(source livekit.TrackSource) TrackPublication

+ func (p *LocalParticipant) Identity() string

+ func (p *LocalParticipant) IsCameraEnabled() bool

+ func (p *LocalParticipant) IsMicrophoneEnabled() bool

+ func (p *LocalParticipant) IsScreenShareAudioEnabled() bool

+ func (p *LocalParticipant) IsScreenShareEnabled() bool

+ func (p *LocalParticipant) IsSpeaking() bool

+ func (p *LocalParticipant) Kind() ParticipantKind

+ func (p *LocalParticipant) Metadata() string

+ func (p *LocalParticipant) Name() string

+ func (p *LocalParticipant) Permissions() *livekit.ParticipantPermission

+ func (p *LocalParticipant) PublishData(payload []byte, opts ...DataPublishOption) error

+ func (p *LocalParticipant) PublishDataPacket(pck DataPacket, opts ...DataPublishOption) error

+ func (p *LocalParticipant) PublishSimulcastTrack(tracks []*LocalTrack, opts *TrackPublicationOptions) (*LocalTrackPublication, error)

+ func (p *LocalParticipant) PublishTrack(track webrtc.TrackLocal, opts *TrackPublicationOptions) (*LocalTrackPublication, error)

+ func (p *LocalParticipant) SID() string

+ func (p *LocalParticipant) SetMetadata(metadata string)

+ func (p *LocalParticipant) SetName(name string)

+ func (p *LocalParticipant) TrackPublications() []TrackPublication

+ func (p *LocalParticipant) UnpublishTrack(sid string) error

+ type LocalSampleTrack = LocalTrack

+ type LocalSampleTrackOptions = LocalTrackOptions

+ type LocalTrack struct

+ func NewLocalFileTrack(file string, options ...ReaderSampleProviderOption) (*LocalTrack, error)

+ func NewLocalReaderTrack(in io.ReadCloser, mime string, options ...ReaderSampleProviderOption) (*LocalTrack, error)

+ func NewLocalSampleTrack(c webrtc.RTPCodecCapability, opts ...LocalTrackOptions) (*LocalTrack, error)

+ func NewLocalTrack(c webrtc.RTPCodecCapability, opts ...LocalTrackOptions) (*LocalTrack, error)

+ func (s *LocalTrack) Bind(t webrtc.TrackLocalContext) (webrtc.RTPCodecParameters, error)

+ func (s *LocalTrack) Close() error

+ func (s *LocalTrack) Codec() webrtc.RTPCodecCapability

+ func (s *LocalTrack) ID() string

+ func (s *LocalTrack) IsBound() bool

+ func (s *LocalTrack) Kind() webrtc.RTPCodecType

+ func (s *LocalTrack) OnBind(f func())

+ func (s *LocalTrack) OnUnbind(f func())

+ func (s *LocalTrack) RID() string

+ func (s *LocalTrack) SSRC() webrtc.SSRC

+ func (s *LocalTrack) SetTransceiver(transceiver *webrtc.RTPTransceiver)

+ func (s *LocalTrack) StartWrite(provider SampleProvider, onComplete func()) error

+ func (s *LocalTrack) StreamID() string

+ func (s *LocalTrack) Unbind(t webrtc.TrackLocalContext) error

+ func (s *LocalTrack) WriteRTP(p *rtp.Packet, opts *SampleWriteOptions) error

+ func (s *LocalTrack) WriteSample(sample media.Sample, opts *SampleWriteOptions) error

+ type LocalTrackOptions func(s *LocalTrack)

+ func WithRTCPHandler(cb func(rtcp.Packet)) LocalTrackOptions

+ func WithSimulcast(simulcastID string, layer *livekit.VideoLayer) LocalTrackOptions

+ type LocalTrackPublication struct

+ func NewLocalTrackPublication(kind TrackKind, track Track, opts TrackPublicationOptions, ...) *LocalTrackPublication

+ func (p *LocalTrackPublication) CloseTrack()

+ func (p *LocalTrackPublication) GetSimulcastTrack(quality livekit.VideoQuality) *LocalTrack

+ func (p *LocalTrackPublication) IsMuted() bool

+ func (p *LocalTrackPublication) IsSubscribed() bool

+ func (p *LocalTrackPublication) Kind() TrackKind

+ func (p *LocalTrackPublication) MimeType() string

+ func (p *LocalTrackPublication) Name() string

+ func (p *LocalTrackPublication) PublicationOptions() TrackPublicationOptions

+ func (p *LocalTrackPublication) SID() string

+ func (p *LocalTrackPublication) SetMuted(muted bool)

+ func (p *LocalTrackPublication) Source() livekit.TrackSource

+ func (p *LocalTrackPublication) Track() Track

+ func (p *LocalTrackPublication) TrackInfo() *livekit.TrackInfo

+ func (p *LocalTrackPublication) TrackLocal() webrtc.TrackLocal

+ type LocalTrackWithClose interface

+ Close func() error

+ type NullSampleProvider struct

+ BytesPerSample uint32

+ SampleDuration time.Duration

+ func NewNullSampleProvider(bitrate uint32) *NullSampleProvider

+ func (p *NullSampleProvider) NextSample(ctx context.Context) (media.Sample, error)

+ type PCTransport struct

+ OnOffer func(description webrtc.SessionDescription)

+ func NewPCTransport(params PCTransportParams) (*PCTransport, error)

+ func (t *PCTransport) AddICECandidate(candidate webrtc.ICECandidateInit) error

+ func (t *PCTransport) Close() error

+ func (t *PCTransport) GetSelectedCandidatePair() (*webrtc.ICECandidatePair, error)

+ func (t *PCTransport) IsConnected() bool

+ func (t *PCTransport) Negotiate()

+ func (t *PCTransport) OnRemoteDescriptionSettled(f func() error)

+ func (t *PCTransport) PeerConnection() *webrtc.PeerConnection

+ func (t *PCTransport) SetRTT(rtt uint32)

+ func (t *PCTransport) SetRemoteDescription(sd webrtc.SessionDescription) error

+ type PCTransportParams struct

+ Configuration webrtc.Configuration

+ Interceptors []interceptor.Factory

+ IsSender bool

+ OnRTTUpdate func(rtt uint32)

+ Pacer pacer.Factory

+ RetransmitBufferSize uint16

+ type PLIWriter func(webrtc.SSRC)

+ type Participant interface

+ AudioLevel func() float32

+ GetTrackPublication func(source livekit.TrackSource) TrackPublication

+ Identity func() string

+ IsCameraEnabled func() bool

+ IsMicrophoneEnabled func() bool

+ IsScreenShareAudioEnabled func() bool

+ IsScreenShareEnabled func() bool

+ IsSpeaking func() bool

+ Kind func() ParticipantKind

+ Metadata func() string

+ Name func() string

+ Permissions func() *livekit.ParticipantPermission

+ SID func() string

+ TrackPublications func() []TrackPublication

+ type ParticipantCallback struct

+ OnConnectionQualityChanged func(update *livekit.ConnectionQualityInfo, p Participant)

+ OnDataPacket func(data DataPacket, params DataReceiveParams)

+ OnDataReceived func(data []byte, params DataReceiveParams)

+ OnIsSpeakingChanged func(p Participant)

+ OnMetadataChanged func(oldMetadata string, p Participant)

+ OnTrackMuted func(pub TrackPublication, p Participant)

+ OnTrackPublished func(publication *RemoteTrackPublication, rp *RemoteParticipant)

+ OnTrackSubscribed func(track *webrtc.TrackRemote, publication *RemoteTrackPublication, ...)

+ OnTrackSubscriptionFailed func(sid string, rp *RemoteParticipant)

+ OnTrackUnmuted func(pub TrackPublication, p Participant)

+ OnTrackUnpublished func(publication *RemoteTrackPublication, rp *RemoteParticipant)

+ OnTrackUnsubscribed func(track *webrtc.TrackRemote, publication *RemoteTrackPublication, ...)

+ func NewParticipantCallback() *ParticipantCallback

+ func (cb *ParticipantCallback) Merge(other *ParticipantCallback)

+ type ParticipantKind int

+ type PubCallback func(pub TrackPublication, participant *RemoteParticipant)

+ type RTCEngine struct

+ JoinTimeout time.Duration

+ OnConnectionQuality func([]*livekit.ConnectionQualityInfo)

+ OnDataPacket func(identity string, dataPacket DataPacket)

+ OnDataReceived func(userPacket *livekit.UserPacket)

+ OnDisconnected func(reason DisconnectionReason)

+ OnMediaTrack func(track *webrtc.TrackRemote, receiver *webrtc.RTPReceiver)

+ OnParticipantUpdate func([]*livekit.ParticipantInfo)

+ OnRestarted func(*livekit.JoinResponse)

+ OnRestarting func()

+ OnResumed func()

+ OnResuming func()

+ OnRoomUpdate func(room *livekit.Room)

+ OnSpeakersChanged func([]*livekit.SpeakerInfo)

+ func NewRTCEngine() *RTCEngine

+ func (e *RTCEngine) Close()

+ func (e *RTCEngine) GetDataChannel(kind livekit.DataPacket_Kind) *webrtc.DataChannel

+ func (e *RTCEngine) GetDataChannelSub(kind livekit.DataPacket_Kind) *webrtc.DataChannel

+ func (e *RTCEngine) IsConnected() bool

+ func (e *RTCEngine) Join(url string, token string, params *connectParams) (*livekit.JoinResponse, error)

+ func (e *RTCEngine) Publisher() (*PCTransport, bool)

+ func (e *RTCEngine) Subscriber() (*PCTransport, bool)

+ func (e *RTCEngine) TrackPublishedChan() <-chan *livekit.TrackPublishedResponse

+ type ReaderSampleProvider struct

+ AudioLevel uint8

+ FrameDuration time.Duration

+ Mime string

+ OnWriteComplete func()

+ func (p *ReaderSampleProvider) Close() error

+ func (p *ReaderSampleProvider) CurrentAudioLevel() uint8

+ func (p *ReaderSampleProvider) NextSample(ctx context.Context) (media.Sample, error)

+ func (p *ReaderSampleProvider) OnBind() error

+ func (p *ReaderSampleProvider) OnUnbind() error

+ type ReaderSampleProviderOption func(*ReaderSampleProvider)

+ type RemoteParticipant struct

+ func (p *RemoteParticipant) AudioLevel() float32

+ func (p *RemoteParticipant) GetTrackPublication(source livekit.TrackSource) TrackPublication

+ func (p *RemoteParticipant) Identity() string

+ func (p *RemoteParticipant) IsCameraEnabled() bool

+ func (p *RemoteParticipant) IsMicrophoneEnabled() bool

+ func (p *RemoteParticipant) IsScreenShareAudioEnabled() bool

+ func (p *RemoteParticipant) IsScreenShareEnabled() bool

+ func (p *RemoteParticipant) IsSpeaking() bool

+ func (p *RemoteParticipant) Kind() ParticipantKind

+ func (p *RemoteParticipant) Metadata() string

+ func (p *RemoteParticipant) Name() string

+ func (p *RemoteParticipant) Permissions() *livekit.ParticipantPermission

+ func (p *RemoteParticipant) SID() string

+ func (p *RemoteParticipant) TrackPublications() []TrackPublication

+ func (p *RemoteParticipant) WritePLI(ssrc webrtc.SSRC)

+ type RemoteTrackPublication struct

+ func (p *RemoteTrackPublication) IsEnabled() bool

+ func (p *RemoteTrackPublication) IsMuted() bool

+ func (p *RemoteTrackPublication) IsSubscribed() bool

+ func (p *RemoteTrackPublication) Kind() TrackKind

+ func (p *RemoteTrackPublication) MimeType() string

+ func (p *RemoteTrackPublication) Name() string

+ func (p *RemoteTrackPublication) OnRTCP(cb func(rtcp.Packet))

+ func (p *RemoteTrackPublication) Receiver() *webrtc.RTPReceiver

+ func (p *RemoteTrackPublication) SID() string

+ func (p *RemoteTrackPublication) SetEnabled(enabled bool)

+ func (p *RemoteTrackPublication) SetSubscribed(subscribed bool) error

+ func (p *RemoteTrackPublication) SetVideoDimensions(width uint32, height uint32)

+ func (p *RemoteTrackPublication) SetVideoQuality(quality livekit.VideoQuality) error

+ func (p *RemoteTrackPublication) Source() livekit.TrackSource

+ func (p *RemoteTrackPublication) Track() Track

+ func (p *RemoteTrackPublication) TrackInfo() *livekit.TrackInfo

+ func (p *RemoteTrackPublication) TrackRemote() *webrtc.TrackRemote

+ type Room struct

+ LocalParticipant *LocalParticipant

+ func ConnectToRoom(url string, info ConnectInfo, callback *RoomCallback, opts ...ConnectOption) (*Room, error)

+ func ConnectToRoomWithToken(url, token string, callback *RoomCallback, opts ...ConnectOption) (*Room, error)

+ func NewRoom(callback *RoomCallback) *Room

+ func (r *Room) ActiveSpeakers() []Participant

+ func (r *Room) ConnectionState() ConnectionState

+ func (r *Room) Disconnect()

+ func (r *Room) GetParticipantByIdentity(identity string) *RemoteParticipant

+ func (r *Room) GetParticipantBySID(sid string) *RemoteParticipant

+ func (r *Room) GetRemoteParticipants() []*RemoteParticipant

+ func (r *Room) Join(url string, info ConnectInfo, opts ...ConnectOption) error

+ func (r *Room) JoinWithToken(url, token string, opts ...ConnectOption) error

+ func (r *Room) Metadata() string

+ func (r *Room) Name() string

+ func (r *Room) SID() string

+ func (r *Room) ServerInfo() *livekit.ServerInfo

+ func (r *Room) Simulate(scenario SimulateScenario)

+ type RoomCallback struct

+ OnActiveSpeakersChanged func([]Participant)

+ OnDisconnected func()

+ OnDisconnectedWithReason func(reason DisconnectionReason)

+ OnParticipantConnected func(*RemoteParticipant)

+ OnParticipantDisconnected func(*RemoteParticipant)

+ OnReconnected func()

+ OnReconnecting func()

+ OnRoomMetadataChanged func(metadata string)

+ func NewRoomCallback() *RoomCallback

+ func (cb *RoomCallback) Merge(other *RoomCallback)

+ type RoomServiceClient struct

+ func NewRoomServiceClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *RoomServiceClient

+ func (c *RoomServiceClient) CreateRoom(ctx context.Context, req *livekit.CreateRoomRequest) (*livekit.Room, error)

+ func (c *RoomServiceClient) CreateToken() *auth.AccessToken

+ func (c *RoomServiceClient) DeleteRoom(ctx context.Context, req *livekit.DeleteRoomRequest) (*livekit.DeleteRoomResponse, error)

+ func (c *RoomServiceClient) GetParticipant(ctx context.Context, req *livekit.RoomParticipantIdentity) (*livekit.ParticipantInfo, error)

+ func (c *RoomServiceClient) ListParticipants(ctx context.Context, req *livekit.ListParticipantsRequest) (*livekit.ListParticipantsResponse, error)

+ func (c *RoomServiceClient) ListRooms(ctx context.Context, req *livekit.ListRoomsRequest) (*livekit.ListRoomsResponse, error)

+ func (c *RoomServiceClient) MutePublishedTrack(ctx context.Context, req *livekit.MuteRoomTrackRequest) (*livekit.MuteRoomTrackResponse, error)

+ func (c *RoomServiceClient) RemoveParticipant(ctx context.Context, req *livekit.RoomParticipantIdentity) (*livekit.RemoveParticipantResponse, error)

+ func (c *RoomServiceClient) SendData(ctx context.Context, req *livekit.SendDataRequest) (*livekit.SendDataResponse, error)

+ func (c *RoomServiceClient) UpdateParticipant(ctx context.Context, req *livekit.UpdateParticipantRequest) (*livekit.ParticipantInfo, error)

+ func (c *RoomServiceClient) UpdateRoomMetadata(ctx context.Context, req *livekit.UpdateRoomMetadataRequest) (*livekit.Room, error)

+ func (c *RoomServiceClient) UpdateSubscriptions(ctx context.Context, req *livekit.UpdateSubscriptionsRequest) (*livekit.UpdateSubscriptionsResponse, error)

+ type SIPClient struct

+ func NewSIPClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *SIPClient

+ func (s *SIPClient) CreateSIPDispatchRule(ctx context.Context, in *livekit.CreateSIPDispatchRuleRequest) (*livekit.SIPDispatchRuleInfo, error)

+ func (s *SIPClient) CreateSIPInboundTrunk(ctx context.Context, in *livekit.CreateSIPInboundTrunkRequest) (*livekit.SIPInboundTrunkInfo, error)

+ func (s *SIPClient) CreateSIPOutboundTrunk(ctx context.Context, in *livekit.CreateSIPOutboundTrunkRequest) (*livekit.SIPOutboundTrunkInfo, error)

+ func (s *SIPClient) CreateSIPParticipant(ctx context.Context, in *livekit.CreateSIPParticipantRequest) (*livekit.SIPParticipantInfo, error)

+ func (s *SIPClient) CreateSIPTrunk(ctx context.Context, in *livekit.CreateSIPTrunkRequest) (*livekit.SIPTrunkInfo, error)

+ func (s *SIPClient) DeleteSIPDispatchRule(ctx context.Context, in *livekit.DeleteSIPDispatchRuleRequest) (*livekit.SIPDispatchRuleInfo, error)

+ func (s *SIPClient) DeleteSIPTrunk(ctx context.Context, in *livekit.DeleteSIPTrunkRequest) (*livekit.SIPTrunkInfo, error)

+ func (s *SIPClient) ListSIPDispatchRule(ctx context.Context, in *livekit.ListSIPDispatchRuleRequest) (*livekit.ListSIPDispatchRuleResponse, error)

+ func (s *SIPClient) ListSIPInboundTrunk(ctx context.Context, in *livekit.ListSIPInboundTrunkRequest) (*livekit.ListSIPInboundTrunkResponse, error)

+ func (s *SIPClient) ListSIPOutboundTrunk(ctx context.Context, in *livekit.ListSIPOutboundTrunkRequest) (*livekit.ListSIPOutboundTrunkResponse, error)

+ func (s *SIPClient) ListSIPTrunk(ctx context.Context, in *livekit.ListSIPTrunkRequest) (*livekit.ListSIPTrunkResponse, error)

+ type SampleProvider interface

+ Close func() error

+ NextSample func(context.Context) (media.Sample, error)

+ OnBind func() error

+ OnUnbind func() error

+ type SampleWriteOptions struct

+ AudioLevel *uint8

+ type SignalClient struct

+ OnAnswer func(sd webrtc.SessionDescription)

+ OnClose func()

+ OnConnectionQuality func([]*livekit.ConnectionQualityInfo)

+ OnLeave func(*livekit.LeaveRequest)

+ OnLocalTrackPublished func(response *livekit.TrackPublishedResponse)

+ OnLocalTrackUnpublished func(response *livekit.TrackUnpublishedResponse)

+ OnOffer func(sd webrtc.SessionDescription)

+ OnParticipantUpdate func([]*livekit.ParticipantInfo)

+ OnRoomUpdate func(room *livekit.Room)

+ OnSpeakersChanged func([]*livekit.SpeakerInfo)

+ OnTokenRefresh func(refreshToken string)

+ OnTrackRemoteMuted func(request *livekit.MuteTrackRequest)

+ OnTrickle func(init webrtc.ICECandidateInit, target livekit.SignalTarget)

+ func NewSignalClient() *SignalClient

+ func (c *SignalClient) Close()

+ func (c *SignalClient) IsStarted() bool

+ func (c *SignalClient) Join(urlPrefix string, token string, params connectParams) (*livekit.JoinResponse, error)

+ func (c *SignalClient) Reconnect(urlPrefix string, token string, params connectParams) (*livekit.ReconnectResponse, error)

+ func (c *SignalClient) SendAnswer(sd webrtc.SessionDescription) error

+ func (c *SignalClient) SendICECandidate(candidate webrtc.ICECandidateInit, target livekit.SignalTarget) error

+ func (c *SignalClient) SendLeave() error

+ func (c *SignalClient) SendMuteTrack(sid string, muted bool) error

+ func (c *SignalClient) SendOffer(sd webrtc.SessionDescription) error

+ func (c *SignalClient) SendRequest(req *livekit.SignalRequest) error

+ func (c *SignalClient) SendSyncState(state *livekit.SyncState) error

+ func (c *SignalClient) SendUpdateParticipantMetadata(metadata *livekit.UpdateParticipantMetadata) error

+ func (c *SignalClient) SendUpdateTrackSettings(settings *livekit.UpdateTrackSettings) error

+ func (c *SignalClient) Start()

+ type SimulateScenario int

+ const SimulateForceTCP

+ const SimulateForceTLS

+ const SimulateMigration

+ const SimulateNodeFailure

+ const SimulateServerLeave

+ const SimulateSignalReconnect

+ const SimulateSpeakerUpdate

+ type SimulcastTrack struct

+ func NewSimulcastTrack(trackLocal webrtc.TrackLocal, videoLayer *livekit.VideoLayer) *SimulcastTrack

+ func (t *SimulcastTrack) Quality() livekit.VideoQuality

+ func (t *SimulcastTrack) TrackLocal() webrtc.TrackLocal

+ func (t *SimulcastTrack) VideoLayer() *livekit.VideoLayer

+ type Track interface

+ ID func() string

+ type TrackKind string

+ const TrackKindAudio

+ const TrackKindVideo

+ func KindFromRTPType(rt webrtc.RTPCodecType) TrackKind

+ func (k TrackKind) ProtoType() livekit.TrackType

+ func (k TrackKind) RTPType() webrtc.RTPCodecType

+ func (k TrackKind) String() string

+ type TrackPubCallback func(track Track, pub TrackPublication, participant *RemoteParticipant)

+ type TrackPublication interface

+ IsMuted func() bool

+ IsSubscribed func() bool

+ Kind func() TrackKind

+ MimeType func() string

+ Name func() string

+ SID func() string

+ Source func() livekit.TrackSource

+ Track func() Track

+ TrackInfo func() *livekit.TrackInfo

+ type TrackPublicationOptions struct

+ DisableDTX bool

+ Name string

+ Source livekit.TrackSource

+ Stereo bool

+ Stream string

+ VideoHeight int

+ VideoWidth int

+ type UserDataPacket struct

+ Payload []byte

+ Topic string

+ func UserData(data []byte) *UserDataPacket

+ func (p *UserDataPacket) ToProto() *livekit.DataPacket