notifier

Jan 4, 2024

Changes in this version

type Notifier

+ func (notifier *Notifier) CleanCache()

+ func (notifier *Notifier) SendToUser(notif notification.Notification, user users.UserWithPermissions) error

+ func (notifier *Notifier) SendToUserLogin(notif notification.Notification, login string) error

+ func (notifier *Notifier) SendToUserLogins(notif notification.Notification, users []string) error

Aug 31, 2022

Changes in this version

+ func ReplaceGlobals(notifier *Notifier) func()

+ type Client interface

+ GetSendChannel func() chan []byte

+ GetUser func() *users.UserWithPermissions

+ Read func()

+ Write func()

+ type ClientManager struct

+ Clients map[Client]bool

+ func NewClientManager() *ClientManager

+ func (manager *ClientManager) GetClients() []Client

+ func (manager *ClientManager) Register(newClient Client) error

+ func (manager *ClientManager) Unregister(existentClient Client) error

+ type GenericClient struct

+ ID string

+ Send chan []byte

+ User *users.UserWithPermissions

+ func (c *GenericClient) GetSendChannel() chan []byte

+ func (c *GenericClient) GetUser() *users.UserWithPermissions

+ type Notifier struct

+ func C() *Notifier

+ func NewNotifier() *Notifier

+ func (notifier *Notifier) Broadcast(notif notification.Notification)

+ func (notifier *Notifier) Register(client Client) error

+ func (notifier *Notifier) Send(message []byte, client Client)

+ func (notifier *Notifier) SendToRoles(cacheKey string, timeout time.Duration, notif notification.Notification, ...)

+ func (notifier *Notifier) SendToUsers(notif notification.Notification, users []uuid.UUID)

+ func (notifier *Notifier) Unregister(client Client) error

+ type SSEClient struct

+ func BuildSSEClient(w http.ResponseWriter, user *users.UserWithPermissions) (*SSEClient, error)

+ func (c *SSEClient) Read()

+ func (c *SSEClient) Write()

+ type WebsocketClient struct

+ Receive chan []byte

+ Socket *websocket.Conn

+ func BuildWebsocketClient(w http.ResponseWriter, r *http.Request, user *users.UserWithPermissions) (*WebsocketClient, error)

+ func NewWebsocketClient(conn *websocket.Conn, user *users.UserWithPermissions) *WebsocketClient

+ func (c *WebsocketClient) Read()

+ func (c *WebsocketClient) Write()