core

Documentation

Index

• func GetActiveViewers() map[string]*models.Viewer
• func GetBroadcaster() *models.Broadcaster
• func GetCurrentBroadcast() *models.CurrentBroadcast
• func GetStatus() models.Status
• func IsStreamConnected() bool
• func RemoveChatClient(clientID string)
• func SetStreamAsDisconnected()
• func SetViewerActive(viewer *models.Viewer)
• func Start() error
• func StartOfflineCleanupTimer()
• func StopOfflineCleanupTimer()

Functions

func GetActiveViewers

func GetActiveViewers() map[string]*models.Viewer

GetActiveViewers will return the active viewers.

func GetBroadcaster

func GetBroadcaster() *models.Broadcaster

GetBroadcaster will return the details of the currently active broadcaster.

func GetCurrentBroadcast

func GetCurrentBroadcast() *models.CurrentBroadcast

GetCurrentBroadcast will return the currently active broadcast.

func GetStatus

func GetStatus() models.Status

GetStatus gets the status of the system.

func IsStreamConnected

func IsStreamConnected() bool

IsStreamConnected checks if the stream is connected or not.

func RemoveChatClient

func RemoveChatClient(clientID string)

RemoveChatClient removes a client from the active clients record.

func SetStreamAsDisconnected

func SetStreamAsDisconnected()

SetStreamAsDisconnected sets the stream as disconnected.

func SetViewerActive

func SetViewerActive(viewer *models.Viewer)

SetViewerActive sets a client as active and connected.

func Start

func Start() error

Start starts up the core processing.

func StartOfflineCleanupTimer

func StartOfflineCleanupTimer()

StartOfflineCleanupTimer will fire a cleanup after n minutes being disconnected.

func StopOfflineCleanupTimer

func StopOfflineCleanupTimer()

StopOfflineCleanupTimer will stop the previous cleanup timer.