lksdk

Dec 2, 2025

Changes in this version

+ const ParticipantConnector

+ type ConnectorClient struct

+ func NewConnectorClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *ConnectorClient

+ func (c *ConnectorClient) AcceptWhatsAppCall(ctx context.Context, req *livekit.AcceptWhatsAppCallRequest) (*livekit.AcceptWhatsAppCallResponse, error)

+ func (c *ConnectorClient) ConnectTwilioCall(ctx context.Context, req *livekit.ConnectTwilioCallRequest) (*livekit.ConnectTwilioCallResponse, error)

+ func (c *ConnectorClient) ConnectWhatsAppCall(ctx context.Context, req *livekit.ConnectWhatsAppCallRequest) (*livekit.ConnectWhatsAppCallResponse, error)

+ func (c *ConnectorClient) DialWhatsAppCall(ctx context.Context, req *livekit.DialWhatsAppCallRequest) (*livekit.DialWhatsAppCallResponse, error)

+ func (c *ConnectorClient) DisconnectWhatsAppCall(ctx context.Context, req *livekit.DisconnectWhatsAppCallRequest) (*livekit.DisconnectWhatsAppCallResponse, error)

type LocalParticipant

+ func (p *LocalParticipant) DisconnectReason() livekit.DisconnectReason

type RemoteParticipant

+ func (p *RemoteParticipant) DisconnectReason() livekit.DisconnectReason

Nov 5, 2025

Changes in this version

type Room

+ func (r *Room) IsRecording() bool

type RoomCallback

+ OnRecordingStatusChanged func(isRecording bool)

Nov 2, 2025

Changes in this version

+ func ReaderTrackWithH26xStreamingFormat(h26xStreamingFormat H26xStreamingFormat) func(provider *ReaderSampleProvider)

+ type H26xStreamingFormat int

+ const H26xStreamingFormatAnnexB

+ const H26xStreamingFormatLengthPrefixed

+ func (f H26xStreamingFormat) String() string

Nov 1, 2025

Changes in this version

+ func ReaderTrackWithH26xFormat(h26xFormat H26xFormat) func(provider *ReaderSampleProvider)

+ type H26xFormat int

+ const H26xFormatAVCC

+ const H26xFormatAnnexB

+ func (f H26xFormat) String() string

Oct 29, 2025

Changes in this version

+ var ErrMissingPrimaryCodec = errors.New("primary track must be TrackLocalWithCodec when backup codec is present")

type LocalParticipant

+ func (p *LocalParticipant) SetLogger(log protoLogger.Logger)

type LocalTrackPublication

+ func (p *LocalTrackPublication) SetLogger(log protoLogger.Logger)

+ func (p *LocalTrackPublication) TrackLocalForSimulcast() []*LocalTrack

+ type LocalTrackPublishOption func(*LocalTrackPublishOptions)

+ func WithBackupCodec(backupCodecTrack TrackLocalWithCodec) LocalTrackPublishOption

+ func WithBackupCodecForSimulcastTrack(backupCodecTracks []*LocalTrack) LocalTrackPublishOption

+ type LocalTrackPublishOptions struct

type PCTransportParams

+ Codecs []webrtc.RTPCodecParameters

type RTCEngine

+ func (e *RTCEngine) OnSubscribedAudioCodecUpdate(subscribedAudioCodecUpdate *livekit.SubscribedAudioCodecUpdate)

type RemoteParticipant

+ func (p *RemoteParticipant) SetLogger(logger protoLogger.Logger)

type Room

+ func (r *Room) OnSubscribedAudioCodecUpdate(subscribedAudioCodecUpdate *livekit.SubscribedAudioCodecUpdate)

+ type TrackLocalWithCodec interface

+ Codec func() webrtc.RTPCodecCapability

type TrackPublicationOptions

+ BackupCodecPolicy livekit.BackupCodecPolicy

Oct 21, 2025

Changes in this version

+ type PhoneNumberClient struct

+ func NewPhoneNumberClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *PhoneNumberClient

+ func (p *PhoneNumberClient) GetPhoneNumber(ctx context.Context, in *livekit.GetPhoneNumberRequest) (*livekit.GetPhoneNumberResponse, error)

