service

Documentation

Index

• type Client
• type SSEManager
  • func NewSSEManager(lenChan int) *SSEManager
  • func (mgr *SSEManager) RegisterClient(c Client)
  • func (mgr *SSEManager) SendMessage(ctx context.Context, m model.Message) error
  • func (mgr *SSEManager) Shutdown()
  • func (mgr *SSEManager) UnregisterClient(c Client)

Types

type Client

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

type SSEManager

type SSEManager struct {
	Broadcast chan model.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) SendMessage

func (mgr *SSEManager) SendMessage(ctx context.Context, m model.Message) error

func (*SSEManager) Shutdown

func (mgr *SSEManager) Shutdown()

func (*SSEManager) UnregisterClient

func (mgr *SSEManager) UnregisterClient(c Client)