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

internal

package

Go to main page

Versions in this module

v0

v0.2.0

Aug 20, 2021

Changes in this version

type ClusterReq

+ PubMsg *utp.Publish

+ SubMsg *utp.Subscribe

+ UnsubMsg *utp.Unsubscribe

type ClusterResp

+ PubMsg *utp.Publish

+ RespMsg []byte

+ SubMsg *utp.Subscribe

+ UnsubMsg *utp.Unsubscribe

v0.1.1

Jul 8, 2021

Changes in this version

+ var Globals struct

+ func ClusterInit(configString json.RawMessage, self *string) int

+ func NewConnCache() *_ConnCache

+ func NewService(cfg *config.Config) (s *_Service, err error)

+ func ResponseHandler(w http.ResponseWriter, r *http.Request, data []byte)

+ func TimeNow() time.Time

+ type Cluster struct

+ func (Cluster) Proxy(resp *ClusterResp, unused *bool) error

+ func (c *Cluster) Master(msg *ClusterReq, rejected *bool) error

+ func (c *Cluster) Ping(ping *ClusterPing, unused *bool) error

+ func (c *Cluster) Start()

+ func (c *Cluster) Vote(vreq *ClusterVoteRequest, response *ClusterVoteResponse) error

+ type ClusterNode struct

+ type ClusterPing struct

+ Leader string

+ Nodes []string

+ Signature string

+ Term int

+ type ClusterReq struct

+ Conn *ClusterSess

+ ConnGone bool

+ Message *message.Message

+ MsgPub *lp.Publish

+ MsgSub *lp.Subscribe

+ MsgUnsub *lp.Unsubscribe

+ Node string

+ Signature string

+ Topic *security.Topic

+ Type uint8

+ type ClusterResp struct

+ FromConnID uid.LID

+ Message *message.Message

+ Msg []byte

+ MsgPub *lp.Publish

+ MsgSub *lp.Subscribe

+ MsgUnsub *lp.Unsubscribe

+ Topic *security.Topic

+ Type uint8

+ type ClusterSess struct

+ ClientID uid.ID

+ ConnID uid.LID

+ Proto lp.Proto

+ RemoteAddr string

+ SessID uid.LID

+ type ClusterVote struct

+ type ClusterVoteRequest struct

+ Node string

+ Term int

+ type ClusterVoteResponse struct

+ Result bool

+ Term int

+ type Meter struct

+ ConnTimeSeries metrics.TimeSeries

+ Connections metrics.Counter

+ InBytes metrics.Counter

+ InMsgs metrics.Counter

+ Metrics metrics.Metrics

+ OutBytes metrics.Counter

+ OutMsgs metrics.Counter

+ Subscriptions metrics.Counter

+ func NewMeter() *Meter

+ func (m *Meter) UnregisterAll()

+ type Varz struct

+ Connections int64

+ HMean float64

+ InBytes int64

+ InMsgs int64

+ Long5p float64

+ Max float64

+ Min float64

+ Now time.Time

+ OutBytes int64

+ OutMsgs int64

+ P50 float64

+ P75 float64

+ P95 float64

+ P99 float64

+ P999 float64

+ Short5p float64

+ Start time.Time

+ StdDev float64

+ Subscriptions int64

+ Uptime string