livekit

Documentation

Index

• func NewLiveKit(conf *config.RTC) rtc.MeetingRtc
• func NewRTC(roomID string, liveKit *LiveKit) rtc.CallbackInterface
• type CallbackLiveKit
  • func (r *CallbackLiveKit) OnMeetingDisconnected(ctx context.Context, roomID string)
  • func (r *CallbackLiveKit) OnMeetingUnmute(ctx context.Context, roomID string, streamType string, mute bool, ...)
  • func (r *CallbackLiveKit) OnRoomDisconnected(ctx context.Context)
  • func (r *CallbackLiveKit) OnRoomParticipantConnected(ctx context.Context, userID string)
  • func (r *CallbackLiveKit) OnRoomParticipantDisconnected(ctx context.Context, userID string)
• type LiveKit
  • func (x *LiveKit) CloseRoom(ctx context.Context, roomID string) error
  • func (x *LiveKit) CreateRoom(ctx context.Context, meetingID, identify string, ...) (sID, token, liveUrl string, err error)
  • func (x *LiveKit) GetAllRooms(ctx context.Context) ([]*livekit.Room, error)
  • func (x *LiveKit) GetJoinToken(ctx context.Context, roomID, identity string, ...) (string, string, error)
  • func (x *LiveKit) GetParticipantMetaData(ctx context.Context, roomID, userID string) (*meeting.ParticipantMetaData, error)
  • func (x *LiveKit) GetParticipantUserIDs(ctx context.Context, roomID string) ([]string, error)
  • func (x *LiveKit) GetRoom(ctx context.Context, roomID string) (*livekit.Room, error)
  • func (x *LiveKit) GetRoomData(ctx context.Context, roomID string) (*meeting.MeetingMetadata, error)
  • func (x *LiveKit) IsNotFound(err error) bool
  • func (x *LiveKit) ListParticipants(ctx context.Context, roomID string) ([]*livekit.ParticipantInfo, error)
  • func (x *LiveKit) RemoveParticipant(ctx context.Context, roomID, userID string) error
  • func (x *LiveKit) RoomIsExist(ctx context.Context, meetingID string) (string, error)
  • func (x *LiveKit) SendRoomData(ctx context.Context, roomID string, userIDList *[]string, ...) error
  • func (x *LiveKit) ToggleMimeStream(ctx context.Context, roomID, userID, mineType string, mute bool) error
  • func (x *LiveKit) UpdateMetaData(ctx context.Context, updateData *meeting.MeetingMetadata) error
  • func (x *LiveKit) UpdateParticipantData(ctx context.Context, data *meeting.ParticipantMetaData, roomID, userID string) error

Functions

func NewLiveKit

func NewLiveKit(conf *config.RTC) rtc.MeetingRtc

func NewRTC

func NewRTC(roomID string, liveKit *LiveKit) rtc.CallbackInterface

Types

type CallbackLiveKit

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

func (*CallbackLiveKit) OnMeetingDisconnected

func (r *CallbackLiveKit) OnMeetingDisconnected(ctx context.Context, roomID string)

func (*CallbackLiveKit) OnMeetingUnmute

func (r *CallbackLiveKit) OnMeetingUnmute(ctx context.Context, roomID string, streamType string, mute bool, userIDs []string)

func (*CallbackLiveKit) OnRoomDisconnected

func (r *CallbackLiveKit) OnRoomDisconnected(ctx context.Context)

func (*CallbackLiveKit) OnRoomParticipantConnected

func (r *CallbackLiveKit) OnRoomParticipantConnected(ctx context.Context, userID string)

func (*CallbackLiveKit) OnRoomParticipantDisconnected

func (r *CallbackLiveKit) OnRoomParticipantDisconnected(ctx context.Context, userID string)

type LiveKit

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

func (*LiveKit) CloseRoom

func (x *LiveKit) CloseRoom(ctx context.Context, roomID string) error

func (*LiveKit) CreateRoom

func (x *LiveKit) CreateRoom(ctx context.Context, meetingID, identify string, roomMetaData *meeting.MeetingMetadata, participantMetaData *meeting.ParticipantMetaData, userRpc *rpcclient.User) (sID, token, liveUrl string, err error)

func (*LiveKit) GetAllRooms

func (x *LiveKit) GetAllRooms(ctx context.Context) ([]*livekit.Room, error)

func (*LiveKit) GetJoinToken

func (x *LiveKit) GetJoinToken(ctx context.Context, roomID, identity string, metadata *meeting.ParticipantMetaData, isListener bool) (string, string, error)

func (*LiveKit) GetParticipantMetaData

func (x *LiveKit) GetParticipantMetaData(ctx context.Context, roomID, userID string) (*meeting.ParticipantMetaData, error)

func (*LiveKit) GetParticipantUserIDs

func (x *LiveKit) GetParticipantUserIDs(ctx context.Context, roomID string) ([]string, error)

func (*LiveKit) GetRoom

func (x *LiveKit) GetRoom(ctx context.Context, roomID string) (*livekit.Room, error)

func (*LiveKit) GetRoomData

func (x *LiveKit) GetRoomData(ctx context.Context, roomID string) (*meeting.MeetingMetadata, error)

func (*LiveKit) IsNotFound

func (x *LiveKit) IsNotFound(err error) bool

func (*LiveKit) ListParticipants

func (x *LiveKit) ListParticipants(ctx context.Context, roomID string) ([]*livekit.ParticipantInfo, error)

func (*LiveKit) RemoveParticipant

func (x *LiveKit) RemoveParticipant(ctx context.Context, roomID, userID string) error

func (*LiveKit) RoomIsExist

func (x *LiveKit) RoomIsExist(ctx context.Context, meetingID string) (string, error)

func (*LiveKit) SendRoomData

func (x *LiveKit) SendRoomData(ctx context.Context, roomID string, userIDList *[]string, sendData *meeting.NotifyMeetingData) error

func (*LiveKit) ToggleMimeStream

func (x *LiveKit) ToggleMimeStream(ctx context.Context, roomID, userID, mineType string, mute bool) error

func (*LiveKit) UpdateMetaData

func (x *LiveKit) UpdateMetaData(ctx context.Context, updateData *meeting.MeetingMetadata) error

func (*LiveKit) UpdateParticipantData

func (x *LiveKit) UpdateParticipantData(ctx context.Context, data *meeting.ParticipantMetaData, roomID, userID string) error