+ func (p *PhoneNumberClient) ListPhoneNumbers(ctx context.Context, in *livekit.ListPhoneNumbersRequest) (*livekit.ListPhoneNumbersResponse, error)

+ func (p *PhoneNumberClient) PurchasePhoneNumber(ctx context.Context, in *livekit.PurchasePhoneNumberRequest) (*livekit.PurchasePhoneNumberResponse, error)

+ func (p *PhoneNumberClient) ReleasePhoneNumbers(ctx context.Context, in *livekit.ReleasePhoneNumbersRequest) (*livekit.ReleasePhoneNumbersResponse, error)

+ func (p *PhoneNumberClient) SearchPhoneNumbers(ctx context.Context, in *livekit.SearchPhoneNumbersRequest) (*livekit.SearchPhoneNumbersResponse, error)

+ func (p *PhoneNumberClient) UpdatePhoneNumber(ctx context.Context, in *livekit.UpdatePhoneNumberRequest) (*livekit.UpdatePhoneNumberResponse, error)

Aug 29, 2025

Changes in this version

type RTCEngine

+ func (e *RTCEngine) OnMediaSectionsRequirement(mediaSectionsRequirement *livekit.MediaSectionsRequirement)

type Room

+ func (r *Room) OnMediaSectionsRequirement(mediaSectionsRequirement *livekit.MediaSectionsRequirement)

Aug 21, 2025

Changes in this version

+ func ChatMessage(ts time.Time, text string) *livekit.ChatMessage

type ConnectOption

+ func WithMetadata(metadata string) ConnectOption

type PCTransport

+ func (t *PCTransport) GetLocalOffer() (webrtc.SessionDescription, error)

+ func (t *PCTransport) SetLocalOffer(offer webrtc.SessionDescription)

type RTCEngine

+ func (e *RTCEngine) OnReconnectResponse(res *livekit.ReconnectResponse) error

type Room

+ func (r *Room) OnRoomJoined(room *livekit.Room, participant *livekit.ParticipantInfo, ...)

Jul 22, 2025

Changes in this version

+ var ErrInvalidMessageType = signalling.ErrInvalidMessageType

type AgentClient

+ func (c *AgentClient) RestartAgent(ctx context.Context, req *livekit.RestartAgentRequest) (*livekit.RestartAgentResponse, error)

type ConnectOption

+ func WithExtraAttributes(attrs map[string]string) ConnectOption

type LocalParticipant

+ func (p *LocalParticipant) HandleIncomingRpcAck(requestId string)

+ func (p *LocalParticipant) HandleIncomingRpcResponse(requestId string, payload *string, error *RpcError)

type RTCEngine

+ func (e *RTCEngine) OnAnswer(sd webrtc.SessionDescription, answerId uint32)

+ func (e *RTCEngine) OnJoinResponse(res *livekit.JoinResponse)

+ func (e *RTCEngine) OnLeave(leave *livekit.LeaveRequest)

+ func (e *RTCEngine) OnLocalTrackPublished(res *livekit.TrackPublishedResponse)

+ func (e *RTCEngine) OnOffer(sd webrtc.SessionDescription, offerId uint32)

+ func (e *RTCEngine) OnSubscribedQualityUpdate(subscribedQualityUpdate *livekit.SubscribedQualityUpdate)

+ func (e *RTCEngine) OnTokenRefresh(refreshToken string)

+ func (e *RTCEngine) OnTransportClose()

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

+ func (e *RTCEngine) SendAddTrack(addTrack *livekit.AddTrackRequest) error

+ func (e *RTCEngine) SendLeaveWithReason(reason livekit.DisconnectReason) error

+ func (e *RTCEngine) SendMuteTrack(sid string, muted bool) error

+ func (e *RTCEngine) SendSubscriptionPermission(subscriptionPermission *livekit.SubscriptionPermission) error

+ func (e *RTCEngine) SendSyncState(syncState *livekit.SyncState) error

+ func (e *RTCEngine) SendUpdateParticipantMetadata(metadata *livekit.UpdateParticipantMetadata) error

+ func (e *RTCEngine) SendUpdateSubscription(updateSubscription *livekit.UpdateSubscription) error

