signaling

package module

Go to main page

Versions in this module

v1

v1.3.1

May 23, 2024

v1.3.0

May 22, 2024

Changes in this version

+ const ExtensionUrlPlayoutDelay

+ const ExtensionUrlVideoOrientation

+ var DefaultTrustedProxies = DefaultPrivateIps()

+ var ErrBruteforceDetected = errors.New("bruteforce detected")

+ var ErrInvalidSdp = NewError("invalid_sdp", "Payload does not contain a valid SDP.")

+ var ErrNoSdp = NewError("no_sdp", "Payload does not contain a SDP.")

+ var ErrNoSuchResumeId = fmt.Errorf("unknown resume id")

+ var ErrRemoteStreamsNotSupported = errors.New("Need Janus 1.1.0 for remote streams")

+ var TooManyRequests = NewError("too_many_requests", "Too many requests.")

+ func CatchLogForTest(t testing.TB)

+ func GetRealUserIP(r *http.Request, trusted *AllowedIps) string

+ func GetStringOptionWithEnv(config *goconf.ConfigFile, section string, option string) (string, error)

+ func RegisterThrottleStats()

+ func SlicesSortFunc[T any](l []T, f func(a T, b T) int)

type AllowedIps

+ func DefaultPrivateIps() *AllowedIps

+ func (a *AllowedIps) String() string

type CertPoolReloader

+ func (r *CertPoolReloader) Close()

type CertificateReloader

+ func (r *CertificateReloader) Close()

type Client

+ func (c *Client) Context() context.Context

+ func (c *Client) GetSessionId() string

+ func (c *Client) SetHandler(handler ClientHandler)

+ func (c *Client) SetSessionId(sessionId string)

type ClientSession

+ func (s *ClientSession) Context() context.Context

type CommandProxyClientMessage

+ Hostname string

+ Port int

+ RemoteToken string

+ RemoteUrl string

+ RtcpPort int

type CommandProxyServerMessage

+ Streams []PublisherStream

+ type EventProxyServerBandwidth struct

+ Incoming *float64

+ Outgoing *float64

+ func (b *EventProxyServerBandwidth) String() string

+ func (b EventProxyServerBandwidth) AllowIncoming() bool

+ func (b EventProxyServerBandwidth) AllowOutgoing() bool

type EventProxyServerMessage

+ Bandwidth *EventProxyServerBandwidth

type GrpcClient

+ func (c *GrpcClient) LookupResumeId(ctx context.Context, resumeId string) (*LookupResumeIdReply, error)

+ func (c *GrpcClient) ProxySession(ctx context.Context, sessionId string, receiver ProxySessionReceiver) (*SessionProxy, error)

type GrpcServer

+ func (s *GrpcServer) LookupResumeId(ctx context.Context, request *LookupResumeIdRequest) (*LookupResumeIdReply, error)

+ func (s *GrpcServer) ProxySession(request RpcSessions_ProxySessionServer) error

+ type GrpcServerHub interface

+ GetBackend func(u *url.URL) *Backend

+ GetSessionByPublicId func(sessionId string) Session

+ GetSessionByResumeId func(resumeId string) Session

+ GetSessionIdByRoomSessionId func(roomSessionId string) (string, error)

+ type HandlerClient interface

+ Close func()

+ Context func() context.Context

+ Country func() string

+ GetSession func() Session

+ IsAuthenticated func() bool

+ IsConnected func() bool

+ RemoteAddr func() string

+ SendByeResponse func(message *ClientMessage) bool

+ SendByeResponseWithReason func(message *ClientMessage, reason string) bool

+ SendError func(e *Error) bool

+ SendMessage func(message WritableClientMessage) bool

+ SetSession func(session Session)

+ UserAgent func() string

type Hub

+ func (h *Hub) GetBackend(u *url.URL) *Backend

+ func (h *Hub) GetSessionByResumeId(resumeId string) Session

+ func (h *Hub) GetSessionIdByRoomSessionId(roomSessionId string) (string, error)

+ func (h *Hub) IsShutdownScheduled() bool

+ func (h *Hub) ScheduleShutdown()

+ func (h *Hub) ShutdownChannel() <-chan struct{}

type McuPublisher

+ GetStreams func(ctx context.Context) ([]PublisherStream, error)

+ PublishRemote func(ctx context.Context, remoteId string, hostname string, port int, rtcpPort int) error

+ UnpublishRemote func(ctx context.Context, remoteId string) error

+ type McuRemotePublisher interface

+ type McuRemotePublisherProperties interface

+ Port func() int

+ RtcpPort func() int

+ type McuRemoteSubscriber interface

type ProxyClientMessage

+ func (m *ProxyClientMessage) String() string

type ProxyServerMessage

+ func (r *ProxyServerMessage) String() string

+ type ProxySessionReceiver interface

+ Country func() string

+ OnProxyClose func(err error)

+ OnProxyMessage func(message *ServerSessionMessage) error

+ RemoteAddr func() string

+ UserAgent func() string

+ type PublisherStream struct

+ Codec string

+ Description string

+ Disabled bool

+ Dtx bool

+ ExtIdPlayoutDelay int

+ ExtIdVideoOrientation int

+ Fec bool

+ Mid string

+ Mindex int

+ ProfileH264 string

+ ProfileVP9 string

+ Simulcast bool

+ Stereo bool

+ Svc bool

+ Type string

+ type RemoteMcu interface

+ NewRemotePublisher func(ctx context.Context, listener McuListener, ...) (McuRemotePublisher, error)

+ NewRemoteSubscriber func(ctx context.Context, listener McuListener, publisher McuRemotePublisher) (McuRemoteSubscriber, error)

+ type RemotePublisherController interface

+ GetStreams func(ctx context.Context) ([]PublisherStream, error)

+ PublisherId func() string

+ StartPublishing func(ctx context.Context, publisher McuRemotePublisherProperties) error

+ type RemoteSession struct

+ func NewRemoteSession(hub *Hub, client *Client, remoteClient *GrpcClient, sessionId string) (*RemoteSession, error)

+ func (s *RemoteSession) Close()

+ func (s *RemoteSession) Country() string

+ func (s *RemoteSession) IsConnected() bool

+ func (s *RemoteSession) OnClosed(client HandlerClient)

+ func (s *RemoteSession) OnLookupCountry(client HandlerClient) string

+ func (s *RemoteSession) OnMessageReceived(client HandlerClient, message []byte)

+ func (s *RemoteSession) OnProxyClose(err error)

+ func (s *RemoteSession) OnProxyMessage(msg *ServerSessionMessage) error

+ func (s *RemoteSession) OnRTTReceived(client HandlerClient, rtt time.Duration)

+ func (s *RemoteSession) RemoteAddr() string

+ func (s *RemoteSession) SendMessage(message WritableClientMessage) bool

+ func (s *RemoteSession) Start(message *ClientMessage) error

+ func (s *RemoteSession) UserAgent() string

type Session

+ Context func() context.Context

+ SendError func(e *Error) bool

+ SendMessage func(message *ServerMessage) bool

+ type SessionProxy struct

+ func (p *SessionProxy) Close() error

+ func (p *SessionProxy) Send(message *ClientSessionMessage) error

+ type ThrottleFunc func(ctx context.Context)

+ type Throttler interface

+ CheckBruteforce func(ctx context.Context, client string, action string) (ThrottleFunc, error)

+ Close func()

+ func NewMemoryThrottler() (Throttler, error)

type VirtualSession

+ func (s *VirtualSession) Context() context.Context

+ func (s *VirtualSession) SendError(e *Error) bool

+ func (s *VirtualSession) SendMessage(message *ServerMessage) bool

v1.2.4

Apr 3, 2024

Changes in this version

+ func IsValidStreamType(s string) bool

+ func RegisterHttpClientPoolStats()

type CertPoolReloader

+ func (r *CertPoolReloader) GetReloadCounter() uint64

type CertificateReloader

+ func (r *CertificateReloader) GetReloadCounter() uint64

type CommandProxyServerMessage

+ Bitrate int

+ type FileWatcher struct

+ func NewFileWatcher(filename string, callback FileWatcherCallback) (*FileWatcher, error)

+ func (f *FileWatcher) Close() error

+ type FileWatcherCallback func(filename string)

type McuClient

+ MaxBitrate func() int

type MessageClientMessageData

+ func (m *MessageClientMessageData) CheckValid() error

+ type StreamType string

+ const StreamTypeAudio

+ const StreamTypeScreen

+ const StreamTypeVideo

v1.2.3

Jan 31, 2024

Changes in this version

+ type DnsMonitor struct

+ func NewDnsMonitor(interval time.Duration) (*DnsMonitor, error)

+ func (m *DnsMonitor) Add(target string, callback DnsMonitorCallback) (*DnsMonitorEntry, error)

