server

package

Go to main page

Versions in this module

v1

v1.0.1

Apr 25, 2017

v1.0.0

Apr 24, 2017

v0

v0.9.9

Apr 24, 2017

v0.9.8

Apr 9, 2017

v0.9.7

Apr 7, 2017

v0.9.6

Dec 15, 2016

v0.9.4

Aug 18, 2016

Changes in this version

type Options

+ ClusterNoAdvertise bool

v0.9.2

Aug 8, 2016

Changes in this version

type Server

+ func (s *Server) GetListenEndpoint() string

+ func (s *Server) GetRouteListenEndpoint() string

v0.8.1

Apr 6, 2017

v0.8.0

Apr 5, 2017

Changes in this version

+ const ClientProtoInfo

+ const ClientProtoZero

+ const ConProto

+ const ConnzPath

+ const INTERNALCLI

+ const InfoProto

+ const OP_UNSUB_SPC

+ const RootPath

+ const RoutezPath

+ const StackszPath

+ const SubszPath

+ const VarzPath

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

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

+ var ErrClientConnectedToRoutePort = errors.New("Attempted To Connect To Route Port")

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

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

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

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

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

+ func IsValidLiteralSubject(subject string) bool

+ func IsValidSubject(subject string) bool

+ func PrintTLSHelpAndDie()

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

type ClientAuth

+ GetTLSConnectionState func() *tls.ConnectionState

+ RegisterUser func(*User)

+ type ClusterOpts struct

+ AuthTimeout float64

+ ConnectRetries int

+ Host string

+ ListenStr string

+ NoAdvertise bool

+ Password string

+ Port int

+ TLSConfig *tls.Config

+ TLSTimeout float64

+ Username string

type ConnInfo

+ AuthorizedUser string

+ Idle string

+ LastActivity time.Time

+ Start time.Time

+ Uptime string

type Connz

+ Total int

type Info

+ ClientConnectURLs []string

+ IP string

+ ServerRank int

+ type InternalClient interface

+ Name func() string

+ Start func(info Info, opts Options, logger Logger) (net.Conn, error)

+ Stop func()

+ type LocalInternalClient interface

+ IsInternal func()

type Options

+ Cluster ClusterOpts

+ HTTPHost string

+ HealthAgent bool

+ HealthBeat time.Duration

+ HealthLease time.Duration

+ HealthRank int

+ InternalCli []InternalClient

+ Users []*User

+ WriteDeadline time.Duration

+ type Pairs []Pair

+ func (d Pairs) Len() int

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

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

+ type Permissions struct

+ Publish []string

+ Subscribe []string

type RouteInfo

+ IsConfigured bool

+ RemoteID string

+ type RouteType int

+ const Explicit

+ const Implicit

type Server

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

+ func (s *Server) ID() string

+ func (s *Server) InternalCliRegisterCallback(srv net.Conn)

+ func (s *Server) ReOpenLogFile()

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

+ 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 TLSConfigOpts

+ CurvePreferences []tls.CurveID

+ type User struct

+ Password string

+ Permissions *Permissions

+ Username string

type Varz

+ HTTPReqStats map[string]uint64

+ Subscriptions uint32

+ 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