Documentation
¶
Index ¶
Constants ¶
View Source
const TaskChannelBufferSize = 10
TaskChannelBufferSize is the buffer size for task subscription channels
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages all active subscriptions for real-time updates
func GetGlobalManager ¶ added in v0.51.0
func GetGlobalManager() *Manager
GetGlobalManager returns the global subscription manager instance
func (*Manager) Publish ¶
func (sm *Manager) Publish(userID string, notification Notification) error
Publish sends a notification to all subscribers for that user
func (*Manager) Subscribe ¶
func (sm *Manager) Subscribe(userID string, ch chan Notification)
Subscribe adds a new subscriber for a user's notification creations
func (*Manager) Unsubscribe ¶
func (sm *Manager) Unsubscribe(userID string, ch chan Notification)
Unsubscribe removes a subscriber
type Notification ¶ added in v0.51.0
type Notification interface{}
Notification is an interface that represents a notification that can be published This avoids import cycles with ent/generated The ent/generated.Notification type has ID and UserID fields that satisfy this interface
Source Files
Click to show internal directories.
Click to hide internal directories.