Versions in this module Expand all Collapse all v0 v0.1.0 Aug 31, 2022 Changes in this version + const RootTagName + const RootUsername + type AppProxy interface + GetAppID func() string + type AppProxyImpl struct + func NewAppProxy(app *domain.App) *AppProxyImpl + func (p *AppProxyImpl) GetAppID() string + type BroadcasterFactory interface + GetBroadcaster func() domain.NotificationBroadcaster + type Grid interface + AddUser func(username string) + GetUserProxy func(userID string) (UserProxy, error) + ReceiveAppNotification func(notification model.AppNotification) (appID string) + type GridImpl struct + func NewGrid(repositoryFactory RepositoryFactory, broadcasterFactory BroadcasterFactory) *GridImpl + func (g *GridImpl) AddUser(username string) + func (g *GridImpl) GetUserProxy(username string) (UserProxy, error) + func (g *GridImpl) ReceiveAppNotification(appNotification model.AppNotification) (appID string) + func (g *GridImpl) Start() + type RepositoryFactory interface + GetRepository func() domain.NotificationRepository + type UserProxy interface + GetAllNotifications func() []model.ClientNotification + GetLastNotifications func(n int) []model.ClientNotification + GetNotificationCount func() int + GetNotifications func(from, to int) []model.ClientNotification + RegisterClient func(interface{}) + SubscribeUserToTag func(tag *domain.Tag) + type UserProxyImpl struct + func NewUserProxy(username string, repo domain.NotificationRepository, ...) *UserProxyImpl + func (p *UserProxyImpl) GetAllNotifications() []model.ClientNotification + func (p *UserProxyImpl) GetLastNotifications(n int) []model.ClientNotification + func (p *UserProxyImpl) GetNotificationCount() int + func (p *UserProxyImpl) GetNotifications(from, to int) []model.ClientNotification + func (p *UserProxyImpl) RegisterClient(conn interface{}) + func (p *UserProxyImpl) SubscribeUserToTag(tag *domain.Tag)