+ func (m *DnsMonitor) Remove(entry *DnsMonitorEntry)

+ func (m *DnsMonitor) Start() error

+ func (m *DnsMonitor) Stop()

+ type DnsMonitorCallback = func(entry *DnsMonitorEntry, all []net.IP, add []net.IP, keep []net.IP, ...)

+ type DnsMonitorEntry struct

+ func (e *DnsMonitorEntry) URL() string

+ type McuProxy interface

+ AddConnection func(ignoreErrors bool, url string, ips ...net.IP) error

+ KeepConnection func(url string, ips ...net.IP)

+ RemoveConnection func(url string, ips ...net.IP)

+ type ProxyConfig interface

+ Reload func(config *goconf.ConfigFile) error

+ Start func() error

+ Stop func()

+ func NewProxyConfigEtcd(config *goconf.ConfigFile, etcdClient *EtcdClient, proxy McuProxy) (ProxyConfig, error)

+ func NewProxyConfigStatic(config *goconf.ConfigFile, proxy McuProxy, dnsMonitor *DnsMonitor) (ProxyConfig, error)

v1.2.2

Dec 11, 2023

Changes in this version

+ func GetStringOptions(config *goconf.ConfigFile, section string, ignoreErrors bool) (map[string]string, error)

v1.2.1

Nov 15, 2023

Changes in this version

type Hub

+ func (h *Hub) GetDialoutSession(roomId string, backend *Backend) *ClientSession

type InternalServerDialoutRequest

+ Backend string

v1.2.0

Oct 30, 2023

Changes in this version

+ const ClientFeatureStartDialout

+ const ServerFeatureDialout

type AsyncMessage

+ func (m *AsyncMessage) String() string

+ type BackendResponseWithStatus interface

+ Status func() int

+ type BackendRoomDialoutError struct

+ Code string

+ Message string

+ type BackendRoomDialoutRequest struct

+ Number string

+ Options json.RawMessage

+ func (r *BackendRoomDialoutRequest) ValidateNumber() *Error

+ type BackendRoomDialoutResponse struct

+ CallId string

+ Error *Error

+ type BackendRoomTransientRequest struct

+ Action TransientAction

+ Key string

+ TTL time.Duration

+ Value interface{}

type BackendServerRoomRequest

+ Dialout *BackendRoomDialoutRequest

+ Transient *BackendRoomTransientRequest

+ type BackendServerRoomResponse struct

+ Dialout *BackendRoomDialoutResponse

+ Type string

type ClientSession

+ func (s *ClientSession) ClearResponseHandler(id string)

+ func (s *ClientSession) HandleResponse(id string, handler ResponseHandlerFunc)

+ func (s *ClientSession) ProcessResponse(message *ClientMessage) bool

+ func (s *ClientSession) UpdateRoomSessionId(roomSessionId string) error

+ type DialoutErrorResponse struct

+ func (r *DialoutErrorResponse) Status() int

+ type DialoutInternalClientMessage struct

+ Error *Error

+ RoomId string

+ Status *DialoutStatusInternalClientMessage

+ Type string

+ func (m *DialoutInternalClientMessage) CheckValid() error

+ type DialoutStatus string

+ var DialoutStatusAccepted DialoutStatus = "accepted"

+ var DialoutStatusCleared DialoutStatus = "cleared"

+ var DialoutStatusConnected DialoutStatus = "connected"

+ var DialoutStatusRejected DialoutStatus = "rejected"

+ var DialoutStatusRinging DialoutStatus = "ringing"

+ type DialoutStatusInternalClientMessage struct

+ CallId string

+ Cause string

+ Code int

+ Message string

+ Status DialoutStatus

+ type Flags struct

+ func (f *Flags) Add(flags uint32) bool

+ func (f *Flags) Get() uint32

+ func (f *Flags) Remove(flags uint32) bool

+ func (f *Flags) Set(flags uint32) bool

type InternalClientMessage

+ Dialout *DialoutInternalClientMessage

+ type InternalServerDialoutRequest struct

+ Request *BackendRoomDialoutRequest

+ RoomId string

+ type InternalServerMessage struct

+ Dialout *InternalServerDialoutRequest

+ Type string

+ type ResponseHandlerFunc func(message *ClientMessage) bool

type Room

+ func (r *Room) SetTransientDataTTL(key string, value interface{}, ttl time.Duration)

+ type RoomErrorDetails struct

+ Room *RoomServerMessage

type ServerMessage

+ Dialout *DialoutInternalClientMessage

+ Internal *InternalServerMessage

+ type TransientAction string

+ const TransientActionDelete

+ const TransientActionSet

type TransientData

+ func (t *TransientData) CompareAndSetTTL(key string, old, value interface{}, ttl time.Duration) bool

+ func (t *TransientData) SetTTL(key string, value interface{}, ttl time.Duration) bool

type TransientDataClientMessage

+ TTL time.Duration

v1.1.3

Jul 5, 2023

Changes in this version

+ type AllowedIps struct

+ func DefaultAllowedIps() *AllowedIps

+ func ParseAllowedIps(allowed string) (*AllowedIps, error)

+ func (a *AllowedIps) Allowed(ip net.IP) bool

+ func (a *AllowedIps) Empty() bool

v1.1.2

Mar 13, 2023

v1.1.1

Feb 22, 2023

v1.1.0

Feb 22, 2023

Changes in this version

+ const ClientFeatureInternalInCall

+ const ServerFeatureSwitchTo

+ var ErrIncompleteResponse = errors.New("incomplete OCS response")

+ var ErrThrottledResponse = errors.New("throttled OCS response")

type AddSessionInternalClientMessage

+ InCall *int

+ type BackendRoomSwitchToMessageRequest struct

+ RoomId string

+ Sessions *json.RawMessage

+ SessionsList BackendRoomSwitchToSessionsList

+ SessionsMap BackendRoomSwitchToSessionsMap

+ type BackendRoomSwitchToSessionsList []string

+ type BackendRoomSwitchToSessionsMap map[string]json.RawMessage

type BackendServerRoomRequest

+ SwitchTo *BackendRoomSwitchToMessageRequest

+ type ChannelWaiters struct

+ func (w *ChannelWaiters) Add(ch chan struct{}) uint64

+ func (w *ChannelWaiters) Remove(id uint64)

+ func (w *ChannelWaiters) Wakeup()

+ type ClientGeoIpHandler interface

+ OnLookupCountry func(*Client) string

+ type ClientHandler interface

+ OnClosed func(*Client)

+ OnMessageReceived func(*Client, []byte)

+ OnRTTReceived func(*Client, time.Duration)

type ClientSession

+ func (s *ClientSession) GetInCall() int

+ func (s *ClientSession) SetInCall(inCall int) bool

+ type Closer struct

+ C chan struct{}

+ func NewCloser() *Closer

+ func (c *Closer) Close()

+ func (c *Closer) IsClosed() bool

type EventServerMessage

+ SwitchTo *EventServerMessageSwitchTo

+ type EventServerMessageSwitchTo struct

+ Details json.RawMessage

+ RoomId string

type Hub

+ func (h *Hub) OnClosed(client *Client)

+ func (h *Hub) OnLookupCountry(client *Client) string

+ func (h *Hub) OnMessageReceived(client *Client, data []byte)

+ func (h *Hub) OnRTTReceived(client *Client, rtt time.Duration)

+ type InCallInternalClientMessage struct

+ InCall int

+ func (m *InCallInternalClientMessage) CheckValid() error

type InternalClientMessage

+ InCall *InCallInternalClientMessage

+ type SessionChangeFlag int

+ const SessionChangeFlags

+ const SessionChangeInCall

type UpdateSessionInternalClientMessage

+ InCall *int

type VirtualSession

+ func (s *VirtualSession) GetInCall() int

+ func (s *VirtualSession) SetInCall(inCall int) bool

v1.0.0

Aug 4, 2022

Changes in this version

+ const BackendTypeEtcd

+ const BackendTypeStatic

+ const ConfigKeyHelloV2TokenKey

+ const DefaultBackendType

+ const DefaultGrpcTargetType

+ const GrpcTargetTypeEtcd

+ const GrpcTargetTypeStatic

+ const HelloVersionV1

+ const HelloVersionV2

+ const NatsLoopbackUrl

+ const ServerFeatureHelloV2

+ const ServerFeatureWelcome

+ var CertificateCheckInterval = time.Minute

+ var DefaultWelcomeFeatures = []string

+ var GrpcServerId string

+ var InvalidHelloVersion = NewError("invalid_hello_version", "The hello version is not supported.")

+ var TokenExpired = NewError("token_expired", "The token is expired.")

+ var TokenNotValidYet = NewError("token_not_valid_yet", "The token is not valid yet.")

