hub

package

v0.0.0-...-78bde51 Latest Latest Go to latest Published: Sep 14, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrRoomNotFound = errors.New("room not found")
)

This section is empty.

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

func New(lc fx.Lifecycle, logger *slog.Logger, tmpl *template.Template) *Hub

func (h *Hub) Join(id int64, o notifier.Observer[*Message]) *list.Element

func (h *Hub) Leave(id int64, e *list.Element) error

func (h *Hub) Send(id int64, msg *Message) error

type Message struct {
	Sender  string `json:"-"`
	Payload string `json:"payload"`
}