Versions in this module Expand all Collapse all v0 v0.6.0 Jun 16, 2015 Changes in this version + const DefaultConnListSize + func Errorf(format string, v ...interface{}) + func Noticef(format string, v ...interface{}) + type Auth interface + Check func(c ClientAuth) bool + type ClientAuth interface + GetOpts func() *clientOpts type ConnInfo + Lang string + NumSubs uint32 + Version string type Connz + Limit int + Offset int + type Logger interface + Debugf func(format string, v ...interface{}) + Errorf func(format string, v ...interface{}) + Fatalf func(format string, v ...interface{}) + Noticef func(format string, v ...interface{}) + Tracef func(format string, v ...interface{}) type Options + RemoteSyslog string + Syslog bool + type RouteInfo struct + DidSolicit bool + IP string + InBytes int64 + InMsgs int64 + NumSubs uint32 + OutBytes int64 + OutMsgs int64 + Pending int + Port int + RemoteId string + Rid uint64 + Subs []string + type Routez struct + NumRoutes int + Routes []*RouteInfo type Server + func (s *Server) HandleRoutez(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleSubsz(w http.ResponseWriter, r *http.Request) + func (s *Server) SetAuthMethod(authMethod Auth) + func (s *Server) SetLogger(logger Logger, debugFlag, traceFlag bool) + type Subsz struct + SubjectStats sublist.Stats type Varz + Remotes int + Routes int v0.5.6 Sep 10, 2014 Changes in this version + func RemoveSelfReference(routes []*url.URL) []*url.URL v0.5.4 Jul 25, 2014 Changes in this version + const RANDOM_PORT type Server + func (s *Server) Addr() net.Addr v0.5.2 Apr 30, 2014 Changes in this version + const ACCEPT_MAX_SLEEP + const ACCEPT_MIN_SLEEP + const AUTH_TIMEOUT + const CLIENT + const CONNECT_ARG + const CR_LF + const DEFAULT_FLUSH_DEADLINE + const DEFAULT_HOST + const DEFAULT_HTTP_PORT + const DEFAULT_MAX_CONNECTIONS + const DEFAULT_PING_INTERVAL + const DEFAULT_PING_MAX_OUT + const DEFAULT_PORT + const DEFAULT_ROUTE_CONNECT + const DEFAULT_ROUTE_DIAL + const DEFAULT_ROUTE_RECONNECT + const EXPECTED_MATCHES + const INFO_ARG + const LEN_CR_LF + const MAX_CONTROL_LINE_SIZE + const MAX_MSG_ARGS + const MAX_PAYLOAD_SIZE + const MAX_PENDING_SIZE + const MAX_PUB_ARGS + const MINUS_ERR_ARG + const MSG_ARG + const MSG_END + const MSG_PAYLOAD + const OP_C + const OP_CO + const OP_CON + const OP_CONN + const OP_CONNE + const OP_CONNEC + const OP_CONNECT + const OP_I + const OP_IN + const OP_INF + const OP_INFO + const OP_M + const OP_MINUS + const OP_MINUS_E + const OP_MINUS_ER + const OP_MINUS_ERR + const OP_MINUS_ERR_SPC + const OP_MS + const OP_MSG + const OP_MSG_SPC + const OP_P + const OP_PI + const OP_PIN + const OP_PING + const OP_PLUS + const OP_PLUS_O + const OP_PLUS_OK + const OP_PO + const OP_PON + const OP_PONG + const OP_PU + const OP_PUB + const OP_PUB_SPC + const OP_S + const OP_START + const OP_SU + const OP_SUB + const OP_SUB_SPC + const OP_U + const OP_UN + const OP_UNS + const OP_UNSU + const OP_UNSUB + const PROTO_SNIPPET_SIZE + const PUB_ARG + const QRSID + const ROUTER + const RSID + const RSID_CID_INDEX + const RSID_SID_INDEX + const SSL_TIMEOUT + const SUB_ARG + const UNSUB_ARG + const VERSION + var ErrAuthorization = errors.New("Authorization Error") + var ErrConnectionClosed = errors.New("Connection closed") + func Debug(v ...interface{}) + func Debugf(format string, v ...interface{}) + func Fatal(v ...interface{}) + func Fatalf(format string, v ...interface{}) + func Log(v ...interface{}) + func LogSetup() + func Logf(format string, v ...interface{}) + func PrintAndDie(msg string) + func PrintServerAndExit() + func Trace(v ...interface{}) + func Tracef(format string, v ...interface{}) + func Usage() + type ConnInfo struct + Cid uint64 + IP string + InBytes int64 + InMsgs int64 + OutBytes int64 + OutMsgs int64 + Pending int + Port int + Subs uint32 + type Connz struct + Conns []*ConnInfo + NumConns int + type Info struct + AuthRequired bool + Host string + ID string + MaxPayload int + Port int + SslRequired bool + Version string + type Options struct + AuthTimeout float64 + Authorization string + ClusterAuthTimeout float64 + ClusterHost string + ClusterPassword string + ClusterPort int + ClusterUsername string + Debug bool + HTTPPort int + Host string + LogFile string + Logtime bool + MaxConn int + MaxControlLine int + MaxPayload int + MaxPingsOut int + NoLog bool + NoSigs bool + Password string + PidFile string + PingInterval time.Duration + Port int + ProfPort int + Routes []*url.URL + SslTimeout float64 + Trace bool + Username string + func MergeOptions(fileOpts, flagOpts *Options) *Options + func ProcessConfigFile(configFile string) (*Options, error) + type Server struct + func New(opts *Options) *Server + func (s *Server) AcceptLoop() + func (s *Server) HandleConnz(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleVarz(w http.ResponseWriter, r *http.Request) + func (s *Server) LogInit() + func (s *Server) NumClients() int + func (s *Server) NumRemotes() int + func (s *Server) NumRoutes() int + func (s *Server) NumSubscriptions() uint32 + func (s *Server) Shutdown() + func (s *Server) Start() + func (s *Server) StartHTTPMonitoring() + func (s *Server) StartProfiler() + func (s *Server) StartRouting() + type Varz struct + CPU float64 + Connections int + Cores int + InBytes int64 + InMsgs int64 + Mem int64 + Options *Options + OutBytes int64 + OutMsgs int64 + Start time.Time + Uptime string
Go to main page