+ func GetSubjectForSessionId(sessionId string, backend *Backend) string

+ func NewReloadableCredentials(config *goconf.ConfigFile, server bool) (credentials.TransportCredentials, error)

+ func RegisterGrpcClientStats()

+ func RegisterGrpcServerStats()

+ func WrapSyscallConn(rawConn, newConn net.Conn) net.Conn

+ type AsyncBackendRoomEventListener interface

+ ProcessBackendRoomRequest func(message *AsyncMessage)

+ type AsyncEvents interface

+ Close func()

+ PublishBackendRoomMessage func(roomId string, backend *Backend, message *AsyncMessage) error

+ PublishRoomMessage func(roomId string, backend *Backend, message *AsyncMessage) error

+ PublishSessionMessage func(sessionId string, backend *Backend, message *AsyncMessage) error

+ PublishUserMessage func(userId string, backend *Backend, message *AsyncMessage) error

+ RegisterBackendRoomListener func(roomId string, backend *Backend, listener AsyncBackendRoomEventListener) error

+ RegisterRoomListener func(roomId string, backend *Backend, listener AsyncRoomEventListener) error

+ RegisterSessionListener func(sessionId string, backend *Backend, listener AsyncSessionEventListener) error

+ RegisterUserListener func(userId string, backend *Backend, listener AsyncUserEventListener) error

+ UnregisterBackendRoomListener func(roomId string, backend *Backend, listener AsyncBackendRoomEventListener)

+ UnregisterRoomListener func(roomId string, backend *Backend, listener AsyncRoomEventListener)

+ UnregisterSessionListener func(sessionId string, backend *Backend, listener AsyncSessionEventListener)

+ UnregisterUserListener func(userId string, backend *Backend, listener AsyncUserEventListener)

+ func NewAsyncEvents(url string) (AsyncEvents, error)

+ func NewAsyncEventsNats(client NatsClient) (AsyncEvents, error)

+ type AsyncMessage struct

+ AsyncRoom *AsyncRoomMessage

+ Id string

+ Message *ServerMessage

+ Permissions []Permission

+ Room *BackendServerRoomRequest

+ SendOffer *SendOfferMessage

+ SendTime time.Time

+ Type string

+ type AsyncRoomEventListener interface

+ ProcessAsyncRoomMessage func(message *AsyncMessage)

+ type AsyncRoomMessage struct

+ ClientType string

+ SessionId string

+ Type string

+ type AsyncSessionEventListener interface

+ ProcessAsyncSessionMessage func(message *AsyncMessage)

+ type AsyncUserEventListener interface

+ ProcessAsyncUserMessage func(message *AsyncMessage)

type Backend

+ func (b *Backend) Len() int

+ func (b *Backend) Limit() int

+ func (b *Backend) ParsedUrl() *url.URL

+ func (b *Backend) Url() string

type BackendClient

+ func (b *BackendClient) Close()

type BackendConfiguration

+ func (b *BackendConfiguration) Close()

+ type BackendInformationEtcd struct

+ MaxScreenBitrate int

+ MaxStreamBitrate int

+ Secret string

+ SessionLimit uint64

+ Url string

+ func (p *BackendInformationEtcd) CheckValid() error

+ type BackendStorage interface

+ Close func()

+ GetBackend func(u *url.URL) *Backend

+ GetBackends func() []*Backend

+ GetCompatBackend func() *Backend

+ Reload func(config *goconf.ConfigFile)

+ func NewBackendStorageEtcd(config *goconf.ConfigFile, etcdClient *EtcdClient) (BackendStorage, error)

+ func NewBackendStorageStatic(config *goconf.ConfigFile) (BackendStorage, error)

+ type Backoff interface

+ NextWait func() time.Duration

+ Reset func()

+ Wait func(context.Context)

+ func NewExponentialBackoff(initial time.Duration, maxWait time.Duration) (Backoff, error)

type BuiltinRoomSessions

+ func (r *BuiltinRoomSessions) LookupSessionId(ctx context.Context, roomSessionId string, disconnectReason string) (string, error)

type Capabilities

+ func (c *Capabilities) InvalidateCapabilities(u *url.URL)

+ type CertPoolReloader struct

+ func NewCertPoolReloader(certFile string) (*CertPoolReloader, error)

+ func (r *CertPoolReloader) GetCertPool() *x509.CertPool

+ type CertificateReloader struct

+ func NewCertificateReloader(certFile string, keyFile string) (*CertificateReloader, error)

+ func (r *CertificateReloader) GetCertificate(h *tls.ClientHelloInfo) (*tls.Certificate, error)

+ func (r *CertificateReloader) GetClientCertificate(i *tls.CertificateRequestInfo) (*tls.Certificate, error)

type ClientSession

+ func (s *ClientSession) GetOrWaitForPublisher(ctx context.Context, streamType string) McuPublisher

+ func (s *ClientSession) GetVirtualSessions() []*VirtualSession

+ func (s *ClientSession) ProcessAsyncRoomMessage(message *AsyncMessage)

+ func (s *ClientSession) ProcessAsyncSessionMessage(message *AsyncMessage)

+ func (s *ClientSession) ProcessAsyncUserMessage(message *AsyncMessage)

+ func (s *ClientSession) SubscribeEvents() error

+ func (s *ClientSession) SubscribeRoomEvents(roomid string, roomSessionId string) error

+ func (s *ClientSession) UnsubscribeRoomEvents()

+ type EtcdClient struct

+ func NewEtcdClient(config *goconf.ConfigFile, compatSection string) (*EtcdClient, error)

+ func (c *EtcdClient) AddListener(listener EtcdClientListener)

+ func (c *EtcdClient) Close() error

+ func (c *EtcdClient) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)

+ func (c *EtcdClient) IsConfigured() bool

+ func (c *EtcdClient) RemoveListener(listener EtcdClientListener)

+ func (c *EtcdClient) WaitForConnection()

+ func (c *EtcdClient) Watch(ctx context.Context, key string, watcher EtcdClientWatcher, ...) error

+ type EtcdClientListener interface

+ EtcdClientCreated func(client *EtcdClient)

+ type EtcdClientWatcher interface

+ EtcdKeyDeleted func(client *EtcdClient, key string)

+ EtcdKeyUpdated func(client *EtcdClient, key string, value []byte)

+ EtcdWatchCreated func(client *EtcdClient, key string)

type EventServerMessage

+ func (m *EventServerMessage) String() string

+ type GrpcClient struct

+ func NewGrpcClient(target string, ip net.IP, opts ...grpc.DialOption) (*GrpcClient, error)

+ func (c *GrpcClient) Close() error

+ func (c *GrpcClient) GetPublisherId(ctx context.Context, sessionId string, streamType string) (string, string, net.IP, error)

+ func (c *GrpcClient) GetServerId(ctx context.Context) (string, error)

+ func (c *GrpcClient) GetSessionCount(ctx context.Context, u *url.URL) (uint32, error)

+ func (c *GrpcClient) IsSelf() bool

+ func (c *GrpcClient) IsSessionInCall(ctx context.Context, sessionId string, room *Room) (bool, error)

+ func (c *GrpcClient) LookupSessionId(ctx context.Context, roomSessionId string, disconnectReason string) (string, error)

+ func (c *GrpcClient) SetSelf(self bool)

+ func (c *GrpcClient) Target() string

+ type GrpcClients struct

+ func NewGrpcClients(config *goconf.ConfigFile, etcdClient *EtcdClient) (*GrpcClients, error)

+ func (c *GrpcClients) Close()

+ func (c *GrpcClients) EtcdClientCreated(client *EtcdClient)

+ func (c *GrpcClients) EtcdKeyDeleted(client *EtcdClient, key string)

+ func (c *GrpcClients) EtcdKeyUpdated(client *EtcdClient, key string, data []byte)

+ func (c *GrpcClients) EtcdWatchCreated(client *EtcdClient, key string)

+ func (c *GrpcClients) GetClients() []*GrpcClient

+ func (c *GrpcClients) Reload(config *goconf.ConfigFile)

+ func (c *GrpcClients) WaitForInitialized(ctx context.Context) error

+ type GrpcServer struct

+ func NewGrpcServer(config *goconf.ConfigFile) (*GrpcServer, error)

+ func (s *GrpcServer) Close()

+ func (s *GrpcServer) GetPublisherId(ctx context.Context, request *GetPublisherIdRequest) (*GetPublisherIdReply, error)

+ func (s *GrpcServer) GetServerId(ctx context.Context, request *GetServerIdRequest) (*GetServerIdReply, error)

+ func (s *GrpcServer) GetSessionCount(ctx context.Context, request *GetSessionCountRequest) (*GetSessionCountReply, error)

