Versions in this module Expand all Collapse all v1 v1.8.0 Mar 10, 2024 v1.7.0 Feb 12, 2024 v1.6.1 Oct 10, 2022 v1.6.0 Oct 10, 2022 v1.5.0 Dec 25, 2020 Changes in this version + const ACCEPT_MAX_SLEEP + const ACCEPT_MIN_SLEEP + const ASUB_ARG + const AUSUB_ARG + const AUTH_TIMEOUT + const AuthenticationExpired + const AuthenticationTimeout + const AuthenticationViolation + const BadClientProtocolVersion + const CLIENT + const CONNECT_ARG + const CR_LF + const ClientClosed + const ClientProtoInfo + const ClientProtoZero + const CommandQuit + const CommandReload + const CommandReopen + const CommandStop + const ConProto + const ConnAll + const ConnClosed + const ConnOpen + const ConnzPath + const DEFAULT_ALLOW_RESPONSE_EXPIRATION + const DEFAULT_ALLOW_RESPONSE_MAX_MSGS + const DEFAULT_CONNECT_ERROR_REPORTS + const DEFAULT_FLUSH_DEADLINE + const DEFAULT_HOST + const DEFAULT_HTTP_BASE_PATH + const DEFAULT_HTTP_PORT + const DEFAULT_LAME_DUCK_DURATION + const DEFAULT_LEAFNODE_INFO_WAIT + const DEFAULT_LEAFNODE_PORT + const DEFAULT_LEAF_NODE_RECONNECT + const DEFAULT_LEAF_TLS_TIMEOUT + const DEFAULT_MAX_ACCOUNT_AE_RESPONSE_MAPS + const DEFAULT_MAX_ACCOUNT_INTERNAL_RESPONSE_MAPS + const DEFAULT_MAX_CLOSED_CLIENTS + const DEFAULT_MAX_CONNECTIONS + const DEFAULT_PING_INTERVAL + const DEFAULT_PING_MAX_OUT + const DEFAULT_PORT + const DEFAULT_RECONNECT_ERROR_REPORTS + const DEFAULT_ROUTE_CONNECT + const DEFAULT_ROUTE_DIAL + const DEFAULT_ROUTE_RECONNECT + const DEFAULT_RTT_MEASUREMENT_INTERVAL + const DEFAULT_SERVICE_LATENCY_SAMPLING + const DEFAULT_TTL_AE_RESPONSE_MAP + const DefaultConnListSize + const DefaultSubListSize + const DuplicateRoute + const GATEWAY + const GatewayzPath + const INFO_ARG + const InboxPrefix + const InfoProto + const LEAF + const LEN_CR_LF + const LeafzPath + 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_N + const MSG_END_R + const MSG_PAYLOAD + const MaxAccountConnectionsExceeded + const MaxConnectionsExceeded + const MaxControlLineExceeded + const MaxPayloadExceeded + const MaxSubscriptionsExceeded + const MissingAccount + const OP_A + const OP_ASUB + const OP_ASUB_SPC + const OP_AUSUB + const OP_AUSUB_SPC + 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_L + const OP_LS + 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_R + const OP_RS + 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 OP_UNSUB_SPC + const PROTO + const PROTO_SNIPPET_SIZE + const PUB_ARG + const ParseError + const ProtocolViolation + const RANDOM_PORT + const ROUTER + const ReadError + const Revocation + const RootPath + const RouteProtoInfo + const RouteProtoV2 + const RouteProtoZero + const RouteRemoved + const RoutezPath + const SUB_ARG + const SYSTEM + const ServerShutdown + const SlowConsumerPendingBytes + const SlowConsumerWriteDeadline + const StackszPath + const StaleConnection + const SubszPath + const TLSHandshakeError + const TLS_TIMEOUT + const UNSUB_ARG + const VERSION + const VarzPath + const WriteError + const WrongGateway + const WrongPort + var ErrAccountExists = errors.New("account exists") + var ErrAccountExpired = errors.New("account expired") + var ErrAccountResolverSameClaims = errors.New("account resolver no new claims") + var ErrAccountResolverUpdateTooSoon = errors.New("account resolver update too soon") + var ErrAccountValidation = errors.New("account validation failed") + var ErrAuthExpired = errors.New("authentication expired") + var ErrAuthTimeout = errors.New("authentication timeout") + var ErrAuthentication = errors.New("authentication error") + var ErrBadAccount = errors.New("bad account") + var ErrBadClientProtocol = errors.New("invalid client protocol") + var ErrBadPublishSubject = errors.New("invalid publish subject") + var ErrBadSampling = errors.New("bad sampling percentage, should be 1-100") + var ErrBadServiceType = errors.New("bad service response type") + var ErrClientConnectedToLeafNodePort = errors.New("attempted to connect to leaf node port") + var ErrClientConnectedToRoutePort = errors.New("attempted to connect to route port") + var ErrClientOrRouteConnectedToGatewayPort = errors.New("attempted to connect to gateway port") + var ErrConnectedToWrongPort = errors.New("attempted to connect to wrong port") + var ErrConnectionClosed = errors.New("connection closed") + var ErrInvalidSubject = errors.New("sublist: invalid subject") + var ErrMaxControlLine = errors.New("maximum control line exceeded") + var ErrMaxPayload = errors.New("maximum payload exceeded") + var ErrMissingAccount = errors.New("account missing") + var ErrMissingService = errors.New("service missing") + var ErrNoAccountResolver = errors.New("account resolver missing") + var ErrNoSysAccount = errors.New("system account not setup") + var ErrNotFound = errors.New("sublist: no matches found") + var ErrReservedAccount = errors.New("reserved account") + var ErrReservedPublishSubject = errors.New("reserved internal subject") + var ErrRevocation = errors.New("credentials have been revoked") + var ErrServerNotRunning = errors.New("server is not running") + var ErrServiceImportAuthorization = errors.New("service import not authorized") + var ErrStreamImportAuthorization = errors.New("stream import not authorized") + var ErrStreamImportBadPrefix = errors.New("stream import prefix can not contain wildcard tokens") + var ErrStreamImportDuplicate = errors.New("stream import already exists") + var ErrTooManyAccountConnections = errors.New("maximum account active connections exceeded") + var ErrTooManyConnections = errors.New("maximum connections exceeded") + var ErrTooManySubs = errors.New("maximum subscriptions exceeded") + var ErrWrongGateway = errors.New("wrong gateway") + var IsPublicExport = []*Account(nil) + func ErrorIs(err, target error) bool + func GenTLSConfig(tc *TLSConfigOpts) (*tls.Config, error) + func IsValidLiteralSubject(subject string) bool + func IsValidPublishSubject(subject string) bool + func IsValidSubject(subject string) bool + func NewErrorCtx(err error, format string, args ...interface{}) error + func NoErrOnUnknownFields(noError bool) + func PrintAndDie(msg string) + func PrintServerAndExit() + func PrintTLSHelpAndDie() + func ProcessCommandLineArgs(cmd *flag.FlagSet) (showVersion bool, showHelp bool, err error) + func ProcessSignal(command Command, pidStr string) error — darwin/amd64, js/wasm, linux/amd64 + func ProcessSignal(command Command, service string) error — windows/amd64 + func ReadOperatorJWT(jwtfile string) (*jwt.OperatorClaims, error) + func RemoveSelfReference(clusterPort int, routes []*url.URL) ([]*url.URL, error) + func ResetGatewaysSolicitDelay() + func ResponseHandler(w http.ResponseWriter, r *http.Request, data []byte) + func RoutesFromStr(routesStr string) []*url.URL + func Run(server *Server) error + func SetGatewaysSolicitDelay(delay time.Duration) + func SetProcessName(name string) — darwin/amd64, js/wasm, linux/amd64 + func SetServiceName(name string) — windows/amd64 + func UnpackIfErrorCtx(err error) string + type Account struct + Issuer string + Name string + Nkey string + func NewAccount(name string) *Account + func (a *Account) AddServiceExport(subject string, accounts []*Account) error + func (a *Account) AddServiceExportWithResponse(subject string, respType ServiceRespType, accounts []*Account) error + func (a *Account) AddServiceImport(destination *Account, from, to string) error + func (a *Account) AddServiceImportWithClaim(destination *Account, from, to string, imClaim *jwt.Import) error + func (a *Account) AddStreamExport(subject string, accounts []*Account) error + func (a *Account) AddStreamImport(account *Account, from, prefix string) error + func (a *Account) AddStreamImportWithClaim(account *Account, from, prefix string, imClaim *jwt.Import) error + func (a *Account) AutoExpireTTL() time.Duration + func (a *Account) IsExpired() bool + func (a *Account) IsExportService(service string) bool + func (a *Account) IsExportServiceTracking(service string) bool + func (a *Account) MaxActiveConnections() int + func (a *Account) MaxActiveLeafNodes() int + func (a *Account) MaxAutoExpireResponseMaps() int + func (a *Account) MaxResponseMaps() int + func (a *Account) MaxTotalConnectionsReached() bool + func (a *Account) MaxTotalLeafNodesReached() bool + func (a *Account) NumConnections() int + func (a *Account) NumLeafNodes() int + func (a *Account) NumLocalConnections() int + func (a *Account) NumRemoteConnections() int + func (a *Account) NumRemoteLeafNodes() int + func (a *Account) NumServiceImports() int + func (a *Account) RoutedSubs() int + func (a *Account) SetAutoExpireTTL(ttl time.Duration) + func (a *Account) SetMaxAutoExpireResponseMaps(max int) + func (a *Account) SetMaxResponseMaps(max int) + func (a *Account) SubscriptionInterest(subject string) bool + func (a *Account) TotalSubs() int + func (a *Account) TrackServiceExport(service, results string) error + func (a *Account) TrackServiceExportWithSampling(service, results string, sampling int) error + func (a *Account) UnTrackServiceExport(service string) + type AccountGatewayz struct + InterestMode string + InterestOnlyThreshold int + Name string + NoInterestCount int + NumQueueSubscriptions int + TotalSubscriptions int + type AccountNumConns struct + Account string + Conns int + LeafNodes int + Server ServerInfo + TotalConns int + type AccountResolver interface + Fetch func(name string) (string, error) + Store func(name, jwt string) error + type Authentication interface + Check func(c ClientAuthentication) bool + type ClientAuthentication interface + GetOpts func() *clientOpts + GetTLSConnectionState func() *tls.ConnectionState + RegisterUser func(*User) + RemoteAddress func() net.Addr + type ClientInfo struct + Account string + Host string + ID uint64 + Lang string + Name string + RTT string + Start time.Time + Stop *time.Time + User string + Version string + type ClosedState int + func (reason ClosedState) String() string + type ClusterOpts struct + Advertise string + AuthTimeout float64 + ConnectRetries int + Host string + ListenStr string + NoAdvertise bool + Password string + Permissions *RoutePermissions + Port int + TLSConfig *tls.Config + TLSMap bool + TLSTimeout float64 + Username string + type ClusterOptsVarz struct + AuthTimeout float64 + Host string + Port int + URLs []string + type Command string + type ConnInfo struct + Account string + AuthorizedUser string + Cid uint64 + IP string + Idle string + InBytes int64 + InMsgs int64 + Lang string + LastActivity time.Time + Name string + NumSubs uint32 + OutBytes int64 + OutMsgs int64 + Pending int + Port int + RTT string + Reason string + Start time.Time + Stop *time.Time + Subs []string + SubsDetail []SubDetail + TLSCipher string + TLSVersion string + Uptime string + Version string + type ConnInfos []*ConnInfo + func (cl ConnInfos) Len() int + func (cl ConnInfos) Swap(i, j int) + type ConnState int + type ConnectEventMsg struct + Client ClientInfo + Server ServerInfo + type Connz struct + Conns []*ConnInfo + ID string + Limit int + Now time.Time + NumConns int + Offset int + Total int + type ConnzOptions struct + Account string + CID uint64 + Limit int + Offset int + Sort SortOpt + State ConnState + Subscriptions bool + SubscriptionsDetail bool + User string + Username bool + type DataStats struct + Bytes int64 + Msgs int64 + type DisconnectEventMsg struct + Client ClientInfo + Reason string + Received DataStats + Sent DataStats + Server ServerInfo + type GatewayInterestMode byte + const InterestOnly + const Optimistic + const Transitioning + func (im GatewayInterestMode) String() string + type GatewayOpts struct + Advertise string + AuthTimeout float64 + ConnectRetries int + Gateways []*RemoteGatewayOpts + Host string + Name string + Password string + Port int + RejectUnknown bool + TLSConfig *tls.Config + TLSMap bool + TLSTimeout float64 + Username string + type GatewayOptsVarz struct + Advertise string + AuthTimeout float64 + ConnectRetries int + Gateways []RemoteGatewayOptsVarz + Host string + Name string + Port int + RejectUnknown bool + TLSTimeout float64 + type GatewayStat struct + ID uint64 + Name string + NumInbound int + Received DataStats + Sent DataStats + type Gatewayz struct + Host string + ID string + InboundGateways map[string][]*RemoteGatewayz + Name string + Now time.Time + OutboundGateways map[string]*RemoteGatewayz + Port int + type GatewayzOptions struct + AccountName string + Accounts bool + Name string + type Info struct + AuthRequired bool + CID uint64 + ClientConnectURLs []string + ClientIP string + Cluster string + Export *SubjectPermission + Gateway string + GatewayCmd byte + GatewayCmdPayload []byte + GatewayNRP bool + GatewayURL string + GatewayURLs []string + GitCommit string + GoVersion string + Host string + ID string + IP string + Import *SubjectPermission + LeafNodeURLs []string + MaxPayload int32 + Name string + Nonce string + Port int + Proto int + TLSRequired bool + TLSVerify bool + Version string + type LeafInfo struct + Account string + IP string + InBytes int64 + InMsgs int64 + NumSubs uint32 + OutBytes int64 + OutMsgs int64 + Port int + RTT string + Subs []string + type LeafNodeOpts struct + Account string + Advertise string + AuthTimeout float64 + Host string + NoAdvertise bool + Password string + Port int + ReconnectInterval time.Duration + Remotes []*RemoteLeafOpts + TLSConfig *tls.Config + TLSMap bool + TLSTimeout float64 + Username string + Users []*User + type LeafNodeOptsVarz struct + AuthTimeout float64 + Host string + Port int + Remotes []RemoteLeafOptsVarz + TLSTimeout float64 + type Leafz struct + ID string + Leafs []*LeafInfo + Now time.Time + NumLeafs int + type LeafzOptions struct + Subscriptions bool + 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{}) + Warnf func(format string, v ...interface{}) + type MemAccResolver struct + func (m *MemAccResolver) Fetch(name string) (string, error) + func (m *MemAccResolver) Store(name, jwt string) error + type NATSLatency struct + Requestor time.Duration + Responder time.Duration + System time.Duration + func (nl *NATSLatency) TotalTime() time.Duration + type NkeyUser struct + Account *Account + Nkey string + Permissions *Permissions + SigningKey string + type Options struct + AccountResolver AccountResolver + AccountResolverTLSConfig *tls.Config + Accounts []*Account + AllowNewAccounts bool + AuthTimeout float64 + Authorization string + CheckConfig bool + ClientAdvertise string + Cluster ClusterOpts + ConfigFile string + ConnectErrorReports int + CustomClientAuthentication Authentication + CustomRouterAuthentication Authentication + Debug bool + DisableShortFirstPing bool + Gateway GatewayOpts + HTTPBasePath string + HTTPHost string + HTTPPort int + HTTPSPort int + Host string + LameDuckDuration time.Duration + LeafNode LeafNodeOpts + LogFile string + LogSizeLimit int64 + Logtime bool + MaxClosedClients int + MaxConn int + MaxControlLine int32 + MaxPayload int32 + MaxPending int64 + MaxPingsOut int + MaxSubs int + MaxTracedMsgLen int + Nkeys []*NkeyUser + NoAuthUser string + NoLog bool + NoSigs bool + NoSublistCache bool + Password string + PidFile string + PingInterval time.Duration + Port int + PortsFileDir string + ProfPort int + ReconnectErrorReports int + RemoteSyslog string + Routes []*url.URL + RoutesStr string + ServerName string + Syslog bool + SystemAccount string + TLS bool + TLSCaCert string + TLSCert string + TLSConfig *tls.Config + TLSKey string + TLSMap bool + TLSTimeout float64 + TLSVerify bool + Trace bool + TraceVerbose bool + TrustedKeys []string + TrustedOperators []*jwt.OperatorClaims + Username string + Users []*User + WriteDeadline time.Duration + var FlagSnapshot *Options + func ConfigureOptions(fs *flag.FlagSet, args []string, printVersion, printHelp, printTLSHelp func()) (*Options, error) + func MergeOptions(fileOpts, flagOpts *Options) *Options + func ProcessConfigFile(configFile string) (*Options, error) + func (o *Options) Clone() *Options + func (o *Options) ProcessConfigFile(configFile string) error + type Permissions struct + Publish *SubjectPermission + Response *ResponsePermission + Subscribe *SubjectPermission + type Ports struct + Cluster []string + Monitoring []string + Nats []string + Profile []string + type RemoteGatewayOpts struct + Name string + TLSConfig *tls.Config + TLSTimeout float64 + URLs []*url.URL + type RemoteGatewayOptsVarz struct + Name string + TLSTimeout float64 + URLs []string + type RemoteGatewayz struct + Accounts []*AccountGatewayz + Connection *ConnInfo + IsConfigured bool + type RemoteLeafOpts struct + Credentials string + DenyExports []string + DenyImports []string + Hub bool + LocalAccount string + TLS bool + TLSConfig *tls.Config + TLSTimeout float64 + URLs []*url.URL + type RemoteLeafOptsVarz struct + LocalAccount string + TLSTimeout float64 + URLs []string + type ResponsePermission struct + Expires time.Duration + MaxMsgs int + type RouteInfo struct + DidSolicit bool + Export *SubjectPermission + IP string + Import *SubjectPermission + InBytes int64 + InMsgs int64 + IsConfigured bool + NumSubs uint32 + OutBytes int64 + OutMsgs int64 + Pending int + Port int + RTT string + RemoteID string + Rid uint64 + Subs []string + SubsDetail []SubDetail + type RoutePermissions struct + Export *SubjectPermission + Import *SubjectPermission + type RouteStat struct + ID uint64 + Name string + Pending int + Received DataStats + Sent DataStats + type RouteType int + const Explicit + const Implicit + type Routez struct + Export *SubjectPermission + ID string + Import *SubjectPermission + Now time.Time + NumRoutes int + Routes []*RouteInfo + type RoutezOptions struct + Subscriptions bool + SubscriptionsDetail bool + type Server struct + func New(opts *Options) *Server + func NewServer(opts *Options) (*Server, error) + func (s *Server) AcceptLoop(clr chan struct{}) + func (s *Server) AccountResolver() AccountResolver + func (s *Server) Addr() net.Addr + func (s *Server) ClientURL() string + func (s *Server) ClusterAddr() *net.TCPAddr + func (s *Server) ConfigTime() time.Time + func (s *Server) ConfigureLogger() + func (s *Server) Connz(opts *ConnzOptions) (*Connz, error) + func (s *Server) Debugf(format string, v ...interface{}) + func (s *Server) Errorc(ctx string, e error) + func (s *Server) Errorf(format string, v ...interface{}) + func (s *Server) Errors(scope interface{}, e error) + func (s *Server) Errorsc(scope interface{}, ctx string, e error) + func (s *Server) EventsEnabled() bool + func (s *Server) Fatalf(format string, v ...interface{}) + func (s *Server) GatewayAddr() *net.TCPAddr + func (s *Server) Gatewayz(opts *GatewayzOptions) (*Gatewayz, error) + func (s *Server) GetClient(cid uint64) *client + func (s *Server) GetLeafNode(cid uint64) *client + func (s *Server) HTTPHandler() http.Handler + func (s *Server) HandleConnz(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleGatewayz(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleLeafz(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleRoot(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleRoutez(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleStacksz(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleSubsz(w http.ResponseWriter, r *http.Request) + func (s *Server) HandleVarz(w http.ResponseWriter, r *http.Request) + func (s *Server) ID() string + func (s *Server) Leafz(opts *LeafzOptions) (*Leafz, error) + func (s *Server) LookupAccount(name string) (*Account, error) + func (s *Server) LookupOrRegisterAccount(name string) (account *Account, isNew bool) + func (s *Server) MemoryPipe() *pipe.Pipe + func (s *Server) MonitorAddr() *net.TCPAddr + func (s *Server) NewAccountsAllowed() bool + func (s *Server) NonceRequired() bool + func (s *Server) Noticef(format string, v ...interface{}) + func (s *Server) NumActiveAccounts() int32 + func (s *Server) NumClients() int + func (s *Server) NumLeafNodes() int + func (s *Server) NumLoadedAccounts() int + func (s *Server) NumOutboundGateways() int + func (s *Server) NumRemotes() int + func (s *Server) NumRoutes() int + func (s *Server) NumSlowConsumers() int64 + func (s *Server) NumSubscriptions() uint32 + func (s *Server) PortsInfo(maxWait time.Duration) *Ports + func (s *Server) ProfilerAddr() *net.TCPAddr + func (s *Server) ReOpenLogFile() + func (s *Server) ReadyForConnections(dur time.Duration) bool + func (s *Server) RegisterAccount(name string) (*Account, error) + func (s *Server) Reload() error + func (s *Server) Routez(routezOpts *RoutezOptions) (*Routez, error) + func (s *Server) SetAccountResolver(ar AccountResolver) + func (s *Server) SetLogger(logger Logger, debugFlag, traceFlag bool) + func (s *Server) SetLoggerV2(logger Logger, debugFlag, traceFlag, sysTrace bool) + func (s *Server) SetSystemAccount(accName string) error + func (s *Server) Shutdown() + func (s *Server) Start() + func (s *Server) StartHTTPMonitoring() + func (s *Server) StartHTTPSMonitoring() + func (s *Server) StartMonitoring() error + func (s *Server) StartProfiler() + func (s *Server) StartRouting(clientListenReady chan struct{}) + func (s *Server) StartWithPipe(mp *pipe.Pipe) + func (s *Server) Subsz(opts *SubszOptions) (*Subsz, error) + func (s *Server) SystemAccount() *Account + func (s *Server) Tracef(format string, v ...interface{}) + func (s *Server) TrackedRemoteServers() int + func (s *Server) UpdateAccountClaims(a *Account, ac *jwt.AccountClaims) + func (s *Server) Varz(varzOpts *VarzOptions) (*Varz, error) + func (s *Server) WaitForShutdown() + func (s *Server) Warnf(format string, v ...interface{}) + type ServerInfo struct + Cluster string + Host string + ID string + Name string + Seq uint64 + Time time.Time + Version string + type ServerStats struct + ActiveAccounts int + CPU float64 + Connections int + Cores int + Gateways []*GatewayStat + Mem int64 + NumSubs uint32 + Received DataStats + Routes []*RouteStat + Sent DataStats + SlowConsumers int64 + Start time.Time + TotalConnections uint64 + type ServerStatsMsg struct + Server ServerInfo + Stats ServerStats + type ServiceLatency struct + AppName string + NATSLatency NATSLatency + RequestStart time.Time + ServiceLatency time.Duration + TotalLatency time.Duration + type ServiceRespType uint8 + const Chunked + const Singleton + const Stream + func (rt ServiceRespType) String() string + type SortOpt string + const ByCid + const ByIdle + const ByInBytes + const ByInMsgs + const ByLast + const ByOutBytes + const ByOutMsgs + const ByPending + const ByReason + const ByStart + const ByStop + const BySubs + const ByUptime + func (s SortOpt) IsValid() bool + type SubDetail struct + Cid uint64 + Max int64 + Msgs int64 + Queue string + Sid string + Subject string + type SubjectPermission struct + Allow []string + Deny []string + type Sublist struct + func NewSublist(enableCache bool) *Sublist + func NewSublistNoCache() *Sublist + func NewSublistWithCache() *Sublist + func (s *Sublist) All(subs *[]*subscription) + func (s *Sublist) CacheCount() int + func (s *Sublist) CacheEnabled() bool + 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) RemoveAllForClient(c *client) + func (s *Sublist) RemoveBatch(subs []*subscription) error + func (s *Sublist) Stats() *SublistStats + func (s *Sublist) UpdateRemoteQSub(sub *subscription) + type SublistResult struct + type SublistStats struct + AvgFanout float64 + CacheHitRate float64 + MaxFanout uint32 + NumCache uint32 + NumInserts uint64 + NumMatches uint64 + NumRemoves uint64 + NumSubs uint32 + type Subsz struct + ID string + Limit int + Now time.Time + Offset int + Subs []SubDetail + Total int + type SubszOptions struct + Limit int + Offset int + Subscriptions bool + Test string + type TLSConfigOpts struct + CaFile string + CertFile string + Ciphers []uint16 + CurvePreferences []tls.CurveID + Insecure bool + KeyFile string + Map bool + Timeout float64 + Verify bool + type URLAccResolver struct + func NewURLAccResolver(url string) (*URLAccResolver, error) + func (ur *URLAccResolver) Fetch(name string) (string, error) + func (ur *URLAccResolver) Store(name, jwt string) error + type User struct + Account *Account + Password string + Permissions *Permissions + Username string + type Varz struct + AuthRequired bool + AuthTimeout float64 + CPU float64 + ClientConnectURLs []string + Cluster ClusterOptsVarz + ConfigLoadTime time.Time + Connections int + Cores int + Gateway GatewayOptsVarz + GitCommit string + GoVersion string + HTTPBasePath string + HTTPHost string + HTTPPort int + HTTPReqStats map[string]uint64 + HTTPSPort int + Host string + ID string + IP string + InBytes int64 + InMsgs int64 + LeafNode LeafNodeOptsVarz + Leafs int + MaxConn int + MaxControlLine int32 + MaxPayload int + MaxPending int64 + MaxPingsOut int + MaxProcs int + MaxSubs int + Mem int64 + Name string + Now time.Time + OutBytes int64 + OutMsgs int64 + PingInterval time.Duration + Port int + Proto int + Remotes int + Routes int + SlowConsumers int64 + Start time.Time + Subscriptions uint32 + TLSRequired bool + TLSTimeout float64 + TLSVerify bool + TotalConnections uint64 + Uptime string + Version string + WriteDeadline time.Duration + type VarzOptions struct v1.4.0 Apr 11, 2020 v1.2.0 Apr 2, 2020