Versions in this module Expand all Collapse all v0 v0.2.2 Oct 26, 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(reqMsg *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 + Node string + PubMsg *utp.Publish + Signature string + SubMsg *utp.Subscribe + Topic *security.Topic + Type uint8 + UnsubMsg *utp.Unsubscribe + type ClusterResp struct + FromConnID uid.LID + Message *message.Message + PubMsg *utp.Publish + RespMsg []byte + SubMsg *utp.Subscribe + Topic *security.Topic + Type uint8 + UnsubMsg *utp.Unsubscribe + 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 v0.2.2-alpha Oct 26, 2021
Go to main page