singlesub

Documentation

Overview

Package singlesub

Index

• type Manage
  • func NewManager(r *redis.Client, label string) *Manage
  • func (m *Manage) AddGroup(groupName string, w http.ResponseWriter, r *http.Request) error
  • func (m *Manage) AddGroupWithExt(groupName string, w http.ResponseWriter, r *http.Request, ...) error
  • func (m *Manage) MsgSub() error
  • func (m *Manage) SendMsg(groupName string, msg string) error
  • func (m *Manage) SetMaxMsgLength(n int)
  • func (m *Manage) SetUpgrade(up *websocket.Upgrader)

Types

type Manage

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

func NewManager

func NewManager(r *redis.Client, label string) *Manage

func (*Manage) AddGroup

func (m *Manage) AddGroup(groupName string, w http.ResponseWriter, r *http.Request) error

func (*Manage) AddGroupWithExt

func (m *Manage) AddGroupWithExt(groupName string, w http.ResponseWriter, r *http.Request, ext *inner.GroupExtData) error

AddGroupWithExt 只一个redis订阅

func (*Manage) MsgSub

func (m *Manage) MsgSub() error

func (*Manage) SendMsg

func (m *Manage) SendMsg(groupName string, msg string) error

func (*Manage) SetMaxMsgLength

func (m *Manage) SetMaxMsgLength(n int)

func (*Manage) SetUpgrade

func (m *Manage) SetUpgrade(up *websocket.Upgrader)