sse

Documentation

Index

• Constants
• type Event
• type Server
  • func New() *Server
  • func (s *Server) Get(id string) (*Session, bool)
  • func (s *Server) HandleFunc() httprouter.Handle
  • func (s *Server) Sessions() map[string]*Session
• type Session
  • func (s *Session) Send(e *Event)

Constants

const (
	SYSSessionCreated = "Created"
)

const SYSSessionTopic = "$SYS/session"

Types

type Event

type Event struct {
	Topic    string `json:"topic"`
	Name     string `json:"name"`
	Data     any    `json:"data"`
	Metadata any    `json:"metadata"`
}

type Server

type Server struct {
	NewSessionHandler   func(id string, session *Session)
	CloseSessionHandler func(id string, session *Session)
	// contains filtered or unexported fields
}

func New

func New() *Server

func (*Server) Get

func (s *Server) Get(id string) (*Session, bool)

func (*Server) HandleFunc

func (s *Server) HandleFunc() httprouter.Handle

func (*Server) Sessions

func (s *Server) Sessions() map[string]*Session

type Session

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

func (*Session) Send

func (s *Session) Send(e *Event)