+ func (s *GrpcServer) IsSessionInCall(ctx context.Context, request *IsSessionInCallRequest) (*IsSessionInCallReply, error)

+ func (s *GrpcServer) LookupSessionId(ctx context.Context, request *LookupSessionIdRequest) (*LookupSessionIdReply, error)

+ func (s *GrpcServer) Run() error

+ type GrpcTargetInformationEtcd struct

+ Address string

+ func (p *GrpcTargetInformationEtcd) CheckValid() error

+ type HelloV2AuthParams struct

+ Token string

+ func (p *HelloV2AuthParams) CheckValid() error

+ type HelloV2TokenClaims struct

+ UserData *json.RawMessage

type Room

+ func (r *Room) ProcessBackendRoomRequest(message *AsyncMessage)

type RoomEventServerMessage

+ func (m *RoomEventServerMessage) String() string

type RoomSessions

+ LookupSessionId func(ctx context.Context, roomSessionId string, disconnectReason string) (string, error)

+ type SendOfferMessage struct

+ Data *MessageClientMessageData

+ MessageId string

+ SessionId string

type ServerMessage

+ Welcome *WelcomeServerMessage

+ type SingleNotifier struct

+ func (n *SingleNotifier) NewWaiter() *SingleWaiter

+ func (n *SingleNotifier) Notify()

+ func (n *SingleNotifier) Release(w *SingleWaiter)

+ func (n *SingleNotifier) Reset()

+ type SingleWaiter struct

+ func (w *SingleWaiter) Wait(ctx context.Context) error

type VirtualSession

+ func (s *VirtualSession) ProcessAsyncSessionMessage(message *AsyncMessage)

+ type WelcomeServerMessage struct

+ Country string

+ Features []string

+ Version string

+ func NewWelcomeServerMessage(version string, feature ...string) *WelcomeServerMessage

+ func (m *WelcomeServerMessage) AddFeature(feature ...string)

+ func (m *WelcomeServerMessage) RemoveFeature(feature ...string)

v0

v0.5.0

Jun 2, 2022

Changes in this version

+ const ConfigGroupSignaling

+ const ConfigKeySessionPingLimit

+ const ServerFeatureInCallAll

+ const ServerFeatureTransientData

+ const ServerFeatureUpdateSdp

type AnswerOfferMessage

+ Sid string

type BackendRoomInCallRequest

+ All bool

+ type Capabilities struct

+ func NewCapabilities(version string, pool *HttpClientPool) (*Capabilities, error)

+ func (c *Capabilities) GetIntegerConfig(ctx context.Context, u *url.URL, group, key string) (int, bool)

+ func (c *Capabilities) GetStringConfig(ctx context.Context, u *url.URL, group, key string) (string, bool)

+ func (c *Capabilities) HasCapabilityFeature(ctx context.Context, u *url.URL, feature string) bool

+ type ChatComment map[string]interface

type ClientMessage

+ TransientData *TransientDataClientMessage

type ClientSession

+ func (s *ClientSession) OnUpdateOffer(client McuClient, offer map[string]interface{})

+ func (s *ClientSession) SubscriberSidUpdated(subscriber McuSubscriber)

type CommandProxyClientMessage

+ Sid string

type CommandProxyServerMessage

+ Sid string

type EventProxyServerMessage

+ Sid string

type EventServerMessageSessionEntry

+ func (e *EventServerMessageSessionEntry) Clone() *EventServerMessageSessionEntry

type McuClient

+ Sid func() string

type McuListener

+ OnUpdateOffer func(client McuClient, offer map[string]interface{})

+ SubscriberSidUpdated func(subscriber McuSubscriber)

type McuPublisher

+ SetMedia func(MediaType)

type PayloadProxyClientMessage

+ Sid string

type Permission

+ var DefaultPermissionOverrides = map[Permission]bool{ ... }

+ var PERMISSION_HIDE_DISPLAYNAMES Permission = "hide-displaynames"

+ var PERMISSION_TRANSIENT_DATA Permission = "transient-data"

+ type Pool struct

+ func (p *Pool) Put(c *http.Client)

type Room

+ func (r *Room) PublishUsersInCallChangedAll(inCall int)

+ func (r *Room) RemoveTransientData(key string)

+ func (r *Room) SetTransientData(key string, value interface{})

+ type RoomEventMessageData struct

+ Chat *RoomEventMessageDataChat

+ Type string

+ type RoomEventMessageDataChat struct

+ Comment *ChatComment

type RoomEventServerMessage

+ All bool

+ type RoomPing struct

+ func NewRoomPing(backend *BackendClient, capabilities *Capabilities) (*RoomPing, error)

+ func (p *RoomPing) DeleteRoom(room *Room)

+ func (p *RoomPing) SendPings(ctx context.Context, room *Room, url *url.URL, entries []BackendPingEntry) error

+ func (p *RoomPing) Start()

+ func (p *RoomPing) Stop()

type ServerMessage

+ TransientData *TransientDataServerMessage

+ type TransientData struct

+ func NewTransientData() *TransientData

+ func (t *TransientData) AddListener(listener TransientListener)

+ func (t *TransientData) CompareAndRemove(key string, old interface{}) bool

+ func (t *TransientData) CompareAndSet(key string, old, value interface{}) bool

+ func (t *TransientData) GetData() map[string]interface{}

+ func (t *TransientData) Remove(key string) bool

+ func (t *TransientData) RemoveListener(listener TransientListener)

+ func (t *TransientData) Set(key string, value interface{}) bool

+ type TransientDataClientMessage struct

+ Key string

+ Type string

+ Value *json.RawMessage

+ func (m *TransientDataClientMessage) CheckValid() error

+ type TransientDataServerMessage struct

+ Data map[string]interface{}

+ Key string

+ OldValue interface{}

+ Type string

+ Value interface{}

+ type TransientListener interface

+ SendMessage func(message *ServerMessage) bool

v0.4.1

Jan 25, 2022

Changes in this version

type EventServerMessageSessionEntry

+ RoomSessionId string

type MessageClientMessageData

+ Bitrate int

v0.4.0

Nov 10, 2021

Changes in this version

+ const ServerFeatureAudioVideoPermissions

+ var ErrNotRedirecting = errors.New("not redirecting to different host")

+ var ErrUnsupportedContentType = errors.New("unsupported_content_type")

+ func IsValidContinent(continent string) bool

+ func RegisterBackendConfigurationStats()

+ func RegisterClientStats()

+ func RegisterHubStats()

+ func RegisterJanusMcuStats()

+ func RegisterProxyMcuStats()

+ func RegisterRoomStats()

+ func RegisterStats()

+ func UnregisterJanusMcuStats()

+ func UnregisterProxyMcuStats()

type Backend

+ func (b *Backend) IsUrlAllowed(u *url.URL) bool

type ClientSession

+ func (s *ClientSession) CheckOfferType(streamType string, data *MessageClientMessageData) (MediaType, error)

+ func (s *ClientSession) HasAnyPermission(permission ...Permission) bool

+ func (s *ClientSession) IsAllowedToSend(data *MessageClientMessageData) error

type CommandProxyClientMessage

+ MediaTypes MediaType

type McuPublisher

+ HasMedia func(MediaType) bool

+ type MediaType int

+ const MediaTypeAudio

+ const MediaTypeScreen

+ const MediaTypeVideo

type NatsMessage

+ Id string

type Permission

+ var PERMISSION_MAY_PUBLISH_AUDIO Permission = "publish-audio"

+ var PERMISSION_MAY_PUBLISH_VIDEO Permission = "publish-video"

+ type PermissionError struct

+ func (e *PermissionError) Error() string

+ func (e *PermissionError) Permission() Permission

type Room

+ func (r *Room) IsEqual(other *Room) bool

+ func (r *Room) IsSessionInCall(session Session) bool

+ type SdpError struct

+ func (e *SdpError) Error() string

+ type WrappedSdpError struct

+ func (e *WrappedSdpError) Unwrap() error

v0.3.0

Jul 1, 2021

Changes in this version

+ const AppNameSpreed

+ const BackendVersion

+ const CapabilitiesCacheDuration

+ const DisinviteReasonDeleted

+ const DisinviteReasonDisinvited

+ const FLAG_MUTED_LISTENING

+ const FLAG_MUTED_SPEAKING

+ const FLAG_TALKING

+ const FeatureSignalingV3Api

+ const FlagDisconnected

+ const FlagInCall

+ const FlagWithAudio

+ const FlagWithPhone

+ const FlagWithVideo

+ const HeaderBackendServer

+ const HeaderBackendSignalingChecksum

+ const HeaderBackendSignalingRandom

+ const HelloClientTypeClient

+ const HelloClientTypeInternal

+ const HelloClientTypeVirtual

+ const HelloVersion

+ const JANUS_ERROR_HANDLE_NOT_FOUND

