server

package

Go to main page

Versions in this module

v0

v0.9.6

Dec 15, 2016

Changes in this version

+ var ErrTooManyConnections = errors.New("Maximum Connections Exceeded")

+ func ProcessCommandLineArgs(cmd *flag.FlagSet) (showVersion bool, showHelp bool, err error)

+ type ClusterOpts struct

+ AuthTimeout float64

+ Host string

+ ListenStr string

+ NoAdvertise bool

+ Password string

+ Port int

+ TLSConfig *tls.Config

+ TLSTimeout float64

+ Username string

type Options

+ Cluster ClusterOpts

type Server

+ func (s *Server) ReOpenLogFile()

+ func (s *Server) ReadyForConnections(dur time.Duration) bool

v0.9.4

Aug 18, 2016

Changes in this version

type Options

+ ClusterNoAdvertise bool

v0.9.2

Aug 8, 2016

Changes in this version

+ const ClientProtoInfo

+ const ClientProtoZero

+ var ErrBadClientProtocol = errors.New("Invalid Client Protocol")

+ var ErrMaxControlLine = errors.New("Maximum Control Line Exceeded")

+ var ErrReservedPublishSubject = errors.New("Reserved Internal Subject")

+ func IsValidSubject(subject string) bool

type ClientAuth

+ RegisterUser func(*User)

type Info

+ ClientConnectURLs []string

+ type Permissions struct

+ Publish []string

+ Subscribe []string

type User

+ Permissions *Permissions

v0.8.1

Jun 9, 2016

Changes in this version

+ const StackszPath

type ConnInfo

+ AuthorizedUser string

type Options

+ HTTPHost string

+ Users []User

type Server

+ func (s *Server) HandleStacksz(w http.ResponseWriter, r *http.Request)

+ type User struct

+ Password string

+ Username string

type Varz

+ Subscriptions uint32

v0.8.0

May 9, 2016

Changes in this version

+ const ConProto

+ const ConnzPath

+ const InfoProto

+ const OP_UNSUB_SPC

+ const RootPath

+ const RoutezPath

+ const SubszPath

+ const VarzPath

+ var ErrAuthTimeout = errors.New("Authorization Timeout")

+ var ErrInvalidSubject = errors.New("sublist: Invalid Subject")

+ var ErrNotFound = errors.New("sublist: No Matches Found")

+ func IsValidLiteralSubject(subject string) bool

+ func PrintTLSHelpAndDie()

type ConnInfo

+ Idle string

+ LastActivity time.Time

+ Start time.Time

+ Uptime string

type Connz

+ Total int

type Info

+ IP string

+ type Pairs []Pair

+ func (d Pairs) Len() int

+ func (d Pairs) Less(i, j int) bool

+ func (d Pairs) Swap(i, j int)

type RouteInfo

+ IsConfigured bool

+ RemoteID string

+ type RouteType int

+ const Explicit

+ const Implicit

type Server

+ func (s *Server) GetListenEndpoint() string

+ func (s *Server) GetRouteListenEndpoint() string

+ func (s *Server) ID() string

+ func (s *Server) SetClientAuthMethod(authMethod Auth)

+ func (s *Server) SetRouteAuthMethod(authMethod Auth)

type SortOpt

+ func (s SortOpt) IsValid() bool

+ type Sublist struct

+ func NewSublist() *Sublist

+ func (s *Sublist) CacheCount() int

+ func (s *Sublist) Count() uint32

+ func (s *Sublist) Insert(sub *subscription) error

+ func (s *Sublist) Match(subject string) *SublistResult

+ func (s *Sublist) Remove(sub *subscription) error

+ func (s *Sublist) Stats() *SublistStats

+ type SublistResult struct

+ type SublistStats struct

+ AvgFanout float64

+ CacheHitRate float64

+ MaxFanout uint32

+ NumCache uint32

+ NumInserts uint64

+ NumMatches uint64

+ NumRemoves uint64

+ NumSubs uint32

type Varz

+ HTTPReqStats map[string]uint64

+ TotalConnections uint64

v0.7.2

Dec 9, 2015

v0.7.0

Dec 4, 2015

Changes in this version

+ const TLS_TIMEOUT

+ func GenTLSConfig(tc *TLSConfigOpts) (*tls.Config, error)

+ func PrintTlsHelpAndDie()

type ConnInfo

+ Name string

+ TLSCipher string

+ TLSVersion string

type Info

+ SSLRequired bool

+ TLSRequired bool

+ TLSVerify bool

type Options

+ ClusterListenStr string

+ ClusterTLSConfig *tls.Config

+ ClusterTLSTimeout float64

+ HTTPSPort int

+ TLS bool

+ TLSCaCert string

+ TLSCert string

+ TLSConfig *tls.Config

+ TLSKey string

+ TLSTimeout float64

+ TLSVerify bool

type Server

+ func (s *Server) StartHTTPSMonitoring()

+ type TLSConfigOpts struct

+ CaFile string

+ CertFile string

+ Ciphers []uint16

+ KeyFile string

+ Timeout float64

+ Verify bool

type Varz

+ Port int

v0.6.8

Sep 18, 2015

Changes in this version

+ const DEFAULT_BUF_SIZE

type Options

+ BufSize int

v0.6.6

Aug 23, 2015

Changes in this version

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

+ type ByPending []Pair

+ func (d ByPending) Len() int

+ func (d ByPending) Less(i, j int) bool

+ func (d ByPending) Swap(i, j int)

type Varz

+ MaxPayload int

v0.6.4

Aug 8, 2015

v0.6.2

Aug 8, 2015

Changes in this version

+ var ErrMaxPayload = errors.New("Maximum Payload Exceeded")

+ func RoutesFromStr(routesStr string) []*url.URL

+ type ByCid []Pair

+ func (d ByCid) Len() int

+ func (d ByCid) Less(i, j int) bool

+ func (d ByCid) Swap(i, j int)

+ type ByInBytes []Pair

+ func (d ByInBytes) Len() int

+ func (d ByInBytes) Less(i, j int) bool

+ func (d ByInBytes) Swap(i, j int)

+ type ByInMsgs []Pair

+ func (d ByInMsgs) Len() int

+ func (d ByInMsgs) Less(i, j int) bool

+ func (d ByInMsgs) Swap(i, j int)

+ type ByOutBytes []Pair

+ func (d ByOutBytes) Len() int

+ func (d ByOutBytes) Less(i, j int) bool

+ func (d ByOutBytes) Swap(i, j int)

+ type ByOutMsgs []Pair

+ func (d ByOutMsgs) Len() int

+ func (d ByOutMsgs) Less(i, j int) bool

+ func (d ByOutMsgs) Swap(i, j int)

+ type BySubs []Pair

+ func (d BySubs) Len() int

+ func (d BySubs) Less(i, j int) bool

+ func (d BySubs) Swap(i, j int)

type Connz

+ Now time.Time

type Info

+ GoVersion string

type Options

+ MaxPending int

+ RoutesStr string

+ type Pair struct

+ Key uint64

+ Val *client

type Routez

+ Now time.Time

type Server

+ func (s *Server) HandleRoot(w http.ResponseWriter, r *http.Request)

+ type SortOpt string

type Varz

+ Now time.Time

+ SlowConsumers int64

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL