server

package

Go to main page

Versions in this module

v2

v2.11.0-preview.1

Feb 27, 2024

v2.11.0-dev

Oct 17, 2023

v2.10.14

Apr 11, 2024

Changes in this version

type StreamStore

+ LoadNextMsgMulti func(sl *Sublist, start uint64, smp *StoreMsg) (sm *StoreMsg, skip uint64, err error)

v2.10.12

Mar 12, 2024

Changes in this version

+ var ErrLeafNodeLoop = errors.New("leafnode loop detected")

v2.10.11

Feb 15, 2024

Changes in this version

+ const JSAdvisoryDomainLeaderElected

+ const JSDomainLeaderElectedAdvisoryType

+ type JSDomainLeaderElectedAdvisory struct

+ Cluster string

+ Domain string

+ Leader string

+ Replicas []*PeerInfo

v2.10.10

Feb 2, 2024

Changes in this version

type ClusterOpts

+ MaxPingsOut int

+ PingInterval time.Duration

v2.10.9

Jan 11, 2024

v2.10.8

Jan 10, 2024

Changes in this version

+ const JSApiSystemResponseType

type JetStreamTier

+ ReservedMemory uint64

+ ReservedStore uint64

type LeafNodeOpts

+ Nkey string

type RemoteLeafOpts

+ Nkey string

type StreamStore

+ SkipMsgs func(seq uint64, num uint64) error

+ type TLSCertPairOpt struct

+ CertFile string

+ KeyFile string

type TLSConfigOpts

+ Certificates []*TLSCertPairOpt

v2.10.7

Dec 6, 2023

v2.10.6

Dec 1, 2023

v2.10.5

Nov 9, 2023

v2.10.4

Oct 27, 2023

Changes in this version

+ const DEFAULT_TLS_HANDSHAKE_FIRST_FALLBACK_DELAY

type ClusterInfo

+ RaftGroup string

type ConnInfo

+ TLSFirst bool

type JSConsumerDeliveryTerminatedAdvisory

+ Reason string

type Options

+ TLSHandshakeFirst bool

+ TLSHandshakeFirstFallback time.Duration

type TLSConfigOpts

+ FallbackDelay time.Duration

v2.10.3

Oct 12, 2023

v2.10.2

Oct 6, 2023

Changes in this version

type Options

+ ProfBlockRate int

v2.10.1

Sep 20, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.10.0

Sep 19, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const AuthCalloutSubject

+ const AuthRequestSubject

+ const AuthRequestXKeyHeader

+ const CompressionAccept

+ const CompressionNotSupported

+ const CompressionOff

+ const CompressionS2Auto

+ const CompressionS2Best

+ const CompressionS2Better

+ const CompressionS2Fast

+ const CompressionS2Uncompressed

+ const DEFAULT_ROUTE_POOL_SIZE

+ const JSMaxMetadataLen

+ const JsPullRequestRemainingBytesT

+ const Kicked

+ var ErrBadStreamStateEncoding = errors.New("bad stream state encoding")

+ var ErrCorruptStreamState = errors.New("stream state snapshot is corrupt")

+ var ErrMappingDestinationIndexOutOfRange = fmt.Errorf("%w: wildcard index out of range", ErrInvalidMappingDestination)

+ var ErrMappingDestinationInvalidArg = fmt.Errorf("%w: function argument is invalid or in the wrong format", ...)

+ var ErrMappingDestinationNotEnoughArgs = fmt.Errorf("%w: not enough arguments passed to the function", ...)

+ var ErrMappingDestinationNotSupportedForImport = fmt.Errorf(...)

+ var ErrMappingDestinationTooManyArgs = fmt.Errorf("%w: too many arguments passed to the function", ErrInvalidMappingDestination)

+ func CommandToSignal(command Command) (syscall.Signal, error) — darwin/amd64, linux/amd64

+ func IsEncodedStreamState(buf []byte) bool

+ func NewSubjectTransform(src, dest string) (*subjectTransform, error)

+ func NewSubjectTransformStrict(src, dest string) (*subjectTransform, error)

+ func NewSubjectTransformWithStrict(src, dest string, strict bool) (*subjectTransform, error)

type AccountStat

+ NumSubs uint32

type ApiError

+ func NewJSConsumerAlreadyExistsError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDoesNotExistError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDuplicateFilterSubjectsError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerEmptyFilterError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerInactiveThresholdExcessError(limit interface{}, opts ...ErrorOption) *ApiError

+ func NewJSConsumerMetadataLengthError(limit interface{}, opts ...ErrorOption) *ApiError

+ func NewJSConsumerMultipleFiltersNotAllowedError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerOverlappingSubjectFiltersError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorInvalidStreamNameError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorInvalidSubjectFilterError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorMultipleFiltersNotAllowedError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorOverlappingSubjectFiltersError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorWithFirstSeqError(opts ...ErrorOption) *ApiError

+ func NewJSSourceDuplicateDetectedError(opts ...ErrorOption) *ApiError

+ func NewJSSourceInvalidStreamNameError(opts ...ErrorOption) *ApiError

+ func NewJSSourceInvalidSubjectFilterError(opts ...ErrorOption) *ApiError

+ func NewJSSourceInvalidTransformDestinationError(opts ...ErrorOption) *ApiError

+ func NewJSSourceMultipleFiltersNotAllowedError(opts ...ErrorOption) *ApiError

+ func NewJSSourceOverlappingSubjectFiltersError(opts ...ErrorOption) *ApiError

+ type AuthCallout struct

+ Account string

+ AuthUsers []string

+ Issuer string

+ XKey string

type ClientInfo

+ Nonce string

type ClientOpts

+ RemoteAccount string

type ClusterOpts

+ Compression CompressionOpts

+ PinnedAccounts []string

+ PoolSize int

type ClusterOptsVarz

+ PoolSize int

+ type CompressionInfo struct

+ Algorithm StoreCompression

+ OriginalSize uint64

+ func (c *CompressionInfo) MarshalMetadata() []byte

+ func (c *CompressionInfo) UnmarshalMetadata(b []byte) (int, error)

+ type CompressionOpts struct

+ Mode string

+ RTTThresholds []time.Duration

+ type ConsumerAction int

+ const ActionCreate

+ const ActionCreateOrUpdate

+ const ActionUpdate

+ func (a *ConsumerAction) UnmarshalJSON(data []byte) error

+ func (a ConsumerAction) MarshalJSON() ([]byte, error)

+ func (a ConsumerAction) String() string

type ConsumerConfig

+ FilterSubjects []string

+ Metadata map[string]string

type ConsumerInfo

+ TimeStamp time.Time

type CreateConsumerRequest

+ Action ConsumerAction

+ type DeleteBlock interface

+ Range func(f func(uint64) bool)

+ State func() (first, last, num uint64)

+ type DeleteBlocks []DeleteBlock

+ func (dbs DeleteBlocks) NumDeleted() (total uint64)

+ type DeleteRange struct

+ First uint64

+ Num uint64

+ func (dr *DeleteRange) Range(f func(uint64) bool)

+ func (dr *DeleteRange) State() (first, last, num uint64)

+ type DeleteSlice []uint64

+ func (ds DeleteSlice) Range(f func(uint64) bool)

+ func (ds DeleteSlice) State() (first, last, num uint64)

type ErrorIdentifier

+ const JSConsumerAlreadyExists

+ const JSConsumerDoesNotExist

+ const JSConsumerDuplicateFilterSubjects

+ const JSConsumerEmptyFilter

+ const JSConsumerInactiveThresholdExcess

+ const JSConsumerMetadataLengthErrF

+ const JSConsumerMultipleFiltersNotAllowed

+ const JSConsumerOverlappingSubjectFilters

+ const JSMirrorInvalidStreamName

+ const JSMirrorInvalidSubjectFilter

+ const JSMirrorMultipleFiltersNotAllowed

+ const JSMirrorOverlappingSubjectFilters

+ const JSMirrorWithFirstSeqErr

+ const JSSourceDuplicateDetected

+ const JSSourceInvalidStreamName

+ const JSSourceInvalidSubjectFilter

+ const JSSourceInvalidTransformDestination

+ const JSSourceMultipleFiltersNotAllowed

+ const JSSourceOverlappingSubjectFilters

type FileStoreConfig

+ Compression StoreCompression

+ SyncAlways bool

type HealthStatus

+ Errors []HealthzError

+ StatusCode int

+ type HealthZErrorType int

+ const HealthzErrorAccount

+ const HealthzErrorBadRequest

+ const HealthzErrorConn

+ const HealthzErrorConsumer

+ const HealthzErrorJetStream

+ const HealthzErrorStream

+ func (t *HealthZErrorType) UnmarshalJSON(data []byte) error

+ func (t HealthZErrorType) MarshalJSON() ([]byte, error)

+ func (t HealthZErrorType) String() string

+ type HealthzError struct

+ Account string

+ Consumer string

+ Error string

+ Stream string

+ Type HealthZErrorType

type HealthzOptions

+ Account string

+ Consumer string

+ Details bool

+ Stream string

type Info

+ Compression string

+ RouteAccReqID string

+ RouteAccount string

+ RoutePoolIdx int

+ RoutePoolSize int

+ XKey string

type JetStreamConfig

+ SyncAlways bool

+ SyncInterval time.Duration

+ UniqueTag string

+ type KickClientReq struct

+ CID uint64

+ type LDMClientReq struct

+ CID uint64

type LeafInfo

+ Compression string

type LeafNodeOpts

+ Compression CompressionOpts

+ TLSHandshakeFirst bool

type Options

+ AuthCallout *AuthCallout

+ DisableJetStreamBanner bool

+ JetStreamOldKey string

+ LogMaxFiles int64

+ SyncAlways bool

+ SyncInterval time.Duration

+ type ProfilezEventOptions struct

+ type ProfilezOptions struct

+ Debug int

+ Name string

+ type ProfilezStatus struct

+ Error string

+ Profile []byte

type RemoteLeafOpts

+ Compression CompressionOpts

+ TLSHandshakeFirst bool

type RouteInfo

+ Account string

+ Compression string

type Server

+ func (s *Server) DisconnectClientByID(id uint64) error

+ func (s *Server) LDMClientByID(id uint64) error

+ func (s *Server) NumSlowConsumersClients() uint64

+ func (s *Server) NumSlowConsumersGateways() uint64

+ func (s *Server) NumSlowConsumersLeafs() uint64

+ func (s *Server) NumSlowConsumersRoutes() uint64

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

+ type ServerCapability uint64

+ const BinaryStreamSnapshot

+ const JetStreamEnabled

+ type ServerID struct

+ Host string

+ ID string

+ Name string

type ServerInfo

+ Flags ServerCapability

+ func (si *ServerInfo) BinaryStreamSnapshot() bool

+ func (si *ServerInfo) JetStreamEnabled() bool

+ func (si *ServerInfo) SetBinaryStreamSnapshot()

+ func (si *ServerInfo) SetJetStreamEnabled()

+ type SlowConsumersStats struct

+ Clients uint64

+ Gateways uint64

+ Leafs uint64

+ Routes uint64

+ type StoreCompression uint8

+ const NoCompression

+ const S2Compression

+ func (alg *StoreCompression) UnmarshalJSON(b []byte) error

+ func (alg StoreCompression) Compress(buf []byte) ([]byte, error)

+ func (alg StoreCompression) Decompress(buf []byte) ([]byte, error)

+ func (alg StoreCompression) MarshalJSON() ([]byte, error)

+ func (alg StoreCompression) String() string

type StreamConfig

+ Compression StoreCompression

+ ConsumerLimits StreamConsumerLimits

+ FirstSeq uint64

+ Metadata map[string]string

+ SubjectTransform *SubjectTransformConfig

+ type StreamConsumerLimits struct

+ InactiveThreshold time.Duration

+ MaxAckPending int

type StreamInfo

+ TimeStamp time.Time

+ type StreamReplicatedState struct

+ Bytes uint64

+ Deleted DeleteBlocks

+ Failed uint64

+ FirstSeq uint64

+ LastSeq uint64

+ Msgs uint64

+ func DecodeStreamState(buf []byte) (*StreamReplicatedState, error)

type StreamSource

+ SubjectTransformDest string

+ SubjectTransforms []SubjectTransformConfig

type StreamSourceInfo

+ FilterSubject string

+ SubjectTransformDest string

+ SubjectTransforms []SubjectTransformConfig

type StreamStore

+ EncodedStreamState func(failed uint64) (enc []byte, err error)

+ SyncDeleted func(dbs DeleteBlocks)

+ type SubjectTransformConfig struct

+ Destination string

+ Source string

type SubjectTransformer

+ TransformSubject func(subject string) string

+ TransformTokenizedSubject func(tokens []string) string

type TLSConfigOpts

+ HandshakeFirst bool

type User

+ ConnectionDeadline time.Time

+ type UserInfo struct

+ Account string

+ Expires time.Duration

+ Permissions *Permissions

+ UserID string

type Varz

+ SlowConsumersStats *SlowConsumersStats

v2.9.25

Mar 1, 2024

v2.9.24

Nov 8, 2023

v2.9.23

Oct 12, 2023

v2.9.22

Sep 6, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.21

Aug 4, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const OCSPPeerChainlinkInvalidEventMsgType

+ const OCSPPeerRejectEventMsgType

+ const OCSPResponseCacheDefaultDir

+ const OCSPResponseCacheDefaultFilename

+ const OCSPResponseCacheDefaultSaveInterval

+ const OCSPResponseCacheDefaultTempFilePrefix

+ const OCSPResponseCacheMinimumSaveInterval

+ var OCSPResponseCacheTypeMap = map[string]OCSPResponseCacheType

+ var OCSPResponseCacheUsage = ...

type LeafNodeOptsVarz

+ TLSOCSPPeerVerify bool

+ type LocalCache struct

+ func (c *LocalCache) Compress(buf []byte) ([]byte, error)

+ func (c *LocalCache) Config() *OCSPResponseCacheConfig

+ func (c *LocalCache) Decompress(buf []byte) ([]byte, error)

+ func (c *LocalCache) Delete(key string, wasMiss bool, log *certidp.Log)

+ func (c *LocalCache) Get(key string, log *certidp.Log) []byte

+ func (c *LocalCache) Online() bool

+ func (c *LocalCache) Put(key string, caResp *ocsp.Response, subj string, log *certidp.Log)

+ func (c *LocalCache) Start(s *Server)

+ func (c *LocalCache) Stats() *OCSPResponseCacheStats

+ func (c *LocalCache) Stop(s *Server)

+ func (c *LocalCache) Type() string

type MQTTOptsVarz

+ TLSOCSPPeerVerify bool

+ type NoOpCache struct

+ func (c *NoOpCache) Config() *OCSPResponseCacheConfig

+ func (c *NoOpCache) Delete(_ string, _ bool, _ *certidp.Log)

+ func (c *NoOpCache) Get(_ string, _ *certidp.Log) []byte

+ func (c *NoOpCache) Online() bool

+ func (c *NoOpCache) Put(_ string, _ *ocsp.Response, _ string, _ *certidp.Log)

+ func (c *NoOpCache) Start(_ *Server)

+ func (c *NoOpCache) Stats() *OCSPResponseCacheStats

+ func (c *NoOpCache) Stop(_ *Server)

+ func (c *NoOpCache) Type() string

+ type OCSPPeerChainlinkInvalidEventMsg struct

+ Link certidp.CertInfo

+ Peer certidp.CertInfo

+ Reason string

+ Server ServerInfo

+ type OCSPPeerRejectEventMsg struct

+ Kind string

+ Peer certidp.CertInfo

+ Reason string

+ Server ServerInfo

+ type OCSPResponseCache interface

+ Config func() *OCSPResponseCacheConfig

+ Delete func(key string, miss bool, log *certidp.Log)

+ Get func(key string, log *certidp.Log) []byte

+ Online func() bool

+ Put func(key string, resp *ocsp.Response, subj string, log *certidp.Log)

+ Start func(s *Server)

+ Stats func() *OCSPResponseCacheStats

+ Stop func(s *Server)

+ Type func() string

+ type OCSPResponseCacheConfig struct

+ LocalStore string

+ PreserveRevoked bool

+ SaveInterval float64

+ Type OCSPResponseCacheType

+ func NewOCSPResponseCacheConfig() *OCSPResponseCacheConfig

+ type OCSPResponseCacheItem struct

+ CachedAt time.Time

+ Resp []byte

+ RespExpires time.Time

+ RespStatus certidp.StatusAssertion

+ Subject string

+ type OCSPResponseCacheStats struct

+ Goods int64

+ Hits int64

+ Misses int64

+ Responses int64

+ Revokes int64

+ Unknowns int64

+ type OCSPResponseCacheType int

+ const LOCAL

+ const NONE

+ type OCSPResponseCacheVarz struct

+ Goods int64

+ Hits int64

+ Misses int64

+ Responses int64

+ Revokes int64

+ Type string

+ Unknowns int64

type Options

+ LogtimeUTC bool

+ OCSPCacheConfig *OCSPResponseCacheConfig

type RemoteLeafOptsVarz

+ TLSOCSPPeerVerify bool

type TLSConfigOpts

+ OCSPPeerConfig *certidp.OCSPPeerConfig

type Varz

+ OCSPResponseCache OCSPResponseCacheVarz

+ TLSOCSPPeerVerify bool

type WebsocketOptsVarz

+ TLSOCSPPeerVerify bool

v2.9.20

Jul 13, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type TLSConfigOpts

+ CertMatch string

+ CertMatchBy certstore.MatchByType

+ CertStore certstore.StoreType

v2.9.19

Jun 20, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.18

Jun 13, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.17

May 18, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ type Number interface

type SortOpt

+ const ByRTT

v2.9.16

Apr 17, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type CommittedEntry

+ func (ce *CommittedEntry) ReturnToPool()

type RouteInfo

+ RemoteName string

type Routez

+ Name string

type Server

+ func (s *Server) JetStreamStepdownConsumer(account, stream, consumer string) error

v2.9.15

Mar 2, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type JSzOptions

+ RaftGroups bool

type LeafInfo

+ IsSpoke bool

+ Name string

+ type RaftGroupDetail struct

+ Name string

+ RaftGroup string

type StoreCipher

+ const NoCipher

type StreamDetail

+ ConsumerRaftGroups []*RaftGroupDetail

+ RaftGroup string

type StreamStore

+ NumPending func(sseq uint64, filter string, lastPerSubject bool) (total, validThrough uint64)

+ SubjectsTotals func(filterSubject string) map[string]uint64

v2.9.14

Feb 6, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.12

Feb 2, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ func SnapshotMonitorInfo()

type ApiError

+ func NewJSConsumerReplicasShouldMatchStreamError(opts ...ErrorOption) *ApiError

type ErrorIdentifier

+ const JSConsumerReplicasShouldMatchStream

type RaftNode

+ Healthy func() bool

v2.9.11

Jan 6, 2023 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type RaftNode

+ IsObserver func() bool

+ SetObserver func(isObserver bool)

v2.9.10

Dec 20, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type HealthzOptions

+ JSEnabledOnly bool

v2.9.9

Dec 8, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.8

Nov 22, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.7

Nov 17, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ConsumerStore

+ BorrowState func() (*ConsumerState, error)

type StreamDetail

+ Created time.Time

v2.9.6

Nov 4, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.5

Nov 1, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.4

Oct 27, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSPullRequestPendingBytes

+ const JSPullRequestPendingMsgs

v2.9.3

Oct 10, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ApiError

+ func NewJSReplicasCountCannotBeNegativeError(opts ...ErrorOption) *ApiError

type ErrorIdentifier

+ const JSReplicasCountCannotBeNegative

v2.9.2

Sep 29, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.9.1

Sep 22, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ApiError

+ func NewJSConsumerCreateDurableAndNameMismatchError(opts ...ErrorOption) *ApiError

type ErrorIdentifier

+ const JSConsumerCreateDurableAndNameMismatch

type JSApiMetaServerRemoveRequest

+ Peer string

type MetaClusterInfo

+ Peer string

type PeerInfo

+ Peer string

type StreamConfig

+ DiscardNewPer bool

v2.9.0

Sep 9, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const AccountStatzPath

+ const BadTransform

+ const ClusterNamesIdentical

+ const JSApiAccountPurge

+ const JSApiAccountPurgeResponseType

+ const JSApiAccountPurgeT

+ const JSApiConsumerCreateEx

+ const JSApiConsumerCreateExT

+ const JSApiServerStreamCancelMove

+ const JSApiServerStreamCancelMoveT

+ const JSApiServerStreamMove

+ const JSApiServerStreamMoveT

+ const JSDirectGetLastBySubject

+ const JSDirectGetLastBySubjectT

+ const JSDirectMsgGet

+ const JSDirectMsgGetT

+ const JSSubject

+ const JSTimeStamp

+ const NoTransform

+ const Partition

+ const SliceFromLeft

+ const SliceFromRight

+ const Split

+ const SplitFromLeft

+ const SplitFromRight

+ const Wildcard

+ var ErrInvalidMappingDestination = errors.New("invalid mapping destination")

+ var ErrInvalidMappingDestinationSubject = fmt.Errorf("%w: invalid subject", ErrInvalidMappingDestination)

+ var ErrLeafNodeDisabled = errors.New("leafnodes disabled")

+ var ErrLeafNodeHasSameClusterName = errors.New("remote leafnode has same cluster name")

+ var ErrMappingDestinationNotUsingAllWildcards = fmt.Errorf("%w: not using all of the token wildcard(s)", ErrInvalidMappingDestination)

+ var ErrUnknownMappingDestinationFunction = fmt.Errorf("%w: unknown function", ErrInvalidMappingDestination)

+ var ErrorMappingDestinationFunctionInvalidArgument = fmt.Errorf("%w: function argument is invalid or in the wrong format", ...)

+ var ErrorMappingDestinationFunctionNotEnoughArguments = fmt.Errorf("%w: not enough arguments passed to the function", ...)

+ var ErrorMappingDestinationFunctionTooManyArguments = fmt.Errorf("%w: too many arguments passed to the function", ErrInvalidMappingDestination)

+ var ErrorMappingDestinationFunctionWildcardIndexOutOfRange = fmt.Errorf("%w: wildcard index out of range", ErrInvalidMappingDestination)

+ func GatewayDoNotForceInterestOnlyMode(doNotForce bool)

+ func ValidateMappingDestination(subject string) error

+ type AccountStat struct

+ Account string

+ Conns int

+ LeafNodes int

+ Received DataStats

+ Sent DataStats

+ SlowConsumers int64

+ TotalConns int

+ type AccountStatz struct

+ Accounts []*AccountStat

+ ID string

+ Now time.Time

+ type AccountStatzEventOptions struct

+ type AccountStatzOptions struct

+ Accounts []string

+ IncludeUnused bool

type ApiError

+ func NewJSConsumerCreateFilterSubjectMismatchError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerNameContainsPathSeparatorsError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMoveNotInProgressError(opts ...ErrorOption) *ApiError

+ func NewJSStreamNameContainsPathSeparatorsError(opts ...ErrorOption) *ApiError

+ func NewJSStreamNameExistRestoreFailedError(opts ...ErrorOption) *ApiError

type ConnInfo

+ TLSPeerCerts []*TLSPeerCert

type ConsumerConfig

+ Name string

type ErrorIdentifier

+ const JSClusterNoPeersErrF

+ const JSConsumerCreateFilterSubjectMismatchErr

+ const JSConsumerNameContainsPathSeparatorsErr

+ const JSStreamMoveInProgressF

+ const JSStreamMoveNotInProgress

+ const JSStreamNameContainsPathSeparatorsErr

+ const JSStreamNameExistRestoreFailedErr

type FileStoreConfig

+ Cipher StoreCipher

+ type HealthzEventOptions struct

+ type HealthzOptions struct

+ JSEnabled bool

+ JSServerOnly bool

type Info

+ GatewayIOM bool

+ type JSApiAccountPurgeResponse struct

+ Initiated bool

+ type JSApiMetaServerStreamMoveRequest struct

+ Cluster string

+ Domain string

+ Server string

+ Tags []string

type JSApiMsgGetRequest

+ NextFor string

type JetStreamConfig

+ CompressOK bool

type MQTTOpts

+ ConsumerInactiveThreshold time.Duration

type Options

+ DontListen bool

+ JetStreamCipher StoreCipher

+ JetStreamMaxCatchup int64

+ type RePublish struct

+ Destination string

+ HeadersOnly bool

+ Source string

type RemoteLeafOpts

+ JetStreamClusterMigrate bool

+ SignatureCB SignatureHandler

type Server

+ func (s *Server) AccountStatz(opts *AccountStatzOptions) (*AccountStatz, error)

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

+ func (s *Server) InProcessConn() (net.Conn, error)

+ type SignatureHandler func([]byte) (string, []byte, error)

+ type StoreCipher int

+ const AES

+ const ChaCha

+ func (cipher StoreCipher) String() string

type StreamConfig

+ AllowDirect bool

+ MirrorDirect bool

+ type SubjectTransformer interface

+ Match func(string) (string, error)

+ func NewSubjectTransformer(src, dest string) (SubjectTransformer, error)

+ type TLSPeerCert struct

+ CertSha256 string

+ Subject string

+ SubjectPKISha256 string

v2.8.4

May 26, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.8.3

May 23, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSLastSequence

+ const JSSequence

+ const JSStream

+ var ErrPurgeArgMismatch = errors.New("sequence > 1 && keep > 0 not allowed")

type ApiError

+ func NewJSConsumerReplicasExceedsStreamError(opts ...ErrorOption) *ApiError

type ConsumerConfig

+ MaxRequestMaxBytes int

+ MemoryStorage bool

+ Replicas int

type ConsumerStore

+ HasState func() bool

+ SetStarting func(sseq uint64) error

type ErrorIdentifier

+ const JSConsumerReplicasExceedsStream

type JSApiConsumerGetNextRequest

+ MaxBytes int

type MQTTOpts

+ ConsumerMemoryStorage bool

+ ConsumerReplicas int