+ const JANUS_ERROR_INVALID_ELEMENT_TYPE

+ const JANUS_ERROR_INVALID_JSON

+ const JANUS_ERROR_INVALID_JSON_OBJECT

+ const JANUS_ERROR_INVALID_REQUEST_PATH

+ const JANUS_ERROR_JSEP_INVALID_SDP

+ const JANUS_ERROR_JSEP_UNKNOWN_TYPE

+ const JANUS_ERROR_MISSING_MANDATORY_ELEMENT

+ const JANUS_ERROR_MISSING_REQUEST

+ const JANUS_ERROR_PLUGIN_ATTACH

+ const JANUS_ERROR_PLUGIN_DETACH

+ const JANUS_ERROR_PLUGIN_MESSAGE

+ const JANUS_ERROR_PLUGIN_NOT_FOUND

+ const JANUS_ERROR_SESSION_CONFLICT

+ const JANUS_ERROR_SESSION_NOT_FOUND

+ const JANUS_ERROR_TOKEN_NOT_FOUND

+ const JANUS_ERROR_TRANSPORT_SPECIFIC

+ const JANUS_ERROR_TRICKE_INVALID_STREAM

+ const JANUS_ERROR_UNAUTHORIZED

+ const JANUS_ERROR_UNAUTHORIZED_PLUGIN

+ const JANUS_ERROR_UNEXPECTED_ANSWER

+ const JANUS_ERROR_UNKNOWN

+ const JANUS_ERROR_UNKNOWN_REQUEST

+ const JANUS_OK

+ const JANUS_VIDEOROOM_ERROR_ALREADY_JOINED

+ const JANUS_VIDEOROOM_ERROR_ALREADY_PUBLISHED

+ const JANUS_VIDEOROOM_ERROR_ID_EXISTS

+ const JANUS_VIDEOROOM_ERROR_INVALID_ELEMENT

+ const JANUS_VIDEOROOM_ERROR_INVALID_JSON

+ const JANUS_VIDEOROOM_ERROR_INVALID_REQUEST

+ const JANUS_VIDEOROOM_ERROR_INVALID_SDP

+ const JANUS_VIDEOROOM_ERROR_INVALID_SDP_TYPE

+ const JANUS_VIDEOROOM_ERROR_JOIN_FIRST

+ const JANUS_VIDEOROOM_ERROR_MISSING_ELEMENT

+ const JANUS_VIDEOROOM_ERROR_NOT_PUBLISHED

+ const JANUS_VIDEOROOM_ERROR_NO_MESSAGE

+ const JANUS_VIDEOROOM_ERROR_NO_SUCH_FEED

+ const JANUS_VIDEOROOM_ERROR_NO_SUCH_ROOM

+ const JANUS_VIDEOROOM_ERROR_PUBLISHERS_FULL

+ const JANUS_VIDEOROOM_ERROR_ROOM_EXISTS

+ const JANUS_VIDEOROOM_ERROR_UNAUTHORIZED

+ const JANUS_VIDEOROOM_ERROR_UNKNOWN_ERROR

+ const McuTypeDefault

+ const McuTypeJanus

+ const McuTypeProxy

+ const RecipientTypeRoom

+ const RecipientTypeSession

+ const RecipientTypeUser

+ const ServerFeatureInternalVirtualSessions

+ const ServerFeatureMcu

+ const ServerFeatureSimulcast

+ var ContinentMap map[string][]string = map[string][]string

+ var DefaultFeatures []string

+ var DefaultFeaturesInternal []string = []string

+ var DuplicateClient = NewError("duplicate_client", "Client already registered.")

+ var ErrDatabaseNotInitialized = fmt.Errorf("GeoIP database not initialized yet")

+ var ErrNoSuchRoomSession = fmt.Errorf("unknown room session id")

+ var ErrNotConnected = fmt.Errorf("not connected")

+ var ErrUseLastResponse = fmt.Errorf("use last response")

+ var HelloExpected = NewError("hello_expected", "Expected Hello request.")

+ var InvalidBackendUrl = NewError("invalid_backend", "The backend URL is not supported.")

+ var InvalidClientType = NewError("invalid_client_type", "The client type is not supported.")

+ var InvalidFormat = NewError("invalid_format", "Invalid data format.")

+ var InvalidToken = NewError("invalid_token", "The passed token is invalid.")

+ var NoSuchSession = NewError("no_such_session", "The session to resume does not exist.")

+ var PathToOcsSignalingBackend = "ocs/v2.php/apps/spreed/api/v1/signaling/backend"

+ var RoomJoinFailed = NewError("room_join_failed", "Could not join the room.")

+ var SessionLimitExceeded = NewError("session_limit_exceeded", "Too many sessions connected for this backend.")

+ var UserAuthFailed = NewError("auth_failed", "The user could not be authenticated.")

+ func AddBackendChecksum(r *http.Request, body []byte, secret []byte)

+ func CalculateBackendChecksum(random string, body []byte, secret []byte) string

+ func ContinentsOverlap(a, b []string) bool

+ func GetEncodedSubject(prefix string, suffix string) string

+ func GetGeoIpDownloadUrl(license string) string

+ func GetSubjectForBackendRoomId(roomId string, backend *Backend) string

+ func GetSubjectForRoomId(roomId string, backend *Backend) string

+ func GetSubjectForUserId(userId string, backend *Backend) string

+ func GetVirtualSessionId(session *ClientSession, sessionId string) string

+ func IsInCall(value interface{}) (bool, bool)

+ func IsValidCountry(country string) bool

+ func LookupContinents(country string) []string

+ func ValidateBackendChecksum(r *http.Request, body []byte, secret []byte) bool

+ func ValidateBackendChecksumValue(checksum string, random string, body []byte, secret []byte) bool

+ type AddSessionInternalClientMessage struct

+ Flags uint32

+ Options *AddSessionOptions

+ User *json.RawMessage

+ UserId string

+ func (m *AddSessionInternalClientMessage) CheckValid() error

+ type AddSessionOptions struct

+ ActorId string

+ ActorType string

+ type AnswerOfferMessage struct

+ From string

+ Payload map[string]interface{}

+ RoomType string

+ To string

+ Type string

+ type Backend struct

+ func (b *Backend) AddSession(session Session) error

+ func (b *Backend) Id() string

+ func (b *Backend) IsCompat() bool

+ func (b *Backend) RemoveSession(session Session)

+ func (b *Backend) Secret() []byte

+ type BackendClient struct

+ func NewBackendClient(config *goconf.ConfigFile, maxConcurrentRequestsPerHost int, version string) (*BackendClient, error)

+ func (b *BackendClient) GetBackend(u *url.URL) *Backend

+ func (b *BackendClient) GetBackends() []*Backend

+ func (b *BackendClient) GetCompatBackend() *Backend

+ func (b *BackendClient) HasCapabilityFeature(ctx context.Context, u *url.URL, feature string) bool

+ func (b *BackendClient) IsUrlAllowed(u *url.URL) bool

+ func (b *BackendClient) PerformJSONRequest(ctx context.Context, u *url.URL, request interface{}, response interface{}) error

+ func (b *BackendClient) Reload(config *goconf.ConfigFile)

+ type BackendClientAuthRequest struct

+ Params *json.RawMessage

+ Version string

+ type BackendClientAuthResponse struct

+ User *json.RawMessage

+ UserId string

+ Version string

+ type BackendClientPingRequest struct

+ Entries []BackendPingEntry

+ RoomId string

+ Version string

+ type BackendClientRequest struct

+ Auth *BackendClientAuthRequest

+ Ping *BackendClientPingRequest

+ Room *BackendClientRoomRequest

+ Session *BackendClientSessionRequest

+ Type string

+ func NewBackendClientAuthRequest(params *json.RawMessage) *BackendClientRequest

+ func NewBackendClientPingRequest(roomid string, entries []BackendPingEntry) *BackendClientRequest

+ func NewBackendClientRoomRequest(roomid string, userid string, sessionid string) *BackendClientRequest

+ func NewBackendClientSessionRequest(roomid string, action string, sessionid string, ...) *BackendClientRequest

+ type BackendClientResponse struct

+ Auth *BackendClientAuthResponse

+ Error *Error

+ Ping *BackendClientRingResponse

+ Room *BackendClientRoomResponse

+ Session *BackendClientSessionResponse

+ Type string

+ type BackendClientRingResponse struct

+ RoomId string

+ Version string

+ type BackendClientRoomRequest struct

+ Action string

+ ActorId string

+ ActorType string

+ InCall int

+ RoomId string

+ SessionId string

+ UserId string

+ Version string

+ type BackendClientRoomResponse struct

+ Permissions *[]Permission

+ Properties *json.RawMessage

+ RoomId string

+ Session *json.RawMessage

