service

Documentation

Index

• type Client
• type SSEManager
  • func NewSSEManager(lenChan int) *SSEManager
  • func (mgr *SSEManager) RegisterClient(c Client)
  • func (mgr *SSEManager) Shutdown()
  • func (mgr *SSEManager) UnregisterClient(c Client)

Types

type Client

type Client struct {
	ID      int
	Channel chan models.Data
}

type SSEManager

type SSEManager struct {
	Broadcast chan models.Data

	LenChan int
	// contains filtered or unexported fields
}

func NewSSEManager

func NewSSEManager(lenChan int) *SSEManager

func (*SSEManager) RegisterClient

func (mgr *SSEManager) RegisterClient(c Client)

func (*SSEManager) Shutdown

func (mgr *SSEManager) Shutdown()

func (*SSEManager) UnregisterClient

func (mgr *SSEManager) UnregisterClient(c Client)