+ StreamReplicas int

type RouteInfo

+ Idle string

+ LastActivity time.Time

+ Start time.Time

+ Uptime string

type StreamConfig

+ RePublish *SubjectMapping

type StreamStore

+ AddConsumer func(o ConsumerStore) error

+ RemoveConsumer func(o ConsumerStore) error

+ type SubjectMapping struct

+ Destination string

+ Source string

v2.8.2

May 4, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSAdvisoryConsumerMsgNakPre

+ const JSConsumerDeliveryNakAdvisoryType

+ type JSConsumerDeliveryNakAdvisory struct

+ Consumer string

+ ConsumerSeq uint64

+ Deliveries uint64

+ Domain string

+ Stream string

+ StreamSeq uint64

v2.8.1

Apr 21, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.8.0

Apr 18, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const DuplicateServerName

+ const IPQueuesPath

+ const MinimumVersionRequired

+ var ErrBadSubjectMappingDestination = errors.New("invalid subject mapping destination")

+ var ErrDuplicateServerName = errors.New("duplicate server name")

+ var ErrMinimumVersionRequired = errors.New("minimum version required")

type ApiError

+ func NewJSConsumerMaxPendingAckExcessError(limit interface{}, opts ...ErrorOption) *ApiError

+ func NewJSConsumerMaxRequestBatchExceededError(limit interface{}, opts ...ErrorOption) *ApiError

+ func NewJSConsumerOfflineError(opts ...ErrorOption) *ApiError

+ func NewJSNoLimitsError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMaxStreamBytesExceededError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMoveAndScaleError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMoveInProgressError(opts ...ErrorOption) *ApiError

+ func NewJSStreamOfflineError(opts ...ErrorOption) *ApiError

type ConsumerStore

+ EncodedState func() ([]byte, error)

type ErrorIdentifier

+ const JSConsumerMaxPendingAckExcessErrF

+ const JSConsumerMaxRequestBatchExceededF

+ const JSConsumerOfflineErr

+ const JSNoLimitsErr

+ const JSStreamMaxStreamBytesExceeded

+ const JSStreamMoveAndScaleErr

+ const JSStreamMoveInProgress

+ const JSStreamOfflineErr

+ type JSLimitOpts struct

+ Duplicates time.Duration

+ MaxAckPending int

+ MaxHAAssets int

+ MaxRequestBatch int

type JetStreamAccountLimits

+ MaxAckPending int

+ MemoryMaxStreamBytes int64

+ StoreMaxStreamBytes int64

type JetStreamAccountStats

+ Tiers map[string]JetStreamTier

+ type JetStreamTier struct

+ Consumers int

+ Limits JetStreamAccountLimits

+ Memory uint64

+ Store uint64

+ Streams int

type LeafNodeOpts

+ MinVersion string

+ type MQTTOptsVarz struct

+ AckWait time.Duration

+ AuthTimeout float64

+ Host string

+ JsDomain string

+ MaxAckPending uint16

+ NoAuthUser string

+ Port int

+ TLSMap bool

+ TLSPinnedCerts []string

+ TLSTimeout float64

type Options

+ JetStreamLimits JSLimitOpts

+ JetStreamUniqueTag string

type RaftNode

+ Term func() uint64

+ UpdateKnownPeers func(knownPeers []string)

+ Wipe func()

type Server

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

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

+ type StoreMsg struct

+ type StreamAlternate struct

+ Cluster string

+ Domain string

+ Name string

type StreamInfo

+ Alternates []StreamAlternate

type Varz

+ MQTT MQTTOptsVarz

+ Websocket WebsocketOptsVarz

+ type WebsocketOptsVarz struct

+ Advertise string

+ AllowedOrigins []string

+ AuthTimeout float64

+ Compression bool

+ HandshakeTimeout time.Duration

+ Host string

+ JWTCookie string

+ NoAuthUser string

+ NoTLS bool

+ Port int

+ SameOrigin bool

+ TLSMap bool

+ TLSPinnedCerts []string

v2.7.4

Mar 9, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.7.3

Feb 24, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type JSApiConsumerGetNextRequest

+ Heartbeat time.Duration

type JetStreamStats

+ HAAssets int

type ServerInfo

+ Tags []string

type StreamStore

+ LoadNextMsg func(filter string, wc bool, start uint64) (subject string, seq uint64, hdr, msg []byte, ts int64, err error)

v2.7.2

Feb 4, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSMaxSubjectDetails

type ApiError

+ func NewJSStreamInfoMaxSubjectsError(opts ...ErrorOption) *ApiError

type ConsumerStore

+ UpdateConfig func(cfg *ConsumerConfig) error

type ErrorIdentifier

+ const JSStreamInfoMaxSubjectsErr

type JSApiStreamInfoRequest

+ SubjectsFilter string

type StreamState

+ NumSubjects int

+ Subjects map[string]uint64

v2.7.1

Jan 25, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const HealthzPath

type ApiError

+ func NewJSConsumerMaxDeliverBackoffError(opts ...ErrorOption) *ApiError

type ConsumerConfig

+ BackOff []time.Duration

+ type ConsumerNakOptions struct

+ Delay time.Duration

type ErrorIdentifier

+ const JSConsumerMaxDeliverBackoffErr

type ExtExport

+ RevokedAct map[string]time.Time

+ type HealthStatus struct

+ Error string

+ Status string

type Server

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

type StreamDetail

+ Mirror *StreamSourceInfo

+ Sources []*StreamSourceInfo

v2.7.0

Jan 14, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ApiError

+ func NewJSConsumerMaxRequestBatchNegativeError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerMaxRequestExpiresToSmallError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMaxBytesRequiredError(opts ...ErrorOption) *ApiError

type ClientInfo

+ Alternates []string

type ConsumerConfig

+ InactiveThreshold time.Duration

+ MaxRequestBatch int

+ MaxRequestExpires time.Duration

type ErrorIdentifier

+ const JSConsumerMaxRequestBatchNegativeErr

+ const JSConsumerMaxRequestExpiresToSmall

+ const JSStreamMaxBytesRequired

type JSApiConsumerListResponse

+ Missing []string

type JSApiStreamListResponse

+ Missing []string

type JetStreamAPIStats

+ Inflight uint64

type JetStreamAccountLimits

+ MaxBytesRequired bool

type MQTTOpts

+ JsDomain string

type Options

+ JetStreamExtHint string

+ JsAccDefaultDomain map[string]string

+ TLSRateLimit int64

type RaftNode

+ ApplyQ func() *ipQueue

type TLSConfigOpts

+ RateLimit int64

v2.7.0-rc2

Jan 13, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.7.0-rc1

Jan 13, 2022 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.6.6

Dec 2, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ApiError

+ func NewJSConsumerInvalidDeliverSubjectError(opts ...ErrorOption) *ApiError

type ErrorIdentifier

+ const JSConsumerInvalidDeliverSubject

v2.6.5

Nov 19, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ClientAuthentication

+ GetNonce func() []byte

+ type JSApiStreamListRequest struct

+ Subject string

type Options

+ AlwaysEnableNonce bool

v2.6.4

Nov 4, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSResponseType

+ var ErrTooManySubTokens = errors.New("subject has exceeded number of tokens limit")

type Options

+ MaxSubTokens uint8

v2.6.3

Oct 28, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.6.2

Oct 12, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSMsgRollup

+ const JSMsgRollupAll

+ const JSMsgRollupSubject

+ const JSMsgSize

type ApiError

+ func NewJSStreamPurgeFailedError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamRollupFailedError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamSealedError(opts ...ErrorOption) *ApiError

type ConsumerConfig

+ HeadersOnly bool

type ErrorIdentifier

+ const JSStreamPurgeFailedF

+ const JSStreamRollupFailedF

+ const JSStreamSealedErr

+ type MetaClusterInfo struct

+ Leader string

+ Name string

+ Replicas []*PeerInfo

+ Size int

type RaftNode

+ AdjustBootClusterSize func(csz int) error

+ ClusterSize func() int

type StreamConfig

+ AllowRollup bool

+ DenyDelete bool

+ DenyPurge bool

+ Sealed bool

v2.6.1

Sep 24, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.6.0

Sep 21, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ApiError

+ func NewJSConsumerWithFlowControlNeedsHeartbeatsError(opts ...ErrorOption) *ApiError

+ func NewJSStreamHeaderExceedsMaximumError(opts ...ErrorOption) *ApiError

type ConsumerStore

+ Type func() StorageType

type ErrorIdentifier

+ const JSConsumerWithFlowControlNeedsHeartbeats

+ const JSStreamHeaderExceedsMaximumErr

type JSApiStreamCreateResponse

+ DidCreate bool

type JetStreamStats

+ ReserveStoreUsed uint64

+ ReservedMemory uint64

+ ReservedMemoryUsed uint64

+ ReservedStore uint64

type StreamInfo

+ Domain string

v2.5.0

Sep 9, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ClientInfo

+ MQTTClient string

type ConnInfo

+ MQTTClient string

type ConnzOptions

+ MQTTClient string

v2.4.0

Aug 26, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSConsumerStalled

type ApiError

+ func NewJSAccountResourcesExceededError(opts ...ErrorOption) *ApiError

+ func NewJSBadRequestError(opts ...ErrorOption) *ApiError

+ func NewJSClusterIncompleteError(opts ...ErrorOption) *ApiError

+ func NewJSClusterNoPeersError(opts ...ErrorOption) *ApiError

+ func NewJSClusterNotActiveError(opts ...ErrorOption) *ApiError

+ func NewJSClusterNotAssignedError(opts ...ErrorOption) *ApiError

+ func NewJSClusterNotAvailError(opts ...ErrorOption) *ApiError

+ func NewJSClusterNotLeaderError(opts ...ErrorOption) *ApiError

+ func NewJSClusterPeerNotMemberError(opts ...ErrorOption) *ApiError

+ func NewJSClusterRequiredError(opts ...ErrorOption) *ApiError

+ func NewJSClusterServerNotMemberError(opts ...ErrorOption) *ApiError

+ func NewJSClusterTagsError(opts ...ErrorOption) *ApiError

+ func NewJSClusterUnSupportFeatureError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerBadDurableNameError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerConfigRequiredError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerCreateError(err error, opts ...ErrorOption) *ApiError

+ func NewJSConsumerDeliverCycleError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDeliverToWildcardsError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDescriptionTooLongError(max interface{}, opts ...ErrorOption) *ApiError

+ func NewJSConsumerDirectRequiresEphemeralError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDirectRequiresPushError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDurableNameNotInSubjectError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDurableNameNotMatchSubjectError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerDurableNameNotSetError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerEphemeralWithDurableInSubjectError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerEphemeralWithDurableNameError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerExistingActiveError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerFCRequiresPushError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerFilterNotSubsetError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerHBRequiresPushError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerInvalidPolicyError(err error, opts ...ErrorOption) *ApiError

+ func NewJSConsumerInvalidSamplingError(err error, opts ...ErrorOption) *ApiError

+ func NewJSConsumerMaxPendingAckPolicyRequiredError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerMaxWaitingNegativeError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerNameExistError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerNameTooLongError(max interface{}, opts ...ErrorOption) *ApiError

+ func NewJSConsumerNotFoundError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerOnMappedError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerPullNotDurableError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerPullRequiresAckError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerPullWithRateLimitError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerPushMaxWaitingError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerReplacementWithDifferentNameError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerSmallHeartbeatError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerStoreFailedError(err error, opts ...ErrorOption) *ApiError

+ func NewJSConsumerWQConsumerNotDeliverAllError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerWQConsumerNotUniqueError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerWQMultipleUnfilteredError(opts ...ErrorOption) *ApiError

+ func NewJSConsumerWQRequiresExplicitAckError(opts ...ErrorOption) *ApiError

+ func NewJSInsufficientResourcesError(opts ...ErrorOption) *ApiError

+ func NewJSInvalidJSONError(opts ...ErrorOption) *ApiError

+ func NewJSMaximumConsumersLimitError(opts ...ErrorOption) *ApiError

+ func NewJSMaximumStreamsLimitError(opts ...ErrorOption) *ApiError

+ func NewJSMemoryResourcesExceededError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorConsumerSetupFailedError(err error, opts ...ErrorOption) *ApiError

+ func NewJSMirrorMaxMessageSizeTooBigError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorWithSourcesError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorWithStartSeqAndTimeError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorWithSubjectFiltersError(opts ...ErrorOption) *ApiError

+ func NewJSMirrorWithSubjectsError(opts ...ErrorOption) *ApiError

+ func NewJSNoAccountError(opts ...ErrorOption) *ApiError

+ func NewJSNoMessageFoundError(opts ...ErrorOption) *ApiError

+ func NewJSNotEmptyRequestError(opts ...ErrorOption) *ApiError

+ func NewJSNotEnabledError(opts ...ErrorOption) *ApiError

+ func NewJSNotEnabledForAccountError(opts ...ErrorOption) *ApiError

+ func NewJSPeerRemapError(opts ...ErrorOption) *ApiError

+ func NewJSRaftGeneralError(err error, opts ...ErrorOption) *ApiError