+ Version string

+ type BackendClientSessionRequest struct

+ Action string

+ RoomId string

+ SessionId string

+ User *json.RawMessage

+ UserId string

+ Version string

+ type BackendClientSessionResponse struct

+ RoomId string

+ Version string

+ type BackendConfiguration struct

+ func NewBackendConfiguration(config *goconf.ConfigFile) (*BackendConfiguration, error)

+ func (b *BackendConfiguration) GetBackend(u *url.URL) *Backend

+ func (b *BackendConfiguration) GetBackends() []*Backend

+ func (b *BackendConfiguration) GetCompatBackend() *Backend

+ func (b *BackendConfiguration) GetSecret(u *url.URL) []byte

+ func (b *BackendConfiguration) IsUrlAllowed(u *url.URL) bool

+ func (b *BackendConfiguration) Reload(config *goconf.ConfigFile)

+ func (b *BackendConfiguration) RemoveBackendsForHost(host string)

+ func (b *BackendConfiguration) UpsertHost(host string, backends []*Backend)

+ type BackendPingEntry struct

+ SessionId string

+ UserId string

+ type BackendRoomDeleteRequest struct

+ UserIds []string

+ type BackendRoomDisinviteRequest struct

+ AllUserIds []string

+ Properties *json.RawMessage

+ SessionIds []string

+ UserIds []string

+ type BackendRoomInCallRequest struct

+ Changed []map[string]interface{}

+ InCall json.RawMessage

+ Users []map[string]interface{}

+ type BackendRoomInviteRequest struct

+ AllUserIds []string

+ Properties *json.RawMessage

+ UserIds []string

+ type BackendRoomMessageRequest struct

+ Data *json.RawMessage

+ type BackendRoomParticipantsRequest struct

+ Changed []map[string]interface{}

+ Users []map[string]interface{}

+ type BackendRoomUpdateRequest struct

+ Properties *json.RawMessage

+ UserIds []string

+ type BackendServer struct

+ func NewBackendServer(config *goconf.ConfigFile, hub *Hub, version string) (*BackendServer, error)

+ func (b *BackendServer) Start(r *mux.Router) error

+ type BackendServerRoomRequest struct

+ Delete *BackendRoomDeleteRequest

+ Disinvite *BackendRoomDisinviteRequest

+ InCall *BackendRoomInCallRequest

+ Invite *BackendRoomInviteRequest

+ Message *BackendRoomMessageRequest

+ Participants *BackendRoomParticipantsRequest

+ ReceivedTime int64

+ Type string

+ Update *BackendRoomUpdateRequest

+ type BuiltinRoomSessions struct

+ func (r *BuiltinRoomSessions) DeleteRoomSession(session Session)

+ func (r *BuiltinRoomSessions) GetSessionId(roomSessionId string) (string, error)

+ func (r *BuiltinRoomSessions) SetRoomSession(session Session, roomSessionId string) error

+ type ByeClientMessage struct

+ func (m *ByeClientMessage) CheckValid() error

+ type ByeProxyClientMessage struct

+ func (m *ByeProxyClientMessage) CheckValid() error

+ type ByeProxyServerMessage struct

+ Reason string

+ type ByeServerMessage struct

+ Reason string

+ type CapabilitiesResponse struct

+ Capabilities map[string]map[string]interface{}

+ Version CapabilitiesVersion

+ type CapabilitiesVersion struct

+ Edition string

+ ExtendedSupport bool

+ Major int

+ Micro int

+ Minor int

+ String string

+ type Client struct

+ OnClosed func(*Client)

+ OnLookupCountry func(*Client) string

+ OnMessageReceived func(*Client, []byte)

+ OnRTTReceived func(*Client, time.Duration)

+ func NewClient(conn *websocket.Conn, remoteAddress string, agent string) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Country() string

+ func (c *Client) GetSession() *ClientSession

+ func (c *Client) IsAuthenticated() bool

+ func (c *Client) IsConnected() bool

+ func (c *Client) ReadPump()

+ func (c *Client) RemoteAddr() string

+ func (c *Client) SendByeResponse(message *ClientMessage) bool

+ func (c *Client) SendByeResponseWithReason(message *ClientMessage, reason string) bool

+ func (c *Client) SendError(e *Error) bool

+ func (c *Client) SendMessage(message WritableClientMessage) bool

+ func (c *Client) SetConn(conn *websocket.Conn, remoteAddress string)

+ func (c *Client) SetSession(session *ClientSession)

+ func (c *Client) UserAgent() string

+ func (c *Client) WritePump()

+ type ClientMessage struct

+ Bye *ByeClientMessage

+ Control *ControlClientMessage

+ Hello *HelloClientMessage

+ Id string

+ Internal *InternalClientMessage

+ Message *MessageClientMessage

+ Room *RoomClientMessage

+ Type string

+ func (m *ClientMessage) CheckValid() error

+ func (m *ClientMessage) NewErrorServerMessage(e *Error) *ServerMessage

+ func (m *ClientMessage) NewWrappedErrorServerMessage(e error) *ServerMessage

+ func (m *ClientMessage) String() string

+ type ClientSession struct

+ func NewClientSession(hub *Hub, privateId string, publicId string, data *SessionIdData, ...) (*ClientSession, error)

+ func (s *ClientSession) AddVirtualSession(session *VirtualSession)

+ func (s *ClientSession) AuthUserId() string

+ func (s *ClientSession) Backend() *Backend

+ func (s *ClientSession) BackendUrl() string

+ func (s *ClientSession) ClearClient(client *Client)

+ func (s *ClientSession) ClientType() string

+ func (s *ClientSession) Close()

+ func (s *ClientSession) Data() *SessionIdData

+ func (s *ClientSession) GetClient() *Client

+ func (s *ClientSession) GetFeatures() []string

+ func (s *ClientSession) GetOrCreatePublisher(ctx context.Context, mcu Mcu, streamType string) (McuPublisher, error)

+ func (s *ClientSession) GetOrCreateSubscriber(ctx context.Context, mcu Mcu, id string, streamType string) (McuSubscriber, error)

+ func (s *ClientSession) GetPublisher(streamType string) McuPublisher

+ func (s *ClientSession) GetRoom() *Room

+ func (s *ClientSession) GetSubscriber(id string, streamType string) McuSubscriber

+ func (s *ClientSession) HasFeature(feature string) bool

+ func (s *ClientSession) HasPermission(permission Permission) bool

+ func (s *ClientSession) IsExpired(now time.Time) bool

+ func (s *ClientSession) LeaveCall()

+ func (s *ClientSession) LeaveRoom(notify bool) *Room

+ func (s *ClientSession) NotifySessionResumed(client *Client)

+ func (s *ClientSession) OnIceCandidate(client McuClient, candidate interface{})

+ func (s *ClientSession) OnIceCompleted(client McuClient)

+ func (s *ClientSession) ParsedBackendUrl() *url.URL

+ func (s *ClientSession) PrivateId() string

+ func (s *ClientSession) PublicId() string

+ func (s *ClientSession) PublisherClosed(publisher McuPublisher)

+ func (s *ClientSession) RemoveVirtualSession(session *VirtualSession)

+ func (s *ClientSession) RoomSessionId() string

+ func (s *ClientSession) SendError(e *Error) bool

+ func (s *ClientSession) SendMessage(message *ServerMessage) bool

+ func (s *ClientSession) SendMessages(messages []*ServerMessage) bool

+ func (s *ClientSession) SetClient(client *Client) *Client

+ func (s *ClientSession) SetPermissions(permissions []Permission)

+ func (s *ClientSession) SetRoom(room *Room)

+ func (s *ClientSession) StartExpire()

+ func (s *ClientSession) StopExpire()

+ func (s *ClientSession) SubscribeNats(n NatsClient) error

+ func (s *ClientSession) SubscribeRoomNats(n NatsClient, roomid string, roomSessionId string) error

+ func (s *ClientSession) SubscriberClosed(subscriber McuSubscriber)

+ func (s *ClientSession) UnsubscribeRoomNats()

+ func (s *ClientSession) UserData() *json.RawMessage

+ func (s *ClientSession) UserId() string

+ type ClientTypeInternalAuthParams struct

+ Backend string

+ Random string

+ Token string

+ func (p *ClientTypeInternalAuthParams) CheckValid() error

+ type CommandProxyClientMessage struct

+ Bitrate int

+ ClientId string

+ PublisherId string

+ StreamType string

+ Type string

+ func (m *CommandProxyClientMessage) CheckValid() error

+ type CommandProxyServerMessage struct

+ Id string

+ type CommonSessionInternalClientMessage struct

+ RoomId string

+ SessionId string

+ func (m *CommonSessionInternalClientMessage) CheckValid() error

+ type ConcurrentStringStringMap struct

