Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gateway

package

Go to main page

Versions in this module

v0

v0.4.1-alpha.7

Jan 18, 2022

v0.4.1-alpha.6

Jan 11, 2022

v0.4.1-alpha.5

Jan 11, 2022

v0.4.1-alpha.4

Jan 10, 2022

v0.4.1-alpha.3

Jan 7, 2022

v0.4.1-alpha.2

Jan 7, 2022

v0.4.1-alpha.1

Jan 7, 2022

v0.4.0

Oct 30, 2018

Changes in this version

type FireTower

+ func (t *FireTower) CheckTopicExist(topic string) bool

+ func (t *FireTower) SetOnConnectHandler(fn func() bool)

+ func (t *FireTower) SetOnOfflineHandler(fn func())

+ func (t *FireTower) SetOnSystemRemove(fn func(topic string))

v0.3.3

Sep 28, 2018

Changes in this version

+ var ClusterId int64 = 1

+ var ConfigTree *toml.Tree

+ var DefaultConfigPath = "./fireTower.toml"

+ var DefaultErrorWriter io.Writer = os.Stderr

+ var DefaultWriter io.Writer = os.Stdout

+ var ErrorClose = errors.New("firetower is collapsed")

+ var ErrorTopicEmpty = errors.New("topic is empty")

+ var FireLogger func(f *FireInfo, types, info string)

+ var IdWorker *snowFlakeByGo.Worker

+ var LogLevel = "INFO"

+ var TopicManageGrpc pb.TopicServiceClient

+ var TowerLogger func(t *FireTower, types, info string)

+ func BuildManagerClient()

+ func GetIP() (string, error)

+ func Init()

+ type Bucket struct

+ BuffChan chan *socket.SendMessage

+ func (b *Bucket) AddSubscribe(topic string, bt *FireTower)

+ func (b *Bucket) DelSubscribe(topic string, bt *FireTower)

+ func (b *Bucket) Push(message *socket.SendMessage) error

+ type FireInfo struct

+ Context *FireLife

+ Message *TopicMessage

+ MessageType int

+ func NewFireInfo(t *FireTower, context *FireLife) *FireInfo

+ func (f *FireInfo) Error(info string)

+ func (f *FireInfo) Info(info string)

+ func (f *FireInfo) Panic(info string)

+ func (f *FireInfo) Recycling()

+ type FireLife struct

+ type FireTower struct

+ ClientId string

+ Cookie []byte

+ Topic map[string]bool

+ UserId string

+ func BuildTower(ws *websocket.Conn, clientId string) (tower *FireTower)

+ func (t *FireTower) Close()

+ func (t *FireTower) GetConnectNum(topic string) int64

+ func (t *FireTower) Publish(fire *FireInfo) error

+ func (t *FireTower) Run()

+ func (t *FireTower) Send(message *socket.SendMessage) error

+ func (t *FireTower) SetBeforeSubscribeHandler(fn func(context *FireLife, topic []string) bool)

+ func (t *FireTower) SetReadHandler(fn func(*FireInfo) bool)

+ func (t *FireTower) SetReadTimeoutHandler(fn func(*FireInfo))

+ func (t *FireTower) SetSubscribeHandler(fn func(context *FireLife, topic []string) bool)

+ func (t *FireTower) SetUnSubscribeHandler(fn func(context *FireLife, topic []string) bool)

+ func (t *FireTower) ToSelf(b []byte) error

+ type FireTowerConfig struct

+ type TopicMessage struct

+ Data json.RawMessage

+ Topic string

+ Type string

+ type TowerManager struct

+ var TM *TowerManager

+ func (t *TowerManager) GetBucket(bt *FireTower) (bucket *Bucket)