domain

Documentation

Index

• Variables
• func NewGatewayAdminAPIRegistry() *gatewayAdminAPIRegistry
• type GatewayToken
  • func (t *GatewayToken) Decrypt() (string, error)
• type GatewayTokensManager
  • func NewGatewayTokensManager(db common.DBInterface, maxAge time.Duration) *GatewayTokensManager
  • func (tm *GatewayTokensManager) ActiveToken(gateway *models.Gateway) (string, error)
  • func (tm *GatewayTokensManager) Close()
  • func (tm *GatewayTokensManager) Monitor()
  • func (tm *GatewayTokensManager) SyncAll()
• type ModelsSuite
  • func (s *ModelsSuite) CreateComposite(rooms []*models.Room) *models.Composite
  • func (s *ModelsSuite) CreateGateway() *models.Gateway
  • func (s *ModelsSuite) CreateGatewayP(gType string, adminUrl, adminPwd string) *models.Gateway
  • func (s *ModelsSuite) CreateRoom(gateway *models.Gateway) *models.Room
  • func (s *ModelsSuite) CreateSession(user *models.User, gateway *models.Gateway, room *models.Room) *models.Session
  • func (s *ModelsSuite) CreateUser() *models.User
• type RoomStatisticsManager
  • func NewRoomStatisticsManager(db common.DBInterface) *RoomStatisticsManager
  • func (m *RoomStatisticsManager) GetAll() ([]*models.RoomStatistic, error)
  • func (m *RoomStatisticsManager) OnAir(roomID int64) error
  • func (m *RoomStatisticsManager) Reset(ctx context.Context) error

Variables

var GatewayAdminAPIRegistry = NewGatewayAdminAPIRegistry()

Functions

func NewGatewayAdminAPIRegistry

func NewGatewayAdminAPIRegistry() *gatewayAdminAPIRegistry

Types

type GatewayToken

type GatewayToken struct {
	Token     string    `json:"token"`
	Plugins   []string  `json:"plugins"`
	CreatedAt time.Time `json:"created_at"`
}

func (*GatewayToken) Decrypt

func (t *GatewayToken) Decrypt() (string, error)

type GatewayTokensManager

type GatewayTokensManager struct {
	*patterns.SimpleObservable
	// contains filtered or unexported fields
}

func NewGatewayTokensManager

func NewGatewayTokensManager(db common.DBInterface, maxAge time.Duration) *GatewayTokensManager

func (*GatewayTokensManager) ActiveToken

func (tm *GatewayTokensManager) ActiveToken(gateway *models.Gateway) (string, error)

func (*GatewayTokensManager) Close

func (tm *GatewayTokensManager) Close()

func (*GatewayTokensManager) Monitor

func (tm *GatewayTokensManager) Monitor()

func (*GatewayTokensManager) SyncAll

func (tm *GatewayTokensManager) SyncAll()

type ModelsSuite

type ModelsSuite struct {
	suite.Suite
	testutil.TestDBManager
}

func (*ModelsSuite) CreateComposite

func (s *ModelsSuite) CreateComposite(rooms []*models.Room) *models.Composite

func (*ModelsSuite) CreateGateway

func (s *ModelsSuite) CreateGateway() *models.Gateway

func (*ModelsSuite) CreateGatewayP

func (s *ModelsSuite) CreateGatewayP(gType string, adminUrl, adminPwd string) *models.Gateway

func (*ModelsSuite) CreateRoom

func (s *ModelsSuite) CreateRoom(gateway *models.Gateway) *models.Room

func (*ModelsSuite) CreateSession

func (s *ModelsSuite) CreateSession(user *models.User, gateway *models.Gateway, room *models.Room) *models.Session

func (*ModelsSuite) CreateUser

func (s *ModelsSuite) CreateUser() *models.User

type RoomStatisticsManager

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

func NewRoomStatisticsManager

func NewRoomStatisticsManager(db common.DBInterface) *RoomStatisticsManager

func (*RoomStatisticsManager) GetAll

func (m *RoomStatisticsManager) GetAll() ([]*models.RoomStatistic, error)

func (*RoomStatisticsManager) OnAir

func (m *RoomStatisticsManager) OnAir(roomID int64) error

func (*RoomStatisticsManager) Reset

func (m *RoomStatisticsManager) Reset(ctx context.Context) error