+ func (m *ConcurrentStringStringMap) Clear()

+ func (m *ConcurrentStringStringMap) Del(key string)

+ func (m *ConcurrentStringStringMap) Get(key string) (string, bool)

+ func (m *ConcurrentStringStringMap) Len() int

+ func (m *ConcurrentStringStringMap) Set(key, value string)

+ type ControlClientMessage struct

+ func (m *ControlClientMessage) CheckValid() error

+ type ControlServerMessage struct

+ Data *json.RawMessage

+ Recipient *MessageClientMessageRecipient

+ Sender *MessageServerMessageSender

+ type DeferredExecutor struct

+ func NewDeferredExecutor(queueSize int) *DeferredExecutor

+ func (e *DeferredExecutor) Close()

+ func (e *DeferredExecutor) Execute(f func())

+ type Error struct

+ Code string

+ Details interface{}

+ Message string

+ func NewError(code string, message string) *Error

+ func NewErrorDetail(code string, message string, details interface{}) *Error

+ func (e *Error) Error() string

+ type EventProxyServerMessage struct

+ ClientId string

+ Load int64

+ Type string

+ type EventServerMessage struct

+ Change []*EventServerMessageSessionEntry

+ Disinvite *RoomDisinviteEventServerMessage

+ Flags *RoomFlagsServerMessage

+ Invite *RoomEventServerMessage

+ Join []*EventServerMessageSessionEntry

+ Leave []string

+ Message *RoomEventMessage

+ Target string

+ Type string

+ Update *RoomEventServerMessage

+ type EventServerMessageSessionEntry struct

+ SessionId string

+ User *json.RawMessage

+ UserId string

+ type GatewayListener interface

+ ConnectionInterrupted func()

+ type GeoLookup struct

+ func NewGeoLookupFromFile(filename string) (*GeoLookup, error)

+ func NewGeoLookupFromUrl(url string) (*GeoLookup, error)

+ func (g *GeoLookup) Close()

+ func (g *GeoLookup) LookupCountry(ip net.IP) (string, error)

+ func (g *GeoLookup) Update() error

+ type HelloClientMessage struct

+ Auth HelloClientMessageAuth

+ Features []string

+ ResumeId string

+ Version string

+ func (m *HelloClientMessage) CheckValid() error

+ type HelloClientMessageAuth struct

+ Params *json.RawMessage

+ Type string

+ Url string

+ type HelloProxyClientMessage struct

+ Features []string

+ ResumeId string

+ Token string

+ Version string

+ func (m *HelloProxyClientMessage) CheckValid() error

+ type HelloProxyServerMessage struct

+ Server *HelloServerMessageServer

+ SessionId string

+ Version string

+ type HelloServerMessage struct

+ ResumeId string

+ Server *HelloServerMessageServer

+ SessionId string

+ UserId string

+ Version string

+ type HelloServerMessageServer struct

+ Country string

+ Features []string

+ Version string

+ type HttpClientPool struct

+ func NewHttpClientPool(constructor func() *http.Client, size int) (*HttpClientPool, error)

+ func (p *HttpClientPool) Get(ctx context.Context) (client *http.Client, err error)

+ func (p *HttpClientPool) Put(c *http.Client)

+ type Hub struct

+ func NewHub(config *goconf.ConfigFile, nats NatsClient, r *mux.Router, version string) (*Hub, error)

+ func (h *Hub) GetServerInfo(session Session) *HelloServerMessageServer

+ func (h *Hub) GetSessionByPublicId(sessionId string) Session

+ func (h *Hub) GetStats() map[string]interface{}

+ func (h *Hub) Reload(config *goconf.ConfigFile)

+ func (h *Hub) Run()

+ func (h *Hub) SetMcu(mcu Mcu)

+ func (h *Hub) Stop()

+ type InfoMsg struct

+ Author string

+ DataChannels bool

+ FullTrickle bool

+ ICE_TCP bool

+ IPv6 bool

+ LocalIP string

+ Name string

+ Plugins map[string]janus.PluginInfo

+ Transports map[string]janus.PluginInfo

+ Version int

+ VersionString string

+ type InternalClientMessage struct

+ AddSession *AddSessionInternalClientMessage

+ RemoveSession *RemoveSessionInternalClientMessage

+ Type string

+ UpdateSession *UpdateSessionInternalClientMessage

+ func (m *InternalClientMessage) CheckValid() error

+ type JanusGateway struct

+ Sessions map[uint64]*JanusSession

+ func NewJanusGateway(wsURL string, listener GatewayListener) (*JanusGateway, error)

+ func (gateway *JanusGateway) Close() error

+ func (gateway *JanusGateway) Create(ctx context.Context) (*JanusSession, error)

+ func (gateway *JanusGateway) Info(ctx context.Context) (*InfoMsg, error)

+ type JanusHandle struct

+ Events chan interface{}

+ Id uint64

+ Type string

+ User string

+ func (handle *JanusHandle) Detach(ctx context.Context) (*janus.AckMsg, error)

+ func (handle *JanusHandle) Message(ctx context.Context, body, jsep interface{}) (*janus.EventMsg, error)

+ func (handle *JanusHandle) Request(ctx context.Context, body interface{}) (*janus.SuccessMsg, error)

+ func (handle *JanusHandle) Trickle(ctx context.Context, candidate interface{}) (*janus.AckMsg, error)

+ func (handle *JanusHandle) TrickleMany(ctx context.Context, candidates interface{}) (*janus.AckMsg, error)

+ type JanusSession struct

+ Handles map[uint64]*JanusHandle

+ Id uint64

+ func (session *JanusSession) Attach(ctx context.Context, plugin string) (*JanusHandle, error)

+ func (session *JanusSession) Destroy(ctx context.Context) (*janus.AckMsg, error)

+ func (session *JanusSession) KeepAlive(ctx context.Context) (*janus.AckMsg, error)

+ type LoopbackNatsClient struct

+ func (c *LoopbackNatsClient) Close()

+ func (c *LoopbackNatsClient) Decode(msg *nats.Msg, v interface{}) error

+ func (c *LoopbackNatsClient) Publish(subject string, message interface{}) error

+ func (c *LoopbackNatsClient) PublishBackendServerRoomRequest(subject string, message *BackendServerRoomRequest) error

+ func (c *LoopbackNatsClient) PublishMessage(subject string, message *ServerMessage) error

+ func (c *LoopbackNatsClient) PublishNats(subject string, message *NatsMessage) error

+ func (c *LoopbackNatsClient) Subscribe(subject string, ch chan *nats.Msg) (NatsSubscription, error)

+ type LruCache struct

+ func NewLruCache(size int) *LruCache

+ func (c *LruCache) Get(key string) interface{}

+ func (c *LruCache) Len() int

+ func (c *LruCache) Remove(key string)

+ func (c *LruCache) RemoveOldest()

+ func (c *LruCache) Set(key string, value interface{})

+ type Mcu interface

+ GetStats func() interface{}

+ NewPublisher func(ctx context.Context, listener McuListener, id string, streamType string, ...) (McuPublisher, error)

+ NewSubscriber func(ctx context.Context, listener McuListener, publisher string, streamType string) (McuSubscriber, error)

+ Reload func(config *goconf.ConfigFile)

+ SetOnConnected func(func())

+ SetOnDisconnected func(func())

+ Start func() error

+ Stop func()

+ func NewMcuJanus(url string, config *goconf.ConfigFile) (Mcu, error)

+ func NewMcuProxy(config *goconf.ConfigFile) (Mcu, error)

+ type McuClient interface

+ Close func(ctx context.Context)

+ Id func() string

+ SendMessage func(ctx context.Context, message *MessageClientMessage, ...)

+ StreamType func() string

+ type McuInitiator interface

+ Country func() string

+ type McuListener interface

+ OnIceCandidate func(client McuClient, candidate interface{})

+ OnIceCompleted func(client McuClient)

+ PublicId func() string

+ PublisherClosed func(publisher McuPublisher)

+ SubscriberClosed func(subscriber McuSubscriber)

+ type McuPublisher interface

+ type McuSubscriber interface

+ Publisher func() string

+ type MessageClientMessage struct

+ Data *json.RawMessage

+ Recipient MessageClientMessageRecipient

+ func (m *MessageClientMessage) CheckValid() error

+ type MessageClientMessageData struct

+ Payload map[string]interface{}

+ RoomType string

+ Sid string

+ Type string

+ type MessageClientMessageRecipient struct

+ SessionId string

+ Type string

+ UserId string

+ type MessageServerMessage struct

+ Data *json.RawMessage

+ Recipient *MessageClientMessageRecipient

+ Sender *MessageServerMessageSender

+ type MessageServerMessageData struct

+ Chat *MessageServerMessageDataChat

+ Type string

