Documentation ¶
Index ¶
- Constants
- type AppProxy
- type AppProxyImpl
- type BroadcasterFactory
- type Grid
- type GridImpl
- type RepositoryFactory
- type UserProxy
- type 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)
Constants ¶
View Source
const ( RootUsername = "root" RootTagName = "root" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppProxy ¶
type AppProxy interface { GetAppID() string // contains filtered or unexported methods }
type AppProxyImpl ¶
type AppProxyImpl struct {
// contains filtered or unexported fields
}
func NewAppProxy ¶
func NewAppProxy(app *domain.App) *AppProxyImpl
func (*AppProxyImpl) GetAppID ¶
func (p *AppProxyImpl) GetAppID() string
type BroadcasterFactory ¶
type BroadcasterFactory interface {
GetBroadcaster() domain.NotificationBroadcaster
}
type GridImpl ¶
type GridImpl struct {
// contains filtered or unexported fields
}
func NewGrid ¶
func NewGrid(repositoryFactory RepositoryFactory, broadcasterFactory BroadcasterFactory) *GridImpl
func (*GridImpl) ReceiveAppNotification ¶
func (g *GridImpl) ReceiveAppNotification(appNotification model.AppNotification) (appID string)
type RepositoryFactory ¶
type RepositoryFactory interface {
GetRepository() domain.NotificationRepository
}
type UserProxy ¶
type UserProxy interface { SubscribeUserToTag(tag *domain.Tag) RegisterClient(interface{}) GetLastNotifications(n int) []model.ClientNotification GetNotifications(from, to int) []model.ClientNotification GetAllNotifications() []model.ClientNotification GetNotificationCount() int }
type UserProxyImpl ¶
type UserProxyImpl struct {
// contains filtered or unexported fields
}
func NewUserProxy ¶
func NewUserProxy(username string, repo domain.NotificationRepository, broadcaster domain.NotificationBroadcaster) *UserProxyImpl
func (*UserProxyImpl) GetAllNotifications ¶
func (p *UserProxyImpl) GetAllNotifications() []model.ClientNotification
func (*UserProxyImpl) GetLastNotifications ¶
func (p *UserProxyImpl) GetLastNotifications(n int) []model.ClientNotification
func (*UserProxyImpl) GetNotificationCount ¶
func (p *UserProxyImpl) GetNotificationCount() int
func (*UserProxyImpl) GetNotifications ¶
func (p *UserProxyImpl) GetNotifications(from, to int) []model.ClientNotification
func (*UserProxyImpl) RegisterClient ¶
func (p *UserProxyImpl) RegisterClient(conn interface{})
func (*UserProxyImpl) SubscribeUserToTag ¶
func (p *UserProxyImpl) SubscribeUserToTag(tag *domain.Tag)
Click to show internal directories.
Click to hide internal directories.