graphsubscriptions

package

v0.47.2 Latest Latest Go to latest Published: Nov 25, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

View Source

const TaskChannelBufferSize = 10

TaskChannelBufferSize is the buffer size for task subscription channels

This section is empty.

This section is empty.

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

Manager manages all active subscriptions for real-time updates

func NewManager() *Manager

NewManager creates a new subscription manager

func (sm *Manager) Publish(userID string, task *generated.Task) error

Publish sends a task to all subscribers for that user

func (sm *Manager) Subscribe(userID string, ch chan *generated.Task)

Subscribe adds a new subscriber for a user's task creations

func (sm *Manager) Unsubscribe(userID string, ch chan *generated.Task)

Unsubscribe removes a subscriber