+ type MessageServerMessageDataChat struct

+ Refresh bool

+ type MessageServerMessageSender struct

+ SessionId string

+ Type string

+ UserId string

+ type NatsClient interface

+ Close func()

+ Decode func(msg *nats.Msg, v interface{}) error

+ Publish func(subject string, message interface{}) error

+ PublishBackendServerRoomRequest func(subject string, message *BackendServerRoomRequest) error

+ PublishMessage func(subject string, message *ServerMessage) error

+ PublishNats func(subject string, message *NatsMessage) error

+ Subscribe func(subject string, ch chan *nats.Msg) (NatsSubscription, error)

+ func NewLoopbackNatsClient() (NatsClient, error)

+ func NewNatsClient(url string) (NatsClient, error)

+ type NatsMessage struct

+ Message *ServerMessage

+ Permissions []Permission

+ Room *BackendServerRoomRequest

+ SendTime time.Time

+ Type string

+ type NatsSubscription interface

+ Unsubscribe func() error

+ type Notifier struct

+ func (n *Notifier) NewWaiter(key string) *Waiter

+ func (n *Notifier) Notify(key string)

+ func (n *Notifier) Release(w *Waiter)

+ func (n *Notifier) Reset()

+ type OcsBody struct

+ Data *json.RawMessage

+ Meta OcsMeta

+ type OcsMeta struct

+ Message string

+ Status string

+ StatusCode int

+ type OcsResponse struct

+ Ocs *OcsBody

+ type PayloadProxyClientMessage struct

+ ClientId string

+ Payload map[string]interface{}

+ Type string

+ func (m *PayloadProxyClientMessage) CheckValid() error

+ type PayloadProxyServerMessage struct

+ ClientId string

+ Payload map[string]interface{}

+ Type string

+ type Permission string

+ var PERMISSION_MAY_CONTROL Permission = "control"

+ var PERMISSION_MAY_PUBLISH_MEDIA Permission = "publish-media"

+ var PERMISSION_MAY_PUBLISH_SCREEN Permission = "publish-screen"

+ type ProxyClientMessage struct

+ Bye *ByeProxyClientMessage

+ Command *CommandProxyClientMessage

+ Hello *HelloProxyClientMessage

+ Id string

+ Payload *PayloadProxyClientMessage

+ Type string

+ func (m *ProxyClientMessage) CheckValid() error

+ func (m *ProxyClientMessage) NewErrorServerMessage(e *Error) *ProxyServerMessage

+ func (m *ProxyClientMessage) NewWrappedErrorServerMessage(e error) *ProxyServerMessage

+ type ProxyInformationEtcd struct

+ Address string

+ func (p *ProxyInformationEtcd) CheckValid() error

+ type ProxyServerMessage struct

+ Bye *ByeProxyServerMessage

+ Command *CommandProxyServerMessage

+ Error *Error

+ Event *EventProxyServerMessage

+ Hello *HelloProxyServerMessage

+ Id string

+ Payload *PayloadProxyServerMessage

+ Type string

+ func (r *ProxyServerMessage) CloseAfterSend(session Session) bool

+ type RemoveSessionInternalClientMessage struct

+ UserId string

+ func (m *RemoveSessionInternalClientMessage) CheckValid() error

+ type Room struct

+ func NewRoom(roomId string, properties *json.RawMessage, hub *Hub, n NatsClient, ...) (*Room, error)

+ func (r *Room) AddSession(session Session, sessionData *json.RawMessage) []Session

+ func (r *Room) Backend() *Backend

+ func (r *Room) Close() []Session

+ func (r *Room) GetRoomSessionData(session Session) *RoomSessionData

+ func (r *Room) HasSession(session Session) bool

+ func (r *Room) Id() string

+ func (r *Room) NotifySessionChanged(session Session)

+ func (r *Room) NotifySessionResumed(session *ClientSession)

+ func (r *Room) Properties() *json.RawMessage

+ func (r *Room) PublishSessionJoined(session Session, sessionData *RoomSessionData)

+ func (r *Room) PublishSessionLeft(session Session)

+ func (r *Room) PublishUsersChanged(changed []map[string]interface{}, users []map[string]interface{})

+ func (r *Room) PublishUsersInCallChanged(changed []map[string]interface{}, users []map[string]interface{})

+ func (r *Room) RemoveSession(session Session) bool

+ func (r *Room) UpdateProperties(properties *json.RawMessage)

+ type RoomClientMessage struct

+ RoomId string

+ SessionId string

+ func (m *RoomClientMessage) CheckValid() error

+ type RoomDisinviteEventServerMessage struct

+ Reason string

+ type RoomEventMessage struct

+ Data *json.RawMessage

+ RoomId string

+ type RoomEventServerMessage struct

+ Changed []map[string]interface{}

+ InCall *json.RawMessage

+ Properties *json.RawMessage

+ RoomId string

+ Users []map[string]interface{}

+ type RoomFlagsServerMessage struct

+ Flags uint32

+ RoomId string

+ SessionId string

+ type RoomServerMessage struct

+ Properties *json.RawMessage

+ RoomId string

+ type RoomSessionData struct

+ UserId string

+ type RoomSessions interface

+ DeleteRoomSession func(session Session)

+ GetSessionId func(roomSessionId string) (string, error)

+ SetRoomSession func(session Session, roomSessionId string) error

+ func NewBuiltinRoomSessions() (RoomSessions, error)

+ type ServerMessage struct

+ Bye *ByeServerMessage

+ Control *ControlServerMessage

+ Error *Error

+ Event *EventServerMessage

+ Hello *HelloServerMessage

+ Id string

+ Message *MessageServerMessage

+ Room *RoomServerMessage

+ Type string

+ func (r *ServerMessage) CloseAfterSend(session Session) bool

+ func (r *ServerMessage) IsChatRefresh() bool

+ func (r *ServerMessage) IsParticipantsUpdate() bool

+ func (r *ServerMessage) String() string

+ type Session interface

+ Backend func() *Backend

+ BackendUrl func() string

+ ClientType func() string

+ Close func()

+ Data func() *SessionIdData

+ GetRoom func() *Room

+ HasPermission func(permission Permission) bool

+ IsExpired func(now time.Time) bool

+ LeaveRoom func(notify bool) *Room

+ ParsedBackendUrl func() *url.URL

+ PrivateId func() string

+ PublicId func() string

+ SetRoom func(room *Room)

+ UserData func() *json.RawMessage

+ UserId func() string

+ type SessionIdData struct

+ BackendId string

+ Created time.Time

+ Sid uint64

+ type TokenClaims struct

+ type TrickleMsg struct

+ Candidate struct{ ... }

+ Handle uint64

+ Session uint64

+ type TurnCredentials struct

+ Password string

+ TTL int64

+ URIs []string

+ Username string

+ type UpdateSessionInternalClientMessage struct

+ Flags *uint32

+ func (m *UpdateSessionInternalClientMessage) CheckValid() error

+ type VirtualSession struct

+ func NewVirtualSession(session *ClientSession, privateId string, publicId string, data *SessionIdData, ...) *VirtualSession

+ func (s *VirtualSession) AddFlags(flags uint32) bool

+ func (s *VirtualSession) Backend() *Backend

+ func (s *VirtualSession) BackendUrl() string

+ func (s *VirtualSession) ClientType() string

+ func (s *VirtualSession) Close()

+ func (s *VirtualSession) CloseWithFeedback(session *ClientSession, message *ClientMessage)

+ func (s *VirtualSession) Data() *SessionIdData

+ func (s *VirtualSession) Flags() uint32

+ func (s *VirtualSession) GetRoom() *Room

+ func (s *VirtualSession) HasPermission(permission Permission) bool

+ func (s *VirtualSession) IsExpired(now time.Time) bool

+ func (s *VirtualSession) LeaveRoom(notify bool) *Room

+ func (s *VirtualSession) Options() *AddSessionOptions

+ func (s *VirtualSession) ParsedBackendUrl() *url.URL

+ func (s *VirtualSession) PrivateId() string

+ func (s *VirtualSession) PublicId() string

+ func (s *VirtualSession) RemoveFlags(flags uint32) bool

+ func (s *VirtualSession) Session() *ClientSession

+ func (s *VirtualSession) SessionId() string

+ func (s *VirtualSession) SetFlags(flags uint32) bool

+ func (s *VirtualSession) SetRoom(room *Room)

+ func (s *VirtualSession) UserData() *json.RawMessage

+ func (s *VirtualSession) UserId() string

+ type Waiter struct

+ func (w *Waiter) Wait(ctx context.Context) error

+ type WritableClientMessage interface

+ CloseAfterSend func(session Session) bool

v0.2.0

Dec 8, 2020

v0.1.0

Sep 7, 2020

v0.0.13

May 12, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL