handlers

Documentation

Index

• type SSE
  • func NewSSE(manager *service.SSEManager) *SSE
  • func (s *SSE) Init(api *gin.RouterGroup)
  • func (s *SSE) SendMessage(ctx context.Context, m models.Message) error
  • func (s *SSE) Stream(c *gin.Context)

Types

type SSE

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

func NewSSE

func NewSSE(manager *service.SSEManager) *SSE

func (*SSE) Init

func (s *SSE) Init(api *gin.RouterGroup)

func (*SSE) SendMessage

func (s *SSE) SendMessage(ctx context.Context, m models.Message) error

func (*SSE) Stream

func (s *SSE) Stream(c *gin.Context)