+ func (e *RTCEngine) SendUpdateTrackSettings(settings *livekit.UpdateTrackSettings) error

+ func (e *RTCEngine) Simulate(scenario SimulateScenario)

type Room

+ func (n *Room) OnConnectionQuality([]*livekit.ConnectionQualityInfo)

+ func (n *Room) OnDisconnected(reason DisconnectionReason)

+ func (n *Room) OnSpeakersChanged([]*livekit.SpeakerInfo)

+ func (n *Room) OnTranscription(*livekit.Transcription)

+ func (r *Room) OnConnectionQualityUpdate(updates []*livekit.ConnectionQualityInfo)

+ func (r *Room) OnDataPacket(identity string, dataPacket DataPacket)

+ func (r *Room) OnDisconnect(reason DisconnectionReason)

+ func (r *Room) OnLocalTrackSubscribed(trackSubscribed *livekit.TrackSubscribed)

+ func (r *Room) OnLocalTrackUnpublished(msg *livekit.TrackUnpublishedResponse)

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

+ func (r *Room) OnParticipantDisconnect(rp *RemoteParticipant)

+ func (r *Room) OnParticipantUpdate(participants []*livekit.ParticipantInfo)

+ func (r *Room) OnRestarted(room *livekit.Room, participant *livekit.ParticipantInfo, ...)

+ func (r *Room) OnRestarting()

+ func (r *Room) OnResumed()

+ func (r *Room) OnResuming()

+ func (r *Room) OnRoomMoved(moved *livekit.RoomMovedResponse)

+ func (r *Room) OnRoomUpdate(room *livekit.Room)

+ func (r *Room) OnRpcAck(requestId string)

+ func (r *Room) OnRpcRequest(callerIdentity, requestId, method, payload string, ...)

+ func (r *Room) OnRpcResponse(requestId string, payload *string, error *RpcError)

+ func (r *Room) OnSignalClientConnected(joinRes *livekit.JoinResponse)

+ func (r *Room) OnSpeakersChange(speakerUpdates []*livekit.SpeakerInfo)

+ func (r *Room) OnStreamChunk(streamChunk *livekit.DataStream_Chunk)

+ func (r *Room) OnStreamHeader(streamHeader *livekit.DataStream_Header, participantIdentity string)

+ func (r *Room) OnStreamTrailer(streamTrailer *livekit.DataStream_Trailer)

+ func (r *Room) OnSubscribedQualityUpdate(subscribedQualityUpdate *livekit.SubscribedQualityUpdate)

+ func (r *Room) OnTrackRemoteMuted(msg *livekit.MuteTrackRequest)

+ func (r *Room) OnTranscriptionReceived(transcription *livekit.Transcription)

Jun 4, 2025

Changes in this version

+ type MuteFunc func(muted bool) error

+ type Private struct

+ func MakePrivate[T any](v T) Private[T]

type RTCEngine

+ OnLocalTrackSubscribed func(trackSubscribed *livekit.TrackSubscribed)

type RoomCallback

+ OnLocalTrackSubscribed func(publication *LocalTrackPublication, lp *LocalParticipant)

type SignalClient

+ OnLocalTrackSubscribed func(trackSubscribed *livekit.TrackSubscribed)

May 16, 2025

Changes in this version

type RTCEngine

+ OnRoomMoved func(moved *livekit.RoomMovedResponse)

type RoomCallback

+ OnRoomMoved func(roomName string, token string)

type SignalClient

+ OnRoomMoved func(moved *livekit.RoomMovedResponse)

May 13, 2025

Changes in this version

type RoomServiceClient

+ func (c *RoomServiceClient) MoveParticipant(ctx context.Context, req *livekit.MoveParticipantRequest) (*livekit.MoveParticipantResponse, error)

Apr 18, 2025

Changes in this version

+ const MaxDataBytes

+ const MaxMessageBytes

+ const MaxPayloadBytes

+ const STREAM_CHUNK_SIZE

+ type AgentClient struct

+ func NewAgentClient(url string, apiKey string, apiSecret string, opts ...twirp.ClientOption) (*AgentClient, error)