+ func NewJSRestoreSubscribeFailedError(err error, subject interface{}, opts ...ErrorOption) *ApiError

+ func NewJSSequenceNotFoundError(seq uint64, opts ...ErrorOption) *ApiError

+ func NewJSSnapshotDeliverSubjectInvalidError(opts ...ErrorOption) *ApiError

+ func NewJSSourceConsumerSetupFailedError(err error, opts ...ErrorOption) *ApiError

+ func NewJSSourceMaxMessageSizeTooBigError(opts ...ErrorOption) *ApiError

+ func NewJSStorageResourcesExceededError(opts ...ErrorOption) *ApiError

+ func NewJSStreamAssignmentError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamCreateError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamDeleteError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamExternalApiOverlapError(prefix interface{}, subject interface{}, opts ...ErrorOption) *ApiError

+ func NewJSStreamExternalDelPrefixOverlapsError(prefix interface{}, subject interface{}, opts ...ErrorOption) *ApiError

+ func NewJSStreamGeneralError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamInvalidConfigError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamInvalidError(opts ...ErrorOption) *ApiError

+ func NewJSStreamInvalidExternalDeliverySubjError(prefix interface{}, opts ...ErrorOption) *ApiError

+ func NewJSStreamLimitsError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamMessageExceedsMaximumError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMirrorNotUpdatableError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMismatchError(opts ...ErrorOption) *ApiError

+ func NewJSStreamMsgDeleteFailedError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamNameExistError(opts ...ErrorOption) *ApiError

+ func NewJSStreamNotFoundError(opts ...ErrorOption) *ApiError

+ func NewJSStreamNotMatchError(opts ...ErrorOption) *ApiError

+ func NewJSStreamReplicasNotSupportedError(opts ...ErrorOption) *ApiError

+ func NewJSStreamReplicasNotUpdatableError(opts ...ErrorOption) *ApiError

+ func NewJSStreamRestoreError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamSequenceNotMatchError(opts ...ErrorOption) *ApiError

+ func NewJSStreamSnapshotError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamStoreFailedError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamSubjectOverlapError(opts ...ErrorOption) *ApiError

+ func NewJSStreamTemplateCreateError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamTemplateDeleteError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamTemplateNotFoundError(opts ...ErrorOption) *ApiError

+ func NewJSStreamUpdateError(err error, opts ...ErrorOption) *ApiError

+ func NewJSStreamWrongLastMsgIDError(id interface{}, opts ...ErrorOption) *ApiError

+ func NewJSStreamWrongLastSequenceError(seq uint64, opts ...ErrorOption) *ApiError

+ func NewJSTempStorageFailedError(opts ...ErrorOption) *ApiError

+ func NewJSTemplateNameNotMatchSubjectError(opts ...ErrorOption) *ApiError

type ConnInfo

+ Kind string

+ Type string

type ConnzOptions

+ FilterSubject string

type ConsumerConfig

+ DeliverGroup string

type ConsumerInfo

+ PushBound bool

+ type ErrorOption func(*errOpts)

+ func Unless(err error) ErrorOption

type PubAck

+ Domain string

+ type SequenceInfo struct

+ Consumer uint64

+ Last *time.Time

+ Stream uint64

+ type ServerAPIConnzResponse struct

+ Data *Connz

+ Error *ApiError

+ Server *ServerInfo

+ type ServerAPIResponse struct

+ Data interface{}

+ Error *ApiError

+ Server *ServerInfo

type StreamStore

+ Utilization func() (total, reported uint64, err error)

type Sublist

+ func (s *Sublist) ClearQueueNotification(subject, queue string, notify chan<- bool) bool

+ func (s *Sublist) RegisterQueueNotification(subject, queue string, notify chan<- bool) error

type Varz

+ PinnedAccountFail uint64

v2.3.4

Aug 4, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSMaxDescriptionLen

+ const MAX_PAYLOAD_MAX_SIZE

type ClientInfo

+ ClientType string

+ Kind string

type ConsumerConfig

+ Description string

type DeliverPolicy

+ const DeliverLastPerSubject

type ErrorIdentifier

+ const JSConsumerDescriptionTooLongErrF

type Info

+ Domain string

type Server

+ func (s *Server) JetStreamEnabledForDomain() bool

+ func (s *Server) ReloadOptions(newOpts *Options) error

type ServerInfo

+ Domain string

type StreamConfig

+ Description string

type StreamStore

+ SubjectsState func(filterSubject string) map[string]SimpleState

v2.3.3

Aug 2, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

v2.3.2

Jul 6, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ErrorIdentifier

+ const JSConsumerBadDurableNameErr

+ const JSConsumerConfigRequiredErr

+ const JSConsumerDeliverCycleErr

+ const JSConsumerDeliverToWildcardsErr

+ const JSConsumerDirectRequiresEphemeralErr

+ const JSConsumerDirectRequiresPushErr

+ const JSConsumerExistingActiveErr

+ const JSConsumerFCRequiresPushErr

+ const JSConsumerFilterNotSubsetErr

+ const JSConsumerHBRequiresPushErr

+ const JSConsumerInvalidPolicyErrF

+ const JSConsumerInvalidSamplingErrF

+ const JSConsumerMaxPendingAckPolicyRequiredErr

+ const JSConsumerMaxWaitingNegativeErr

+ const JSConsumerNameTooLongErrF

+ const JSConsumerOnMappedErr

+ const JSConsumerPullNotDurableErr

+ const JSConsumerPullRequiresAckErr

+ const JSConsumerPullWithRateLimitErr

+ const JSConsumerPushMaxWaitingErr

+ const JSConsumerReplacementWithDifferentNameErr

+ const JSConsumerSmallHeartbeatErr

+ const JSConsumerStoreFailedErrF

+ const JSConsumerWQConsumerNotDeliverAllErr

+ const JSConsumerWQConsumerNotUniqueErr

+ const JSConsumerWQMultipleUnfilteredErr

+ const JSConsumerWQRequiresExplicitAckErr

+ const JSStreamInvalidErr

+ const JSStreamMaximumConsumersReachedErr

v2.3.1

Jun 29, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JSExpectedLastSubjSeq

type ConsumerStore

+ StreamDelete func() error

type ErrorIdentifier

+ const JSStreamStoreFailedF

type JSApiMsgGetRequest

+ LastFor string

type StreamStore

+ LoadLastMsg func(subject string) (subj string, seq uint64, hdr, msg []byte, ts int64, err error)

v2.3.0

Jun 23, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const JetStreamMetaFileKey

+ var ApiErrors = map[ErrorIdentifier]*ApiError

+ var ErrMaxMsgsPerSubject = errors.New("maximum messages per subject exceeded")

+ func IsNatsErr(err error, ids ...ErrorIdentifier) bool

type ApiError

+ ErrCode uint16

+ func (e *ApiError) ErrOr(err error) *ApiError

+ func (e *ApiError) ErrOrNewT(err error, replacements ...interface{}) *ApiError

+ func (e *ApiError) Error() string

+ func (e *ApiError) NewT(replacements ...interface{}) *ApiError

type ApiResponse

+ func (r *ApiResponse) ToError() error

+ type ErrorIdentifier uint16

+ const JSAccountResourcesExceededErr

+ const JSBadRequestErr

+ const JSClusterIncompleteErr

+ const JSClusterNoPeersErr

+ const JSClusterNotActiveErr

+ const JSClusterNotAssignedErr

+ const JSClusterNotAvailErr

+ const JSClusterNotLeaderErr

+ const JSClusterPeerNotMemberErr

+ const JSClusterRequiredErr

+ const JSClusterServerNotMemberErr

+ const JSClusterTagsErr

+ const JSClusterUnSupportFeatureErr

+ const JSConsumerCreateErrF

+ const JSConsumerDurableNameNotInSubjectErr

+ const JSConsumerDurableNameNotMatchSubjectErr

+ const JSConsumerDurableNameNotSetErr

+ const JSConsumerEphemeralWithDurableInSubjectErr

+ const JSConsumerEphemeralWithDurableNameErr

+ const JSConsumerNameExistErr

+ const JSConsumerNotFoundErr

+ const JSInsufficientResourcesErr

+ const JSInvalidJSONErr

+ const JSMaximumConsumersLimitErr

+ const JSMaximumStreamsLimitErr

+ const JSMemoryResourcesExceededErr

+ const JSMirrorConsumerSetupFailedErrF

+ const JSMirrorMaxMessageSizeTooBigErr

+ const JSMirrorWithSourcesErr

+ const JSMirrorWithStartSeqAndTimeErr

+ const JSMirrorWithSubjectFiltersErr

+ const JSMirrorWithSubjectsErr

+ const JSNoAccountErr

+ const JSNoMessageFoundErr

+ const JSNotEmptyRequestErr

+ const JSNotEnabledErr

+ const JSNotEnabledForAccountErr

+ const JSPeerRemapErr

+ const JSRaftGeneralErrF

+ const JSRestoreSubscribeFailedErrF

+ const JSSequenceNotFoundErrF

+ const JSSnapshotDeliverSubjectInvalidErr

+ const JSSourceConsumerSetupFailedErrF

+ const JSSourceMaxMessageSizeTooBigErr

+ const JSStorageResourcesExceededErr

+ const JSStreamAssignmentErrF

+ const JSStreamCreateErrF

+ const JSStreamDeleteErrF

+ const JSStreamExternalApiOverlapErrF

+ const JSStreamExternalDelPrefixOverlapsErrF

+ const JSStreamGeneralErrorF

+ const JSStreamInvalidConfigF

+ const JSStreamInvalidExternalDeliverySubjErrF

+ const JSStreamLimitsErrF

+ const JSStreamMessageExceedsMaximumErr

+ const JSStreamMirrorNotUpdatableErr

+ const JSStreamMismatchErr

+ const JSStreamMsgDeleteFailedF

+ const JSStreamNameExistErr

+ const JSStreamNotFoundErr

+ const JSStreamNotMatchErr

+ const JSStreamReplicasNotSupportedErr

+ const JSStreamReplicasNotUpdatableErr

+ const JSStreamRestoreErrF

+ const JSStreamSequenceNotMatchErr

+ const JSStreamSnapshotErrF

+ const JSStreamSubjectOverlapErr

+ const JSStreamTemplateCreateErrF

+ const JSStreamTemplateDeleteErrF

+ const JSStreamTemplateNotFoundErr

+ const JSStreamUpdateErrF

+ const JSStreamWrongLastMsgIDErrF

+ const JSStreamWrongLastSequenceErrF

+ const JSTempStorageFailedErr

+ const JSTemplateNameNotMatchSubjectErr

+ type ErrorsData struct

+ Code int

+ Comment string

+ Constant string

+ Deprecates string

+ Description string

+ ErrCode uint16

+ Help string

+ URL string

+ type JSApiStreamPurgeRequest struct

+ Keep uint64

+ Sequence uint64

+ Subject string

type JSPubAckResponse

+ func (r *JSPubAckResponse) ToError() error

type JetStreamVarz

+ Meta *ClusterInfo

+ type OCSPConfig struct

+ Mode OCSPMode

+ OverrideURLs []string

+ type OCSPMode uint8

+ const OCSPModeAlways

+ const OCSPModeAuto

+ const OCSPModeMust

+ const OCSPModeNever

+ type OCSPMonitor struct

+ Issuer *x509.Certificate

+ Leaf *x509.Certificate

type Options

+ JetStreamKey string

+ OCSPConfig *OCSPConfig

type Server

+ func (srv *Server) NewOCSPMonitor(config *tlsConfigKind) (*tls.Config, *OCSPMonitor, error)

type ServerStats

+ ActiveServers int

+ JetStream *JetStreamVarz

+ type SimpleState struct

+ First uint64

+ Last uint64

+ Msgs uint64

type StreamConfig

+ MaxMsgsPer int64

type StreamStore

+ FilteredState func(sseq uint64, subject string) SimpleState

+ PurgeEx func(subject string, seq, keep uint64) (uint64, error)

v2.2.6

May 24, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ var ErrCertNotPinned = errors.New("certificate not pinned")

v2.2.5

May 20, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ClusterOpts

+ TLSPinnedCerts PinnedCertSet

type GatewayOpts

+ TLSPinnedCerts PinnedCertSet

type LeafNodeOpts

+ TLSPinnedCerts PinnedCertSet

type MQTTOpts

+ TLSPinnedCerts PinnedCertSet

type Options

+ TLSPinnedCerts PinnedCertSet

+ type PinnedCertSet map[string]struct

type TLSConfigOpts

+ PinnedCerts PinnedCertSet

type WebsocketOpts

+ TLSPinnedCerts PinnedCertSet

v2.2.4

May 12, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ var ErrReplicasNotSupported = errors.New("replicas > 1 not supported in non-clustered mode")

+ type ClientOpts struct

+ Account string

+ AccountNew bool

+ Echo bool

+ Export *SubjectPermission

+ Headers bool

+ Import *SubjectPermission

+ JWT string

+ Lang string

+ Name string

+ Nkey string

+ NoResponders bool

+ Password string

+ Pedantic bool

+ Protocol int

+ Sig string

+ TLSRequired bool

+ Token string

+ Username string

+ Verbose bool

+ Version string

type StreamSourceInfo

+ External *ExternalStream

v2.2.3

May 7, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ var ErrMemoryResourcesExceeded = errors.New("insufficient memory resources available")

+ var ErrStorageResourcesExceeded = errors.New("insufficient storage resources available")

+ type DenyRules struct

+ Exports []string

+ Imports []string

type EventFilterOptions

+ Domain string

type Info

+ RemoteAccount string

type JSAPIAudit

+ Domain string

type JSConsumerAckMetric

+ Domain string

type JSConsumerActionAdvisory

+ Domain string

type JSConsumerDeliveryExceededAdvisory

+ Domain string

type JSConsumerDeliveryTerminatedAdvisory

+ Domain string

type JSConsumerLeaderElectedAdvisory

+ Domain string

type JSConsumerQuorumLostAdvisory

+ Domain string

type JSRestoreCompleteAdvisory

+ Domain string

type JSRestoreCreateAdvisory

+ Domain string

type JSServerOutOfSpaceAdvisory

+ Domain string

type JSServerRemovedAdvisory

+ Domain string

type JSSnapshotCompleteAdvisory

+ Domain string

type JSSnapshotCreateAdvisory

+ Domain string

type JSStreamActionAdvisory

+ Domain string

type JSStreamLeaderElectedAdvisory

+ Domain string

type JSStreamQuorumLostAdvisory

+ Domain string

type JetStreamAccountStats

+ Domain string

type JetStreamConfig

+ Domain string

type Options

+ JetStreamDomain string

type RemoteLeafOpts

+ NoRandomize bool

type RemoteLeafOptsVarz

+ Deny *DenyRules

v2.2.2

Apr 22, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

type ClientAuthentication

+ Kind func() int

type Info

+ ConnectInfo bool

+ InfoOnConnect bool

+ type JSApiStreamInfoRequest struct

+ DeletedDetails bool

type RaftConfig

+ Observer bool

type RaftNode

+ AdjustClusterSize func(csz int) error

type StreamState

+ NumDeleted int

type StreamStore

+ NumFilteredPending func(sseq uint64, subject string) uint64

v2.2.1

Apr 2, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const DEFAULT_ACCOUNT_FETCH_TIMEOUT

+ const JSLastConsumerSeq

+ const JSLastStreamSeq

+ const JsDefaultMaxAckPending

+ var ErrJetStreamResourcesExceeded = errors.New("jetstream resources exceeded for server")

+ type DirResOption func(s *DirAccResolver) error

+ func FetchTimeout(to time.Duration) DirResOption

type RaftConfig

+ Track bool

type RaftNode

+ HadPreviousLeader func() bool

+ ProposeDirect func(entries []*Entry) error

type StreamStore

+ Type func() StorageType

type WAL

+ Type func() StorageType

v2.2.0

Mar 15, 2021 GO-2023-2133

GO-2023-2133: Authorization bypass in github.com/nats-io/nats-server/v2

Changes in this version

+ const ACCOUNT

+ const AccountNumConnsMsgType

+ const AccountzPath

+ const AnyStorage

+ const ClientInfoHdr

+ const ClusterNameConflict

+ const ConnectEventMsgType

+ const DEFAULT_GLOBAL_ACCOUNT

+ const DEFAULT_LAME_DUCK_GRACE_PERIOD

+ const DEFAULT_SERVICE_EXPORT_RESPONSE_THRESHOLD

+ const DEFAULT_SYSTEM_ACCOUNT

+ const DiscardNew

+ const DiscardOld

+ const DisconnectEventMsgType

+ const DuplicateClientID

+ const DuplicateRemoteLeafnodeConnection

+ const FileStorage

+ const FileStoreMaxBlkSize

+ const FileStoreMinBlkSize

+ const HMSG_ARG

+ const HPUB_ARG

+ const HardDelete

+ const InternalClient

+ const JETSTREAM

+ const JSAPIAuditType

+ const JSAdvisoryConsumerCreatedPre

+ const JSAdvisoryConsumerDeletedPre

+ const JSAdvisoryConsumerLeaderElectedPre

+ const JSAdvisoryConsumerMaxDeliveryExceedPre

+ const JSAdvisoryConsumerMsgTerminatedPre

+ const JSAdvisoryConsumerQuorumLostPre

+ const JSAdvisoryPrefix

+ const JSAdvisoryServerOutOfStorage

+ const JSAdvisoryServerRemoved

+ const JSAdvisoryStreamCreatedPre

+ const JSAdvisoryStreamDeletedPre

+ const JSAdvisoryStreamLeaderElectedPre

+ const JSAdvisoryStreamQuorumLostPre

+ const JSAdvisoryStreamRestoreCompletePre

+ const JSAdvisoryStreamRestoreCreatePre

+ const JSAdvisoryStreamSnapshotCompletePre

+ const JSAdvisoryStreamSnapshotCreatePre

+ const JSAdvisoryStreamUpdatedPre

+ const JSApiAccountInfo

+ const JSApiAccountInfoResponseType

+ const JSApiConsumerCreate

+ const JSApiConsumerCreateResponseType

+ const JSApiConsumerCreateT

+ const JSApiConsumerDelete

+ const JSApiConsumerDeleteResponseType

+ const JSApiConsumerDeleteT

+ const JSApiConsumerInfo

+ const JSApiConsumerInfoResponseType

+ const JSApiConsumerInfoT

+ const JSApiConsumerLeaderStepDown

+ const JSApiConsumerLeaderStepDownResponseType

+ const JSApiConsumerLeaderStepDownT

+ const JSApiConsumerList

+ const JSApiConsumerListResponseType

+ const JSApiConsumerListT

+ const JSApiConsumerNamesResponseType

+ const JSApiConsumers

+ const JSApiConsumersT

+ const JSApiDurableCreate

+ const JSApiDurableCreateT

+ const JSApiLeaderStepDown

+ const JSApiLeaderStepDownResponseType

+ const JSApiListLimit

+ const JSApiMetaServerRemoveResponseType

+ const JSApiMsgDelete

+ const JSApiMsgDeleteResponseType

+ const JSApiMsgDeleteT

+ const JSApiMsgGet

+ const JSApiMsgGetResponseType

+ const JSApiMsgGetT

+ const JSApiNamesLimit

+ const JSApiOverloadedType

+ const JSApiPrefix

+ const JSApiPubAckResponseType

+ const JSApiRemoveServer

+ const JSApiRequestNextT

+ const JSApiStreamCreate

+ const JSApiStreamCreateResponseType

+ const JSApiStreamCreateT

+ const JSApiStreamDelete

+ const JSApiStreamDeleteResponseType

+ const JSApiStreamDeleteT

+ const JSApiStreamInfo

+ const JSApiStreamInfoResponseType

+ const JSApiStreamInfoT

+ const JSApiStreamLeaderStepDown

+ const JSApiStreamLeaderStepDownResponseType

+ const JSApiStreamLeaderStepDownT

+ const JSApiStreamList

+ const JSApiStreamListResponseType

+ const JSApiStreamNamesResponseType

+ const JSApiStreamPurge

+ const JSApiStreamPurgeResponseType

+ const JSApiStreamPurgeT

+ const JSApiStreamRemovePeer

+ const JSApiStreamRemovePeerResponseType

+ const JSApiStreamRemovePeerT

+ const JSApiStreamRestore

+ const JSApiStreamRestoreRequestType

+ const JSApiStreamRestoreResponseType

+ const JSApiStreamRestoreT

+ const JSApiStreamSnapshot

+ const JSApiStreamSnapshotResponseType

+ const JSApiStreamSnapshotT

+ const JSApiStreamTemplateCreateResponseType

+ const JSApiStreamTemplateDeleteResponseType

+ const JSApiStreamTemplateInfoResponseType

+ const JSApiStreamTemplateNamesResponseType

+ const JSApiStreamUpdate

+ const JSApiStreamUpdateResponseType

+ const JSApiStreamUpdateT

+ const JSApiStreams

+ const JSApiTemplateCreate

+ const JSApiTemplateCreateT

+ const JSApiTemplateDelete

+ const JSApiTemplateDeleteT

+ const JSApiTemplateInfo

+ const JSApiTemplateInfoT

+ const JSApiTemplates

+ const JSAuditAdvisory

+ const JSConsumerAckMetricType

+ const JSConsumerActionAdvisoryType

+ const JSConsumerDeliveryExceededAdvisoryType

+ const JSConsumerDeliveryTerminatedAdvisoryType

+ const JSConsumerLeaderElectedAdvisoryType

+ const JSConsumerQuorumLostAdvisoryType

+ const JSExpectedLastMsgId

+ const JSExpectedLastSeq

+ const JSExpectedStream

+ const JSMaxNameLen

+ const JSMetricConsumerAckPre

+ const JSMetricPrefix

+ const JSMsgId

+ const JSRestoreCompleteAdvisoryType

+ const JSRestoreCreateAdvisoryType

+ const JSServerOutOfStorageAdvisoryType

+ const JSServerRemovedAdvisoryType

+ const JSSnapshotCompleteAdvisoryType

+ const JSSnapshotCreatedAdvisoryType

+ const JSStreamActionAdvisoryType

+ const JSStreamLeaderElectedAdvisoryType

+ const JSStreamQuorumLostAdvisoryType

+ const JSStreamSource

+ const JSWaitQueueDefaultMax

+ const JetStreamMaxMemDefault

+ const JetStreamMaxStoreDefault

+ const JetStreamMetaFile

+ const JetStreamMetaFileSum

+ const JetStreamStoreDir

+ const JsAckWaitDefault

+ const JsDeleteWaitTimeDefault

+ const JsFlowControlMaxPending

+ const JszPath

+ const MAX_CONTROL_LINE_SNIPPET_SIZE

+ const MAX_HMSG_ARGS

+ const MAX_HPUB_ARGS

+ const MAX_RMSG_ARGS

+ const MQTT

+ const MaxAccountCycleSearchDepth

+ const MemoryStorage

+ const MsgHeaderViolation

+ const NATS

+ const NON_CLIENT

+ const NoDelete

+ const NoRespondersRequiresHeaders

+ const OK

+ const OP_H

+ const OP_HM

+ const OP_HMS

+ const OP_HMSG

+ const OP_HMSG_SPC

+ const OP_HP

+ const OP_HPU

+ const OP_HPUB

+ const OP_HPUB_SPC

+ const RenameDeleted

+ const ServiceLatencyType

+ const StreamDefaultDuplicatesWindow

+ const StreamDefaultReplicas

+ const StreamMaxReplicas

+ const WS

+ var AckAck = []byte("+ACK")

+ var AckNak = []byte("-NAK")

+ var AckNext = []byte("+NXT")

+ var AckOK = []byte(OK)

+ var AckProgress = []byte("+WPI")

+ var AckTerm = []byte("+TERM")

+ var ErrAlreadyRegistered = errors.New("sublist: notification already registered")

+ var ErrBadMsgHeader = errors.New("bad message header detected")

+ var ErrBadQualifier = errors.New("bad qualifier")

+ var ErrBadSubject = errors.New("invalid subject")

+ var ErrClusterNameConfigConflict = errors.New("cluster name conflicts between cluster and gateway definitions")

+ var ErrClusterNameRemoteConflict = errors.New("cluster name from remote server conflicts")

+ var ErrCycleSearchDepth = errors.New("search cycle depth exhausted")

+ var ErrImportFormsCycle = errors.New("import forms a cycle")

+ var ErrInvalidSequence = errors.New("invalid sequence")

+ var ErrJetStreamConsumerAlreadyUsed = errors.New("consumer name already in use")

+ var ErrJetStreamNotAssigned = errors.New("jetstream cluster not assigned to this server")

+ var ErrJetStreamNotClustered = errors.New("jetstream not in clustered mode")

+ var ErrJetStreamNotEnabled = errors.New("jetstream not enabled")

+ var ErrJetStreamNotEnabledForAccount = errors.New("jetstream not enabled for account")

+ var ErrJetStreamNotLeader = errors.New("jetstream cluster can not handle request")

+ var ErrJetStreamStreamAlreadyUsed = errors.New("stream name already in use")

+ var ErrJetStreamStreamNotFound = errors.New("stream not found")

+ var ErrMalformedSubject = errors.New("malformed subject")

+ var ErrMaxBytes = errors.New("maximum bytes exceeded")

+ var ErrMaxMsgs = errors.New("maximum messages exceeded")

+ var ErrMsgHeadersNotSupported = errors.New("message headers not supported")

+ var ErrMsgTooLarge = errors.New("message to large")

+ var ErrNilChan = errors.New("sublist: nil channel")

+ var ErrNoAckPolicy = errors.New("ack policy is none")

+ var ErrNoRespondersRequiresHeaders = errors.New("no responders requires headers support")

+ var ErrNoTransforms = errors.New("no matching transforms available")

+ var ErrSequenceMismatch = errors.New("expected sequence does not match store")

+ var ErrStoreClosed = errors.New("store is closed")

+ var ErrStoreEOF = errors.New("stream store EOF")

+ var ErrStoreMsgNotFound = errors.New("no message found")

+ var ErrStoreSnapshotInProgress = errors.New("snapshot in progress")

+ var ErrStoreWrongType = errors.New("wrong storage type")

+ var ErrSubscribePermissionViolation = errors.New("subscribe permission viloation")

+ func SubjectsCollide(subj1, subj2 string) bool

+ type AccInfoEventOptions struct

type Account

+ func (a *Account) AddMappedStreamImport(account *Account, from, to string) error

+ func (a *Account) AddMappedStreamImportWithClaim(account *Account, from, to string, imClaim *jwt.Import) error

+ func (a *Account) AddMapping(src, dest string) error

+ func (a *Account) AddWeightedMappings(src string, dests ...*MapDest) error

+ func (a *Account) DisableJetStream() error

+ func (a *Account) EnableJetStream(limits *JetStreamAccountLimits) error

+ func (a *Account) GetName() string

+ func (a *Account) Interest(subject string) int

+ func (a *Account) JetStreamEnabled() bool

+ func (a *Account) JetStreamIsConsumerLeader(stream, consumer string) bool

+ func (a *Account) JetStreamIsStreamLeader(stream string) bool

+ func (a *Account) JetStreamUsage() JetStreamAccountStats

+ func (a *Account) NumPendingAllResponses() int

+ func (a *Account) NumPendingResponses(filter string) int

+ func (a *Account) NumPendingReverseResponses() int

+ func (a *Account) RemoveMapping(src string) bool

+ func (a *Account) RestoreStream(ncfg *StreamConfig, r io.Reader) (*stream, error)

+ func (a *Account) ServiceExportResponseThreshold(export string) (time.Duration, error)

+ func (a *Account) SetServiceExportResponseThreshold(export string, maxTime time.Duration) error

+ func (a *Account) SetServiceImportSharing(destination *Account, to string, allow bool) error

+ func (a *Account) String() string

+ func (a *Account) UpdateJetStreamLimits(limits *JetStreamAccountLimits) error

+ type AccountDetail struct

+ Id string

+ Name string

+ Streams []StreamDetail

+ type AccountInfo struct

+ AccountName string

+ Claim *jwt.AccountClaims

+ ClientCnt int

+ Complete bool

+ Expired bool

+ Exports []ExtExport

+ Imports []ExtImport

+ IsSystem bool

+ IssuerKey string

+ JetStream bool

+ Jwt string

+ LastUpdate time.Time

+ LeafCnt int

+ Mappings ExtMap

+ NameTag string

+ Responses map[string]ExtImport

+ RevokedAct map[string]time.Time

+ RevokedUser map[string]time.Time

+ SubCnt uint32

+ Sublist *SublistStats

+ Tags jwt.TagList

+ Vr []ExtVrIssues

type AccountResolver

+ Close func()

+ IsReadOnly func() bool

+ IsTrackingUpdate func() bool

+ Reload func() error

+ Start func(server *Server) error

+ type Accountz struct

+ Account *AccountInfo

+ Accounts []string

+ ID string

+ Now time.Time

+ SystemAccount string

+ type AccountzEventOptions struct

+ type AccountzOptions struct

+ Account string

+ type AckPolicy int

+ const AckAll

+ const AckExplicit

+ const AckNone

+ func (a AckPolicy) String() string

+ func (ap *AckPolicy) UnmarshalJSON(data []byte) error

+ func (ap AckPolicy) MarshalJSON() ([]byte, error)

+ type ActionAdvisoryType string

+ const CreateEvent

+ const DeleteEvent

+ const ModifyEvent

+ type ApiError struct

+ Code int

+ Description string

+ type ApiPaged struct

+ Limit int

+ Offset int

+ Total int

+ type ApiPagedRequest struct

+ Offset int

+ type ApiResponse struct

+ Error *ApiError

+ Type string

+ type CacheDirAccResolver struct

+ func NewCacheDirAccResolver(path string, limit int64, ttl time.Duration, _ ...dirJWTStoreOption) (*CacheDirAccResolver, error)

+ func (dr *CacheDirAccResolver) Reload() error

+ func (dr *CacheDirAccResolver) Start(s *Server) error

type ClientInfo

+ Cluster string

+ IssuerKey string

+ Jwt string

+ NameTag string

+ Server string

+ Service string

+ Tags jwt.TagList

+ type ClusterInfo struct

+ Leader string

+ Name string

+ Replicas []*PeerInfo

type ClusterOpts

+ Name string

+ TLSCheckKnownURLs bool

type ClusterOptsVarz

+ Name string

+ TLSRequired bool

+ TLSTimeout float64

+ TLSVerify bool

+ type CommittedEntry struct

+ Entries []*Entry

+ Index uint64

type ConnInfo

+ IssuerKey string

+ JWT string

+ NameTag string

+ Tags jwt.TagList

+ type ConnzEventOptions struct

+ type ConsumerConfig struct

+ AckPolicy AckPolicy

+ AckWait time.Duration

+ DeliverPolicy DeliverPolicy

+ DeliverSubject string

+ Direct bool

+ Durable string

+ FilterSubject string

+ FlowControl bool

+ Heartbeat time.Duration

+ MaxAckPending int

+ MaxDeliver int

+ MaxWaiting int

+ OptStartSeq uint64

+ OptStartTime *time.Time

+ RateLimit uint64

+ ReplayPolicy ReplayPolicy

+ SampleFrequency string

+ type ConsumerInfo struct

+ AckFloor SequencePair

+ Cluster *ClusterInfo

+ Config *ConsumerConfig

+ Created time.Time

+ Delivered SequencePair

+ Name string

+ NumAckPending int

+ NumPending uint64

+ NumRedelivered int

+ NumWaiting int

+ Stream string

+ type ConsumerState struct

+ AckFloor SequencePair

+ Delivered SequencePair

+ Pending map[uint64]*Pending

+ Redelivered map[uint64]uint64

+ type ConsumerStore interface

+ Delete func() error

+ State func() (*ConsumerState, error)

+ Stop func() error

+ Update func(*ConsumerState) error

+ UpdateAcks func(dseq, sseq uint64) error

+ UpdateDelivered func(dseq, sseq, dc uint64, ts int64) error

+ type CreateConsumerRequest struct

+ Config ConsumerConfig

+ Stream string

+ type DeliverPolicy int

+ const DeliverAll

+ const DeliverByStartSequence

+ const DeliverByStartTime

+ const DeliverLast

+ const DeliverNew

+ func (dp DeliverPolicy) String() string

+ func (p *DeliverPolicy) UnmarshalJSON(data []byte) error

+ func (p DeliverPolicy) MarshalJSON() ([]byte, error)

+ type DirAccResolver struct

+ func NewDirAccResolver(path string, limit int64, syncInterval time.Duration, delete bool) (*DirAccResolver, error)

+ func (dr *DirAccResolver) Fetch(name string) (string, error)

+ func (dr *DirAccResolver) IsTrackingUpdate() bool

+ func (dr *DirAccResolver) Reload() error

+ func (dr *DirAccResolver) Start(s *Server) error

+ func (dr *DirAccResolver) Store(name, jwt string) error

+ type DirJWTStore struct

+ func NewDirJWTStore(dirPath string, shard bool, create bool, _ ...dirJWTStoreOption) (*DirJWTStore, error)

+ func NewExpiringDirJWTStore(dirPath string, shard bool, create bool, delete deleteType, ...) (*DirJWTStore, error)

+ func NewImmutableDirJWTStore(dirPath string, shard bool, _ ...dirJWTStoreOption) (*DirJWTStore, error)

+ func (store *DirJWTStore) Close()

+ func (store *DirJWTStore) Hash() [sha256.Size]byte

+ func (store *DirJWTStore) IsReadOnly() bool

+ func (store *DirJWTStore) LoadAcc(publicKey string) (string, error)

+ func (store *DirJWTStore) LoadAct(hash string) (string, error)

+ func (store *DirJWTStore) Merge(pack string) error

+ func (store *DirJWTStore) Pack(maxJWTs int) (string, error)

+ func (store *DirJWTStore) PackWalk(maxJWTs int, cb func(partialPackMsg string)) error

+ func (store *DirJWTStore) Reload() error

+ func (store *DirJWTStore) SaveAcc(publicKey string, theJWT string) error

+ func (store *DirJWTStore) SaveAct(hash string, theJWT string) error

+ type DiscardPolicy int

+ func (dp *DiscardPolicy) UnmarshalJSON(data []byte) error

+ func (dp DiscardPolicy) MarshalJSON() ([]byte, error)

+ func (dp DiscardPolicy) String() string

+ type Entry struct

+ Data []byte

+ Type EntryType

+ type EntryType uint8

+ const EntryAddPeer

+ const EntryLeaderTransfer

+ const EntryNormal

+ const EntryOldSnapshot

+ const EntryPeerState

+ const EntryRemovePeer

+ const EntrySnapshot

+ func (t EntryType) String() string

+ type EventFilterOptions struct

+ Cluster string

+ Host string

+ Name string

+ Tags []string

+ type ExtExport struct

+ ApprovedAccounts []string

+ type ExtImport struct

+ Invalid bool

+ Latency *jwt.ServiceLatency

+ M1 *ServiceLatency

+ Share bool

+ Tracking bool

+ TrackingHdr http.Header

+ type ExtMap map[string][]*MapDest

+ type ExtVrIssues struct

+ Blocking bool

+ Description string

+ Time bool

+ type ExternalStream struct

+ ApiPrefix string

+ DeliverPrefix string

+ type FileConsumerInfo struct

+ Created time.Time

+ Name string

+ type FileStoreConfig struct

+ AsyncFlush bool

+ BlockSize uint64

+ CacheExpire time.Duration

+ StoreDir string

+ SyncInterval time.Duration

+ type FileStreamInfo struct

+ Created time.Time

type GatewayOpts

+ TLSCheckKnownURLs bool

type GatewayOptsVarz

+ TLSRequired bool

+ TLSVerify bool

+ type GatewayzEventOptions struct

type Info

+ Dynamic bool

+ Headers bool

+ JetStream bool

+ LNOC bool

+ LameDuckMode bool

+ TLSAvailable bool

+ WSConnectURLs []string

+ type JSAPIAudit struct

+ Client *ClientInfo

+ Request string

+ Response string

+ Server string

+ Subject string

+ type JSApiAccountInfoResponse struct

+ type JSApiConsumerCreateResponse struct

+ type JSApiConsumerDeleteResponse struct

+ Success bool

+ type JSApiConsumerGetNextRequest struct

+ Batch int

+ Expires time.Duration

+ NoWait bool

+ type JSApiConsumerInfoResponse struct

+ type JSApiConsumerLeaderStepDownResponse struct

+ Success bool

+ type JSApiConsumerListResponse struct

+ Consumers []*ConsumerInfo

+ type JSApiConsumerNamesResponse struct

+ Consumers []string

+ type JSApiConsumersRequest struct

+ type JSApiLeaderStepDownResponse struct

+ Success bool

+ type JSApiLeaderStepdownRequest struct

+ Placement *Placement

+ type JSApiMetaServerRemoveRequest struct

+ Server string

+ type JSApiMetaServerRemoveResponse struct

+ Success bool

+ type JSApiMsgDeleteRequest struct

+ NoErase bool

+ Seq uint64

+ type JSApiMsgDeleteResponse struct

+ Success bool

+ type JSApiMsgGetRequest struct

+ Seq uint64

+ type JSApiMsgGetResponse struct

+ Message *StoredMsg

+ type JSApiStreamCreateResponse struct

+ type JSApiStreamDeleteResponse struct

+ Success bool

+ type JSApiStreamInfoResponse struct

+ type JSApiStreamLeaderStepDownResponse struct

+ Success bool

+ type JSApiStreamListResponse struct

+ Streams []*StreamInfo

+ type JSApiStreamNamesRequest struct

+ Subject string

+ type JSApiStreamNamesResponse struct

+ Streams []string

+ type JSApiStreamPurgeResponse struct

+ Purged uint64

+ Success bool

+ type JSApiStreamRemovePeerRequest struct

+ Peer string

+ type JSApiStreamRemovePeerResponse struct

+ Success bool

+ type JSApiStreamRestoreRequest struct

+ Config StreamConfig

+ State StreamState

+ type JSApiStreamRestoreResponse struct

+ DeliverSubject string

+ type JSApiStreamSnapshotRequest struct

+ CheckMsgs bool

+ ChunkSize int

+ DeliverSubject string

+ NoConsumers bool

+ type JSApiStreamSnapshotResponse struct

+ Config *StreamConfig

+ State *StreamState

+ type JSApiStreamTemplateCreateResponse struct

+ type JSApiStreamTemplateDeleteResponse struct

+ Success bool

+ type JSApiStreamTemplateInfoResponse struct

+ type JSApiStreamTemplateNamesResponse struct

+ Templates []string

+ type JSApiStreamTemplatesRequest struct

+ type JSApiStreamUpdateResponse struct

+ type JSConsumerAckMetric struct

+ Consumer string

+ ConsumerSeq uint64

+ Delay int64

+ Deliveries uint64

+ Stream string

+ StreamSeq uint64

+ type JSConsumerActionAdvisory struct

+ Action ActionAdvisoryType

+ Consumer string

+ Stream string

+ type JSConsumerDeliveryExceededAdvisory struct

+ Consumer string

+ Deliveries uint64

+ Stream string

+ StreamSeq uint64

+ type JSConsumerDeliveryTerminatedAdvisory struct

+ Consumer string

+ ConsumerSeq uint64

+ Deliveries uint64

+ Stream string

+ StreamSeq uint64

+ type JSConsumerLeaderElectedAdvisory struct

+ Account string

+ Consumer string

+ Leader string

+ Replicas []*PeerInfo

+ Stream string

+ type JSConsumerQuorumLostAdvisory struct

+ Account string

+ Consumer string

+ Replicas []*PeerInfo

+ Stream string

+ type JSInfo struct

+ APICalls int64

+ AccountDetails []*AccountDetail

+ Bytes uint64

+ Config JetStreamConfig

+ Consumers int

+ Disabled bool

+ ID string

+ Messages uint64

+ Meta *ClusterInfo

+ Now time.Time

+ Streams int

+ type JSPubAckResponse struct

+ Error *ApiError

+ type JSRestoreCompleteAdvisory struct

+ Bytes int64

+ Client *ClientInfo

+ End time.Time

+ Start time.Time

+ Stream string

+ type JSRestoreCreateAdvisory struct

+ Client *ClientInfo

+ Stream string

+ type JSServerOutOfSpaceAdvisory struct

+ Cluster string

+ Server string

+ ServerID string

+ Stream string

+ type JSServerRemovedAdvisory struct

+ Cluster string

+ Server string

+ ServerID string

+ type JSSnapshotCompleteAdvisory struct

+ Client *ClientInfo

+ End time.Time

+ Start time.Time

+ Stream string

+ type JSSnapshotCreateAdvisory struct

+ Client *ClientInfo

+ State StreamState

+ Stream string

+ type JSStreamActionAdvisory struct

+ Action ActionAdvisoryType

+ Stream string

+ Template string

+ type JSStreamLeaderElectedAdvisory struct

+ Account string

+ Leader string

+ Replicas []*PeerInfo

+ Stream string

+ type JSStreamQuorumLostAdvisory struct

+ Account string

+ Replicas []*PeerInfo

+ Stream string

+ type JSzOptions struct

+ Account string

+ Accounts bool

+ Config bool

+ Consumer bool

+ LeaderOnly bool

+ Limit int

+ Offset int

+ Streams bool

+ type JWTChanged func(publicKey string)

+ type JetStreamAPIStats struct

+ Errors uint64

+ Total uint64

+ type JetStreamAccountLimits struct

+ MaxConsumers int

+ MaxMemory int64

+ MaxStore int64

+ MaxStreams int

+ type JetStreamAccountStats struct

+ API JetStreamAPIStats

+ Consumers int

+ Limits JetStreamAccountLimits

+ Memory uint64

+ Store uint64

+ Streams int

+ type JetStreamConfig struct

+ MaxMemory int64

+ MaxStore int64

+ StoreDir string

+ type JetStreamStats struct

+ API JetStreamAPIStats

+ Accounts int

+ Memory uint64

+ Store uint64

+ type JetStreamVarz struct

+ Config JetStreamConfig

+ Stats *JetStreamStats

+ type JszEventOptions struct

+ type LeadChange struct

+ Leader bool

+ Previous string

type LeafNodeOptsVarz

+ TLSRequired bool

+ TLSVerify bool

+ type LeafzEventOptions struct

type LeafzOptions

+ Account string

+ type LostStreamData struct

+ Bytes uint64

+ Msgs []uint64

+ type MQTTOpts struct

+ AckWait time.Duration

+ AuthTimeout float64

+ Host string

+ MaxAckPending uint16

+ NoAuthUser string

+ Password string

+ Port int

+ TLSConfig *tls.Config

+ TLSMap bool

+ TLSTimeout float64

+ Token string

+ Username string

+ type MapDest struct

+ Cluster string

+ Subject string

+ Weight uint8

+ func NewMapDest(subject string, weight uint8) *MapDest

type MemAccResolver

+ func (*MemAccResolver) Close()

+ func (*MemAccResolver) IsTrackingUpdate() bool

+ func (*MemAccResolver) Reload() error

+ func (*MemAccResolver) Start(*Server) error

+ func (m *MemAccResolver) IsReadOnly() bool

type NkeyUser

+ AllowedConnectionTypes map[string]struct{}

type Options

+ AllowNonTLS bool

+ JetStream bool

+ JetStreamMaxMemory int64

+ JetStreamMaxStore int64

+ LameDuckGracePeriod time.Duration

+ MQTT MQTTOpts

+ NoHeaderSupport bool

+ NoSystemAccount bool

+ StoreDir string

+ Tags jwt.TagList

+ Websocket WebsocketOpts

+ type Peer struct

+ Current bool

+ ID string

+ Lag uint64

+ Last time.Time

+ type PeerInfo struct

+ Active time.Duration

+ Current bool

+ Lag uint64

+ Name string

+ Offline bool

+ type Pending struct

+ Sequence uint64

+ Timestamp int64

+ type Placement struct

+ Cluster string

+ Tags []string

type Ports

+ WebSocket []string

+ type PubAck struct

+ Duplicate bool

+ Sequence uint64

+ Stream string

+ type RaftConfig struct

+ Log WAL

+ Name string

+ Store string

+ type RaftNode interface

+ Applied func(index uint64) (entries uint64, bytes uint64)

+ ApplyC func() <-chan *CommittedEntry

+ Campaign func() error

+ Compact func(index uint64) error

+ Created func() time.Time

+ Current func() bool

+ Delete func()

+ ForwardProposal func(entry []byte) error

+ Group func() string

+ GroupLeader func() string

+ ID func() string

+ InstallSnapshot func(snap []byte) error

+ LeadChangeC func() <-chan bool

+ Leader func() bool

+ NeedSnapshot func() bool

+ PauseApply func()

+ Peers func() []*Peer

+ Progress func() (index, commit, applied uint64)

+ Propose func(entry []byte) error

+ ProposeAddPeer func(peer string) error

+ ProposeRemovePeer func(peer string) error

+ QuitC func() <-chan struct{}

+ Quorum func() bool

+ ResumeApply func()

+ SendSnapshot func(snap []byte) error

+ Size func() (entries, bytes uint64)

+ State func() RaftState

+ StepDown func(preferred ...string) error

+ Stop func()

+ type RaftState uint8

+ const Candidate

+ const Closed

+ const Follower

+ const Leader

+ const Observer

+ func (state RaftState) String() string

type RemoteLeafOpts

+ Websocket struct{ ... }

+ type ReplayPolicy int

+ const ReplayInstant

+ const ReplayOriginal

+ func (r ReplayPolicy) String() string

+ func (rp *ReplayPolicy) UnmarshalJSON(data []byte) error

+ func (rp ReplayPolicy) MarshalJSON() ([]byte, error)

+ type RetentionPolicy int

+ const InterestPolicy

+ const LimitsPolicy

+ const WorkQueuePolicy

+ func (rp *RetentionPolicy) UnmarshalJSON(data []byte) error

+ func (rp RetentionPolicy) MarshalJSON() ([]byte, error)

+ func (rp RetentionPolicy) String() string

+ type RoutezEventOptions struct

+ type SequencePair struct

+ Consumer uint64

+ Stream uint64

type Server

+ func (s *Server) Accountz(optz *AccountzOptions) (*Accountz, error)

+ func (s *Server) ActivePeers() (peers []string)

+ func (s *Server) ClusterName() string

+ func (s *Server) DisableJetStream() error

+ func (s *Server) EnableJetStream(config *JetStreamConfig) error

+ func (s *Server) GlobalAccount() *Account

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

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

+ func (s *Server) JetStreamClusterPeers() []string

+ func (s *Server) JetStreamConfig() *JetStreamConfig

+ func (s *Server) JetStreamEnabled() bool

+ func (s *Server) JetStreamIsClustered() bool

+ func (s *Server) JetStreamIsConsumerLeader(account, stream, consumer string) bool

+ func (s *Server) JetStreamIsCurrent() bool

+ func (s *Server) JetStreamIsLeader() bool

+ func (s *Server) JetStreamIsStreamAssigned(account, stream string) bool

+ func (s *Server) JetStreamIsStreamCurrent(account, stream string) bool

+ func (s *Server) JetStreamIsStreamLeader(account, stream string) bool

+ func (s *Server) JetStreamNumAccounts() int

+ func (s *Server) JetStreamReservedResources() (int64, int64, error)

+ func (s *Server) JetStreamSnapshotMeta() error

+ func (s *Server) JetStreamSnapshotStream(account, stream string) error

+ func (s *Server) JetStreamStepdownStream(account, stream string) error

+ func (s *Server) Jsz(opts *JSzOptions) (*JSInfo, error)

+ func (s *Server) JszAccount(opts *JSzOptions) (*AccountDetail, error)

+ func (s *Server) Logger() Logger

+ func (s *Server) Name() string

+ func (s *Server) Node() string

+ func (s *Server) NodeName() string

+ func (s *Server) Running() bool

+ func (s *Server) SetDefaultSystemAccount() error

+ func (s *Server) StoreDir() string

+ func (s *Server) String() string

type ServerInfo

+ JetStream bool

type ServiceLatency

+ Error string

+ RequestHeader http.Header

+ Requestor *ClientInfo

+ Responder *ClientInfo

+ Status int

+ SystemLatency time.Duration

+ func (m1 *ServiceLatency) NATSTotalTime() time.Duration

type ServiceRespType

+ const Streamed

+ type SnapshotResult struct

+ Reader io.ReadCloser

+ State StreamState

+ type StatszEventOptions struct

+ type StorageType int

+ func (st *StorageType) UnmarshalJSON(data []byte) error

+ func (st StorageType) MarshalJSON() ([]byte, error)

+ func (st StorageType) String() string

+ type StorageUpdateHandler func(msgs, bytes int64, seq uint64, subj string)

+ type StoredMsg struct

+ Data []byte

+ Header []byte

+ Sequence uint64

+ Subject string

+ Time time.Time

+ type StreamConfig struct

+ Discard DiscardPolicy

+ Duplicates time.Duration

+ MaxAge time.Duration

+ MaxBytes int64

+ MaxConsumers int

+ MaxMsgSize int32

+ MaxMsgs int64

+ Mirror *StreamSource

+ Name string

+ NoAck bool

+ Placement *Placement

+ Replicas int

+ Retention RetentionPolicy

+ Sources []*StreamSource

+ Storage StorageType

+ Subjects []string

+ Template string

+ type StreamDetail struct

+ Cluster *ClusterInfo

+ Config *StreamConfig

+ Consumer []*ConsumerInfo

+ Name string

+ State StreamState

+ type StreamInfo struct

+ Cluster *ClusterInfo

+ Config StreamConfig

+ Created time.Time

+ Mirror *StreamSourceInfo

+ Sources []*StreamSourceInfo

+ State StreamState

+ type StreamSource struct

+ External *ExternalStream

+ FilterSubject string

+ Name string

+ OptStartSeq uint64

+ OptStartTime *time.Time

+ type StreamSourceInfo struct

+ Active time.Duration

+ Error *ApiError

+ Lag uint64

+ Name string

+ type StreamState struct

+ Bytes uint64

+ Consumers int

+ Deleted []uint64

+ FirstSeq uint64

+ FirstTime time.Time

+ LastSeq uint64

+ LastTime time.Time

+ Lost *LostStreamData

+ Msgs uint64

+ type StreamStore interface

+ Compact func(seq uint64) (uint64, error)

+ ConsumerStore func(name string, cfg *ConsumerConfig) (ConsumerStore, error)

+ Delete func() error

+ EraseMsg func(seq uint64) (bool, error)

+ FastState func(*StreamState)

+ GetSeqFromTime func(t time.Time) uint64

+ LoadMsg func(seq uint64) (subject string, hdr, msg []byte, ts int64, err error)

+ Purge func() (uint64, error)

+ RegisterStorageUpdates func(StorageUpdateHandler)

+ RemoveMsg func(seq uint64) (bool, error)

+ SkipMsg func() uint64

+ Snapshot func(deadline time.Duration, includeConsumers, checkMsgs bool) (*SnapshotResult, error)

+ State func() StreamState

+ Stop func() error

+ StoreMsg func(subject string, hdr, msg []byte) (uint64, int64, error)

+ StoreRawMsg func(subject string, hdr, msg []byte, seq uint64, ts int64) error

+ Truncate func(seq uint64) error

+ UpdateConfig func(cfg *StreamConfig) error

+ type StreamTemplateConfig struct

+ Config *StreamConfig

+ MaxStreams uint32

+ Name string

+ type StreamTemplateInfo struct

+ Config *StreamTemplateConfig

+ Streams []string

type SubDetail

+ Account string

type Sublist

+ func (s *Sublist) ClearNotification(subject string, notify chan<- bool) bool

+ func (s *Sublist) RegisterNotification(subject string, notify chan<- bool) error

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

