realtime

package

v0.1.0 Latest Latest Go to latest Published: Jul 21, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Hub manages SSE connections and fans out events from Redis pub/sub.

func NewHub(rdb *redis.Client) *Hub

func (h *Hub) Publish(ctx context.Context, ev models.StreamEvent) error

Publish sends an event to all clients in the hiveshare via Redis.

func (h *Hub) ServeSSE(w http.ResponseWriter, r *http.Request, hiveshareID uuid.UUID)

ServeSSE handles an SSE connection for a specific hiveshare.