+ func (c *AgentClient) CreateAgent(ctx context.Context, req *livekit.CreateAgentRequest) (*livekit.CreateAgentResponse, error)

+ func (c *AgentClient) DeleteAgent(ctx context.Context, req *livekit.DeleteAgentRequest) (*livekit.DeleteAgentResponse, error)

+ func (c *AgentClient) DeployAgent(ctx context.Context, req *livekit.DeployAgentRequest) (*livekit.DeployAgentResponse, error)

+ func (c *AgentClient) GetClientSettings(ctx context.Context, req *livekit.ClientSettingsRequest) (*livekit.ClientSettingsResponse, error)

+ func (c *AgentClient) ListAgentSecrets(ctx context.Context, req *livekit.ListAgentSecretsRequest) (*livekit.ListAgentSecretsResponse, error)

+ func (c *AgentClient) ListAgentVersions(ctx context.Context, req *livekit.ListAgentVersionsRequest) (*livekit.ListAgentVersionsResponse, error)

+ func (c *AgentClient) ListAgents(ctx context.Context, req *livekit.ListAgentsRequest) (*livekit.ListAgentsResponse, error)

+ func (c *AgentClient) RollbackAgent(ctx context.Context, req *livekit.RollbackAgentRequest) (*livekit.RollbackAgentResponse, error)

+ func (c *AgentClient) UpdateAgent(ctx context.Context, req *livekit.UpdateAgentRequest) (*livekit.UpdateAgentResponse, error)

+ func (c *AgentClient) UpdateAgentSecrets(ctx context.Context, req *livekit.UpdateAgentSecretsRequest) (*livekit.UpdateAgentSecretsResponse, error)

+ type ByteStreamHandler func(reader *ByteStreamReader, participantIdentity string)

+ type ByteStreamInfo struct

+ Name *string

+ type ByteStreamReader struct

+ Info ByteStreamInfo

+ func NewByteStreamReader(info ByteStreamInfo, totalChunkCount *uint64) *ByteStreamReader

+ func (r *ByteStreamReader) ReadAll() []byte

+ func (r ByteStreamReader) OnProgress(onProgress *func(progress float64))

+ func (r ByteStreamReader) Read(bytes []byte) (int, error)

+ func (r ByteStreamReader) ReadByte() (byte, error)

+ func (r ByteStreamReader) ReadBytes(delim byte) ([]byte, error)

+ type ByteStreamWriter struct

+ Info ByteStreamInfo

+ func (w ByteStreamWriter) Close()

+ func (w ByteStreamWriter) Write(data T, onDone *func())

type LocalParticipant

+ func (p *LocalParticipant) PerformRpc(params PerformRpcParams) (*string, error)

+ func (p *LocalParticipant) SendFile(filePath string, options StreamBytesOptions) (*ByteStreamInfo, error)

+ func (p *LocalParticipant) SendText(text string, options StreamTextOptions) *TextStreamInfo

+ func (p *LocalParticipant) StreamBytes(options StreamBytesOptions) *ByteStreamWriter

+ func (p *LocalParticipant) StreamText(options StreamTextOptions) *TextStreamWriter

+ type PerformRpcParams struct

+ DestinationIdentity string

+ Method string

+ Payload string

+ ResponseTimeout *time.Duration

type RTCEngine

+ OnRpcAck func(requestId string)

+ OnRpcRequest func(callerIdentity, requestId, method, payload string, ...)

+ OnRpcResponse func(requestId string, payload *string, error *RpcError)

+ OnStreamChunk func(*livekit.DataStream_Chunk)

+ OnStreamHeader func(*livekit.DataStream_Header, string)

+ OnStreamTrailer func(*livekit.DataStream_Trailer)

+ func (e *RTCEngine) OnClose(onClose func())

type Room

+ func (r *Room) RegisterByteStreamHandler(topic string, handler ByteStreamHandler) error

+ func (r *Room) RegisterRpcMethod(method string, handler RpcHandlerFunc) error

+ func (r *Room) RegisterTextStreamHandler(topic string, handler TextStreamHandler) error

+ func (r *Room) UnregisterByteStreamHandler(topic string)