+ type SubszEventOptions struct

type SubszOptions

+ Account string

type TLSConfigOpts

+ TLSCheckKnownURLs bool

+ type TemplateStore interface

+ Delete func(*streamTemplate) error

+ Store func(*streamTemplate) error

+ type TypedEvent struct

+ ID string

+ Time time.Time

+ Type string

type URLAccResolver

+ func (*URLAccResolver) Close()

+ func (*URLAccResolver) IsReadOnly() bool

+ func (*URLAccResolver) IsTrackingUpdate() bool

+ func (*URLAccResolver) Reload() error

+ func (*URLAccResolver) Start(*Server) error

type User

+ AllowedConnectionTypes map[string]struct{}

type Varz

+ JetStream JetStreamVarz

+ SystemAccount string

+ Tags jwt.TagList

+ TrustedOperatorsClaim []*jwt.OperatorClaims

+ TrustedOperatorsJwt []string

+ WSConnectURLs []string

+ type VarzEventOptions struct

+ type WAL interface

+ Compact func(index uint64) (uint64, error)

+ Delete func() error

+ FastState func(*StreamState)

+ LoadMsg func(index uint64) (subj string, hdr, msg []byte, ts int64, err error)

+ Purge func() (uint64, error)

+ RemoveMsg func(index uint64) (bool, error)

+ State func() StreamState

+ Stop func() error

+ StoreMsg func(subj string, hdr, msg []byte) (uint64, int64, error)

+ Truncate func(seq uint64) error

+ type WebsocketOpts struct

+ Advertise string

+ AllowedOrigins []string

+ AuthTimeout float64

+ Compression bool

+ HandshakeTimeout time.Duration

+ Host string

+ JWTCookie string

+ NoAuthUser string

+ NoTLS bool

+ Password string

+ Port int

+ SameOrigin bool

+ TLSConfig *tls.Config

+ TLSMap bool

+ Token string

+ Username string

v2.1.9

Nov 2, 2020

v2.1.8

Sep 3, 2020

Changes in this version

type Account

+ func (a *Account) SubscriptionInterest(subject string) bool

v2.1.7

May 14, 2020

Changes in this version

+ const DEFAULT_HTTP_BASE_PATH

type Options

+ HTTPBasePath string

+ NoAuthUser string

type RemoteLeafOpts

+ DenyExports []string

+ DenyImports []string

+ Hub bool

type Subsz

+ ID string

+ Now time.Time

type Varz

+ HTTPBasePath string

v2.1.6

Mar 31, 2020

Changes in this version

+ func ErrorIs(err, target error) bool

+ func NewErrorCtx(err error, format string, args ...interface{}) error

+ func UnpackIfErrorCtx(err error) string

type ConnInfo

+ SubsDetail []SubDetail

type ConnzOptions

+ SubscriptionsDetail bool

type Info

+ ClientIP string

type Options

+ AccountResolverTLSConfig *tls.Config

+ TraceVerbose bool

type RouteInfo

+ SubsDetail []SubDetail

type RoutezOptions

+ SubscriptionsDetail bool

type Server

+ func (s *Server) Errorc(ctx string, e error)

+ func (s *Server) Errors(scope interface{}, e error)

+ func (s *Server) Errorsc(scope interface{}, ctx string, e error)

+ func (s *Server) SetLoggerV2(logger Logger, debugFlag, traceFlag, sysTrace bool)

+ func (s *Server) WaitForShutdown()

type Varz

+ MaxProcs int

v2.1.4

Jan 30, 2020

Changes in this version

+ var ErrConnectedToWrongPort = errors.New("attempted to connect to wrong port")

+ var ErrStreamImportDuplicate = errors.New("stream import already exists")

type Options

+ LogSizeLimit int64

v2.1.2

Nov 18, 2019

Changes in this version

+ var ErrStreamImportBadPrefix = errors.New("stream import prefix can not contain wildcard tokens")

type Account

+ func (a *Account) NumServiceImports() int

type ConnInfo

+ Account string

type ConnzOptions

+ Account string

+ User string

type Info

+ GatewayNRP bool

+ Name string

type LeafNodeOpts

+ Account string

+ Users []*User

type Options

+ DisableShortFirstPing bool

+ ServerName string

type RouteStat

+ Name string

type Server

+ func (s *Server) NumLoadedAccounts() int

type ServerInfo

+ Name string

type Varz

+ Name string

v2.1.0

Sep 20, 2019

Changes in this version

+ const DEFAULT_SERVICE_LATENCY_SAMPLING

+ const InboxPrefix

+ const LeafzPath

+ 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 ErrMissingService = errors.New("service missing")

+ var ErrServerNotRunning = errors.New("server is not running")

+ func IsValidPublishSubject(subject string) bool

type Account

+ func (a *Account) IsExportService(service string) bool

+ func (a *Account) IsExportServiceTracking(service string) bool

+ func (a *Account) NumRemoteConnections() 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 LeafInfo struct

+ Account string

+ IP string

+ InBytes int64

+ InMsgs int64

+ NumSubs uint32

+ OutBytes int64

+ OutMsgs int64

+ Port int

+ RTT string

+ Subs []string

+ type Leafz struct

+ ID string

+ Leafs []*LeafInfo

+ Now time.Time

+ NumLeafs int

+ type LeafzOptions struct

+ Subscriptions bool

+ type NATSLatency struct

+ Requestor time.Duration

+ Responder time.Duration

+ System time.Duration

+ func (nl *NATSLatency) TotalTime() time.Duration

type RouteInfo

+ RTT string

type Server

+ func (s *Server) ClientURL() string

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

+ func (s *Server) Leafz(opts *LeafzOptions) (*Leafz, error)

+ func (s *Server) TrackedRemoteServers() int

+ type ServiceLatency struct

+ AppName string

+ NATSLatency NATSLatency

+ RequestStart time.Time

+ ServiceLatency time.Duration

+ TotalLatency time.Duration

v2.0.4

Aug 15, 2019

Changes in this version

+ const DEFAULT_ALLOW_RESPONSE_EXPIRATION

+ const DEFAULT_ALLOW_RESPONSE_MAX_MSGS

+ const DEFAULT_MAX_ACCOUNT_INTERNAL_RESPONSE_MAPS

+ const Revocation

+ var ErrRevocation = errors.New("credentials have been revoked")

type Account

+ func (a *Account) AddServiceExportWithResponse(subject string, respType ServiceRespType, accounts []*Account) error

+ func (a *Account) MaxResponseMaps() int

+ func (a *Account) SetMaxResponseMaps(max int)

type Permissions

+ Response *ResponsePermission

+ type ResponsePermission struct

+ Expires time.Duration

+ MaxMsgs int

+ type ServiceRespType uint8

+ const Chunked

+ const Singleton

+ const Stream

+ func (rt ServiceRespType) String() string

type Varz

+ Leafs int

v2.0.2

Jul 15, 2019

Changes in this version

+ const DEFAULT_LEAFNODE_PORT

+ const DEFAULT_LEAF_TLS_TIMEOUT

+ const DEFAULT_RTT_MEASUREMENT_INTERVAL

+ func ReadOperatorJWT(jwtfile string) (*jwt.OperatorClaims, error)

type Options

+ MaxTracedMsgLen int

+ NoSublistCache bool

type RemoteLeafOpts

+ URLs []*url.URL

type RemoteLeafOptsVarz

+ URLs []string

type Sublist

+ func NewSublistWithCache() *Sublist

v2.0.0

Jun 5, 2019

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_CONNECT_ERROR_REPORTS

+ const DEFAULT_FLUSH_DEADLINE

+ const DEFAULT_HOST

+ const DEFAULT_HTTP_PORT

+ const DEFAULT_LAME_DUCK_DURATION

+ const DEFAULT_LEAFNODE_INFO_WAIT

+ const DEFAULT_LEAF_NODE_RECONNECT

+ const DEFAULT_MAX_ACCOUNT_AE_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_TTL_AE_RESPONSE_MAP

+ const DefaultConnListSize

+ const DefaultSubListSize

+ const DuplicateRoute

+ const GATEWAY

+ const GatewayzPath

+ const INFO_ARG

+ const InfoProto

+ const LEAF

+ 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_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 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 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 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 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 ErrServiceImportAuthorization = errors.New("service import not authorized")

+ var ErrStreamImportAuthorization = errors.New("stream import not authorized")

+ 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 GenTLSConfig(tc *TLSConfigOpts) (*tls.Config, error)

+ func IsValidLiteralSubject(subject string) bool

+ func IsValidSubject(subject string) bool

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

+ 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) 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) MaxActiveConnections() int

+ func (a *Account) MaxActiveLeafNodes() int

+ func (a *Account) MaxAutoExpireResponseMaps() 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) NumRemoteLeafNodes() int

+ func (a *Account) RoutedSubs() int

+ func (a *Account) SetAutoExpireTTL(ttl time.Duration)

+ func (a *Account) SetMaxAutoExpireResponseMaps(max int)

+ func (a *Account) TotalSubs() int

+ 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

+ 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

+ 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

+ CID uint64

+ Limit int

+ Offset int

+ Sort SortOpt

+ State ConnState

+ Subscriptions bool

+ 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

+ Cluster string

+ Export *SubjectPermission

+ Gateway string

+ GatewayCmd byte

+ GatewayCmdPayload []byte

+ GatewayURL string

+ GatewayURLs []string

+ GitCommit string

+ GoVersion string

+ Host string

+ ID string

+ IP string

+ Import *SubjectPermission

+ LeafNodeURLs []string

+ MaxPayload int32

+ Nonce string

+ Port int

+ Proto int

+ TLSRequired bool

+ TLSVerify bool

+ Version string

+ type LeafNodeOpts struct

+ 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

+ type LeafNodeOptsVarz struct

+ AuthTimeout float64

+ Host string

+ Port int

+ Remotes []RemoteLeafOptsVarz

+ TLSTimeout float64

+ 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 NkeyUser struct

+ Account *Account

+ Nkey string

+ Permissions *Permissions

+ SigningKey string

+ type Options struct

+ AccountResolver AccountResolver

+ Accounts []*Account

+ AllowNewAccounts bool

+ AuthTimeout float64

+ Authorization string

+ CheckConfig bool

+ ClientAdvertise string

+ Cluster ClusterOpts

+ ConfigFile string

+ ConnectErrorReports int

+ CustomClientAuthentication Authentication

+ CustomRouterAuthentication Authentication

+ Debug bool

+ Gateway GatewayOpts

+ HTTPHost string

+ HTTPPort int

+ HTTPSPort int

+ Host string

+ LameDuckDuration time.Duration

+ LeafNode LeafNodeOpts

+ LogFile string

+ Logtime bool

+ MaxClosedClients int

+ MaxConn int

+ MaxControlLine int32

+ MaxPayload int32

+ MaxPending int64

+ MaxPingsOut int

+ MaxSubs int

+ Nkeys []*NkeyUser

+ NoLog bool

+ NoSigs bool

+ Password string

+ PidFile string

+ PingInterval time.Duration

+ Port int

+ PortsFileDir string

+ ProfPort int

+ ReconnectErrorReports int

+ RemoteSyslog string

+ Routes []*url.URL

+ RoutesStr string

+ Syslog bool

+ SystemAccount string

+ TLS bool

+ TLSCaCert string

+ TLSCert string

+ TLSConfig *tls.Config

+ TLSKey string

+ TLSMap bool

+ TLSTimeout float64

+ TLSVerify bool

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

+ 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

+ LocalAccount string

+ TLS bool

+ TLSConfig *tls.Config

+ TLSTimeout float64

+ URL *url.URL

+ type RemoteLeafOptsVarz struct

+ LocalAccount string

+ TLSTimeout float64

+ URL string

+ 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

+ RemoteID string

+ Rid uint64

+ Subs []string

+ type RoutePermissions struct

+ Export *SubjectPermission

+ Import *SubjectPermission

+ type RouteStat struct

+ ID uint64

+ 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

+ 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) 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) Errorf(format string, v ...interface{})

+ 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) 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) LookupAccount(name string) (*Account, error)

+ func (s *Server) LookupOrRegisterAccount(name string) (account *Account, isNew bool)

+ 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) 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) 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) Subsz(opts *SubszOptions) (*Subsz, error)

+ func (s *Server) SystemAccount() *Account

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

+ func (s *Server) UpdateAccountClaims(a *Account, ac *jwt.AccountClaims)

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

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

+ type ServerInfo struct

+ Cluster string

+ Host string

+ ID 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 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() *Sublist

+ func NewSublistNoCache() *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

+ Limit int

+ 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

+ HTTPHost string

+ HTTPPort int

+ HTTPReqStats map[string]uint64

+ HTTPSPort int

+ Host string

+ ID string

+ IP string

+ InBytes int64

+ InMsgs int64

+ LeafNode LeafNodeOptsVarz

+ MaxConn int

+ MaxControlLine int32

+ MaxPayload int

+ MaxPending int64

+ MaxPingsOut int

+ MaxSubs int

+ Mem int64

+ 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

v2.0.0-RC19

Jun 4, 2019

Other modules containing this package

github.com/nats-io/nats-server

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