server

package

Go to main page

Versions in this module

v1

v1.4.1

Feb 7, 2019

v1.4.0

Jan 15, 2019

Changes in this version

+ const DEFAULT_LAME_DUCK_DURATION

type ClientAuthentication

+ RemoteAddress func() net.Addr

type Info

+ Export *SubjectPermission

+ Import *SubjectPermission

type Logger

+ Warnf func(format string, v ...interface{})

type Options

+ LameDuckDuration time.Duration

type RouteInfo

+ Export *SubjectPermission

+ Import *SubjectPermission

type Routez

+ Export *SubjectPermission

+ Import *SubjectPermission

type Server

+ func (s *Server) Warnf(format string, v ...interface{})

v1.3.0

Aug 30, 2018

Changes in this version

+ func SetProcessName(name string) — darwin/amd64, js/wasm, linux/amd64

+ func SetServiceName(name string) — windows/amd64

+ type SubjectPermission struct

+ Allow []string

+ Deny []string

v1.2.0

Jul 5, 2018

Changes in this version

+ const AuthenticationTimeout

+ const AuthenticationViolation

+ const BadClientProtocolVersion

+ const ClientClosed

+ const ConnAll

+ const ConnClosed

+ const ConnOpen

+ const DEFAULT_MAX_CLOSED_CLIENTS

+ const DEFAULT_REMOTE_QSUBS_SWEEPER

+ const DefaultSubListSize

+ const DuplicateRoute

+ const MaxConnectionsExceeded

+ const MaxControlLineExceeded

+ const MaxPayloadExceeded

+ const PROTO

+ const ParseError

+ const ProtocolViolation

+ const ReadError

+ const RouteRemoved

+ const ServerShutdown

+ const SlowConsumerPendingBytes

+ const SlowConsumerWriteDeadline

+ const StaleConnection

+ const TLSHandshakeError

+ const WriteError

+ const WrongPort

+ var ErrTooManySubs = errors.New("Maximum Subscriptions Exceeded")

+ type ClosedState int

+ func (reason ClosedState) String() string

type ClusterOpts

+ Permissions *RoutePermissions

type ConnInfo

+ RTT string

+ Reason string

+ Stop *time.Time

+ type ConnInfos []*ConnInfo

+ func (cl ConnInfos) Len() int

+ func (cl ConnInfos) Swap(i, j int)

+ type ConnState int

type ConnzOptions

+ CID uint64

+ State ConnState

type Info

+ CID uint64

+ Proto int

type Options

+ MaxClosedClients int

+ MaxSubs int

+ PortsFileDir string

+ RQSubsSweep time.Duration

+ type Ports struct

+ Cluster []string

+ Monitoring []string

+ Nats []string

+ Profile []string

+ type RoutePermissions struct

+ Export []string

+ Import []string

type Server

+ func (s *Server) NumSlowConsumers() int64

+ func (s *Server) PortsInfo(maxWait time.Duration) *Ports

type SortOpt

+ const ByReason

+ const ByStart

+ const ByStop

+ type SubDetail struct

+ Cid uint64

+ Max int64

+ Msgs int64

+ Queue string

+ Sid string

+ Subject string

type Sublist

+ func (s *Sublist) RemoveBatch(subs []*subscription) error

type Subsz

+ Limit int

+ Offset int

+ Subs []SubDetail

+ Total int

type SubszOptions

+ Limit int

+ Offset int

+ Subscriptions bool

+ Test string

type Varz

+ MaxPending int64

+ WriteDeadline time.Duration

v1.1.0

Mar 23, 2018

Changes in this version

+ type ConnzOptions struct

+ Limit int

+ Offset int

+ Sort SortOpt

+ Subscriptions bool

+ Username bool

+ type RoutezOptions struct

+ Subscriptions bool

type Server

+ func (s *Server) Connz(opts *ConnzOptions) (*Connz, error)

+ func (s *Server) Routez(routezOpts *RoutezOptions) (*Routez, error)

+ func (s *Server) Subsz(subszOpts *SubszOptions) (*Subsz, error)

+ func (s *Server) Varz(varzOpts *VarzOptions) (*Varz, error)

type SortOpt

+ const ByIdle

+ const ByLast

+ const ByUptime

+ type SubszOptions struct

+ type VarzOptions struct

v1.0.6

Feb 28, 2018

Changes in this version

type ClusterOpts

+ Advertise string

type Connz

+ ID string

type Info

+ GitCommit string

type Options

+ ClientAdvertise string

type Routez

+ ID string

type Server

+ func (s *Server) ProfilerAddr() *net.TCPAddr

v1.0.4

Sep 27, 2017

Changes in this version

+ type Authentication interface

+ Check func(c ClientAuthentication) bool

+ type ClientAuthentication interface

+ GetOpts func() *clientOpts

+ GetTLSConnectionState func() *tls.ConnectionState

+ RegisterUser func(*User)

type Options

+ CustomClientAuthentication Authentication

+ CustomRouterAuthentication Authentication

+ func ConfigureOptions(fs *flag.FlagSet, args []string, printVersion, printHelp, printTLSHelp func()) (*Options, error)

+ func (o *Options) ProcessConfigFile(configFile string) error

v1.0.2

Jul 19, 2017

v1.0.0

Jul 12, 2017

Changes in this version

+ const CommandQuit

+ const CommandReload

+ const CommandReopen

+ const CommandStop

+ const QRSID_LEN

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

+ func ProcessSignal(command Command, pidStr string) error — darwin/amd64, js/wasm, linux/amd64

+ func ProcessSignal(command Command, service string) error — windows/amd64

+ func Run(server *Server) error

type ClusterOpts

+ ConnectRetries int

+ type Command string

type Options

+ ConfigFile string

+ WriteDeadline time.Duration

+ var FlagSnapshot *Options

+ func (o *Options) Clone() *Options

type Server

+ func (s *Server) ClusterAddr() *net.TCPAddr

+ func (s *Server) ConfigTime() time.Time

+ func (s *Server) ConfigureLogger()

+ func (s *Server) Debugf(format string, v ...interface{})

+ func (s *Server) Errorf(format string, v ...interface{})

+ func (s *Server) Fatalf(format string, v ...interface{})

+ func (s *Server) HTTPHandler() http.Handler

+ func (s *Server) MonitorAddr() *net.TCPAddr

+ func (s *Server) Noticef(format string, v ...interface{})

+ func (s *Server) Reload() error

+ func (s *Server) StartMonitoring() error

+ func (s *Server) Tracef(format string, v ...interface{})

type TLSConfigOpts

+ CurvePreferences []tls.CurveID

type Varz

+ ConfigLoadTime time.Time

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