+ func (r *Room) UnregisterRpcMethod(method string)

+ func (r *Room) UnregisterTextStreamHandler(topic string)

type RoomServiceClient

+ func (c *RoomServiceClient) ForwardParticipant(ctx context.Context, req *livekit.ForwardParticipantRequest) (*livekit.ForwardParticipantResponse, error)

+ type RpcError struct

+ Code RpcErrorCode

+ Data *string

+ Message string

+ func NewRpcError(code RpcErrorCode, message string, data *string) *RpcError

+ func (e *RpcError) Error() string

+ type RpcErrorCode uint32

+ const RpcApplicationError

+ const RpcConnectionTimeout

+ const RpcRecipientDisconnected

+ const RpcRecipientNotFound

+ const RpcRequestPayloadTooLarge

+ const RpcResponsePayloadTooLarge

+ const RpcResponseTimeout

+ const RpcSendFailed

+ const RpcUnsupportedMethod

+ const RpcUnsupportedServer

+ const RpcUnsupportedVersion

+ type RpcHandlerFunc func(data RpcInvocationData) (string, error)

+ type RpcInvocationData struct

+ CallerIdentity string

+ Payload string

+ RequestID string

+ ResponseTimeout time.Duration

type SIPClient

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

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

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

+ type StreamBytesOptions struct

+ Attributes map[string]string

+ DestinationIdentities []string

+ FileName *string

+ MimeType string

+ OnProgress func(progress float64)

+ StreamId *string

+ Topic string

+ TotalSize uint64

+ type StreamTextOptions struct

+ AttachedStreamIds []string

+ Attachments []string

+ Attributes map[string]string

+ DestinationIdentities []string

+ OnProgress func(progress float64)

+ ReplyToStreamId *string

+ StreamId *string

+ Topic string

+ TotalSize uint64

+ type TextStreamHandler func(reader *TextStreamReader, participantIdentity string)

+ type TextStreamInfo struct

+ type TextStreamReader struct

+ Info TextStreamInfo

+ func NewTextStreamReader(info TextStreamInfo, totalChunkCount *uint64) *TextStreamReader

+ func (r *TextStreamReader) ReadAll() string

+ func (r *TextStreamReader) ReadRune() (rune, int, error)

+ func (r *TextStreamReader) ReadString(delim byte) (string, error)

+ func (r TextStreamReader) OnProgress(onProgress *func(progress float64))

+ func (r TextStreamReader) Read(bytes []byte) (int, error)

+ func (r TextStreamReader) ReadByte() (byte, error)

+ func (r TextStreamReader) ReadBytes(delim byte) ([]byte, error)

+ type TextStreamWriter struct

+ Info TextStreamInfo

+ func (w TextStreamWriter) Close()

+ func (w TextStreamWriter) Write(data T, onDone *func())

Feb 25, 2025

Changes in this version

+ func SIPStatusFrom(err error) *livekit.SIPStatus

type RTCEngine

+ OnSignalClientConnected func(*livekit.JoinResponse)

Jan 27, 2025

Changes in this version

type DisconnectionReason

+ const DuplicateIdentity

+ const OtherReason

+ const ParticipantRemoved

+ const RoomClosed

type RTCEngine

+ func (e *RTCEngine) JoinContext(ctx context.Context, url string, token string, ...) (*livekit.JoinResponse, error)

type SignalClient

+ func (c *SignalClient) JoinContext(ctx context.Context, urlPrefix string, token string, ...) (*livekit.JoinResponse, error)

Dec 27, 2024

Changes in this version

+ const LIVEKIT_HKDF_INFO_BYTES

+ const LIVEKIT_IV_LENGTH

+ const LIVEKIT_KEY_SIZE_BYTES

+ const LIVEKIT_PBKDF_ITERATIONS

+ const LIVEKIT_SDK_SALT

+ var ErrBlockCipherRequired = errors.New("input block cipher cannot be nil")

+ var ErrIncorrectIVLength = errors.New("incorrect iv length")

+ var ErrIncorrectKeyLength = errors.New("incorrect key length for encryption/decryption")

+ var ErrIncorrectSaltLength = errors.New("input salt provided to derivation function cannot be empty or nil")

