routing

type LocalNode *livekit.Node

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

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

type MessageSink interface {
	WriteMessage(msg proto.Message) error
	Close()
	OnClose(f func())
}

type MessageSource interface {
	// ReadChan exposes a one way channel to make it easier to use with select
	ReadChan() <-chan proto.Message
}

type NewParticipantCallback func(roomName string, pi ParticipantInit, requestSource MessageSource, responseSink MessageSink)

type NodeSelector interface {
	SelectNode(nodes []*livekit.Node, room *livekit.Room) (*livekit.Node, error)
}

type NodeStats struct {
	NumRooms         int32
	NumClients       int32
	NumVideoChannels int32
	NumAudioChannels int32
	BytesPerMin      int64
}

type ParticipantInit struct {
	Identity        string
	Metadata        string
	Reconnect       bool
	Permission      *livekit.ParticipantPermission
	ProtocolVersion int32
	UsePlanB        bool
	AutoSubscribe   bool
}

type RTCMessageCallback func(roomName, identity string, msg *livekit.RTCNodeMessage)

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

type RandomSelector struct {
}

type RedisRouter struct {
	LocalRouter
	// contains filtered or unexported fields
}

type Router interface {
	GetNodeForRoom(roomName string) (*livekit.Node, error)
	SetNodeForRoom(roomName string, nodeId string) error
	ClearRoomState(roomName string) error
	RegisterNode() error
	UnregisterNode() error
	RemoveDeadNodes() error
	GetNode(nodeId string) (*livekit.Node, error)
	ListNodes() ([]*livekit.Node, error)

	// StartParticipantSignal participant signal connection is ready to start
	StartParticipantSignal(roomName string, pi ParticipantInit) (connectionId string, reqSink MessageSink, resSource MessageSource, err error)

	// CreateRTCSink sends a message to RTC node
	CreateRTCSink(roomName, identity string) (MessageSink, error)

	// OnNewParticipantRTC is called to start a new participant's RTC connection
	OnNewParticipantRTC(callback NewParticipantCallback)

	// OnRTCMessage is called to execute actions on the RTC node
	OnRTCMessage(callback RTCMessageCallback)

	Start() error
	Stop()
}

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