+ var ErrIncorrectSecretLength = errors.New("input secret provided to derivation function cannot be empty or nil")

+ var ErrUnableGenerateIV = errors.New("unable to generate iv for encryption")

+ func DecryptGCMAudioSample(sample, key, sifTrailer []byte) ([]byte, error)

+ func DecryptGCMAudioSampleCustomCipher(sample, sifTrailer []byte, cipherBlock cipher.Block) ([]byte, error)

+ func DeriveKeyFromBytes(secret []byte) ([]byte, error)

+ func DeriveKeyFromBytesCustomSalt(secret []byte, salt string) ([]byte, error)

+ func DeriveKeyFromString(password string) ([]byte, error)

+ func DeriveKeyFromStringCustomSalt(password, salt string) ([]byte, error)

+ func EncryptGCMAudioSample(sample, key []byte, kid uint8) ([]byte, error)

+ func EncryptGCMAudioSampleCustomCipher(sample []byte, kid uint8, cipherBlock cipher.Block) ([]byte, error)

type ParticipantCallback

+ OnTranscriptionReceived func(transcriptionSegments []*TranscriptionSegment, p Participant, ...)

type RTCEngine

+ OnTranscription func(*livekit.Transcription)

type Room

+ func (r *Room) SifTrailer() []byte

type SIPClient

+ func (s *SIPClient) GetSIPDispatchRulesByIDs(ctx context.Context, ids []string) ([]*livekit.SIPDispatchRuleInfo, error)

+ func (s *SIPClient) GetSIPInboundTrunksByIDs(ctx context.Context, ids []string) ([]*livekit.SIPInboundTrunkInfo, error)

+ func (s *SIPClient) GetSIPOutboundTrunksByIDs(ctx context.Context, ids []string) ([]*livekit.SIPOutboundTrunkInfo, error)

type TrackPublicationOptions

+ Encryption livekit.Encryption_Type

+ type TranscriptionSegment struct

+ EndTime uint64

+ Final bool

+ ID string

+ Language string

+ StartTime uint64

+ Text string

+ func ExtractTranscriptionSegments(transcription *livekit.Transcription) []*TranscriptionSegment

Nov 15, 2024

Changes in this version

+ var ErrAborted = errors.New("operation was aborted")

type ParticipantCallback

+ OnLocalTrackPublished func(publication *LocalTrackPublication, lp *LocalParticipant)

+ OnLocalTrackUnpublished func(publication *LocalTrackPublication, lp *LocalParticipant)

type RTCEngine

+ CbGetLocalParticipantSID func() string

+ OnLocalTrackUnpublished func(response *livekit.TrackUnpublishedResponse)

+ OnTrackRemoteMuted func(request *livekit.MuteTrackRequest)

+ func (e *RTCEngine) RegisterTrackPublishedListener(cid string, c chan *livekit.TrackPublishedResponse)

+ func (e *RTCEngine) UnregisterTrackPublishedListener(cid string)

+ type SignalClientConnectParams struct

+ AutoSubscribe bool

+ DisableRegionDiscovery bool

+ ICETransportPolicy webrtc.ICETransportPolicy

+ Interceptors []interceptor.Factory

+ Pacer pacer.Factory

+ Reconnect bool

+ RetransmitBufferSize uint16

Oct 15, 2024

Changes in this version

type DisconnectionReason

+ const RejectedByUser

+ const UserUnavailable

+ func GetDisconnectionReason(reason livekit.DisconnectReason) DisconnectionReason

type LocalParticipant

+ func (p *LocalParticipant) SetSubscriptionPermission(sp *livekit.SubscriptionPermission)

type Room

+ func (r *Room) DisconnectWithReason(reason livekit.DisconnectReason)

type SIPClient

+ func (s *SIPClient) TransferSIPParticipant(ctx context.Context, in *livekit.TransferSIPParticipantRequest) (*emptypb.Empty, error)

type SignalClient

+ func (c *SignalClient) SendLeaveWithReason(reason livekit.DisconnectReason) error

Aug 12, 2024

Changes in this version

+ type AgentDispatchClient struct

+ func NewAgentDispatchServiceClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *AgentDispatchClient

+ func (c *AgentDispatchClient) CreateDispatch(ctx context.Context, req *livekit.CreateAgentDispatchRequest) (*livekit.AgentDispatch, error)

+ func (c *AgentDispatchClient) DeleteDispatch(ctx context.Context, req *livekit.DeleteAgentDispatchRequest) (*livekit.AgentDispatch, error)

+ func (c *AgentDispatchClient) ListDispatch(ctx context.Context, req *livekit.ListAgentDispatchRequest) (*livekit.ListAgentDispatchResponse, error)

type ConnectInfo

+ ParticipantAttributes map[string]string

type ConnectOption

+ func WithDisableRegionDiscovery() ConnectOption

type LocalParticipant

+ func (p *LocalParticipant) Attributes() map[string]string

+ func (p *LocalParticipant) SetAttributes(attrs map[string]string)

type LocalTrack

+ func (s *LocalTrack) SetLogger(l protoLogger.Logger)

type LocalTrackPublication

+ func (p *LocalTrackPublication) SimulateDisconnection(duration time.Duration)

type PCTransport

+ func (t *PCTransport) SetConfiguration(config webrtc.Configuration) error

+ func (t *PCTransport) SetLogger(l protoLogger.Logger)

type Participant

+ Attributes func() map[string]string

+ type ParticipantAttributesChangedFunc func(changed map[string]string, p Participant)

type ParticipantCallback

+ OnAttributesChanged ParticipantAttributesChangedFunc

type RTCEngine

+ func (e *RTCEngine) SetLogger(l protoLogger.Logger)

type RemoteParticipant

+ func (p *RemoteParticipant) Attributes() map[string]string

type Room

+ func (r *Room) PrepareConnection(url, token string) error

+ func (r *Room) SetLogger(l protoLogger.Logger)

type SignalClient

+ func (c *SignalClient) SetLogger(l protoLogger.Logger)

Jun 20, 2024

Changes in this version

+ type ConnectionState string

+ const ConnectionStateConnected

+ const ConnectionStateDisconnected

+ const ConnectionStateReconnecting

type Room

+ func (r *Room) ConnectionState() ConnectionState

type SIPClient

+ 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) ListSIPInboundTrunk(ctx context.Context, in *livekit.ListSIPInboundTrunkRequest) (*livekit.ListSIPInboundTrunkResponse, error)

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

Apr 20, 2024

Changes in this version

type ConnectOption

+ func WithICETransportPolicy(iceTransportPolicy webrtc.ICETransportPolicy) ConnectOption

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

type LocalTrack

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

type PCTransportParams

+ Interceptors []interceptor.Factory

Apr 2, 2024

Changes in this version

+ type DisconnectionReason string

+ const Failed

+ const LeaveRequested

type RoomCallback

+ OnDisconnectedWithReason func(reason DisconnectionReason)

Mar 11, 2024

Changes in this version

+ type DataPacket interface

+ ToProto func() *livekit.DataPacket

type LocalParticipant

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

type ParticipantCallback

+ OnDataPacket func(data DataPacket, params DataReceiveParams)

type RTCEngine

+ OnDataPacket func(identity string, dataPacket DataPacket)

+ type UserDataPacket struct

+ Payload []byte

+ Topic string

+ func UserData(data []byte) *UserDataPacket

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

Mar 6, 2024

Changes in this version

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

type RTCEngine

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

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

Mar 6, 2024

Changes in this version

type PCTransportParams

+ IsSender bool

Feb 2, 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 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 WithPacer(pacer pacer.Factory) ConnectOption

+ func WithRetransmitBufferSize(val uint16) ConnectOption

+ 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 EgressClient struct

+ func NewEgressClient(url string, apiKey string, secretKey string) *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) *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) 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) 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

+ 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)

+ 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)

+ OnDataReceived func(userPacket *livekit.UserPacket)

+ OnDisconnected func()

+ 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) 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) 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()

+ 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) *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) *SIPClient

+ func (s *SIPClient) CreateSIPDispatchRule(ctx context.Context, in *livekit.CreateSIPDispatchRuleRequest) (*livekit.SIPDispatchRuleInfo, 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) 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