server

Apr 16, 2019

Changes in this version

type Options

+ NATSClientOpts []nats.Option

type Serverz

+ Role string

Feb 8, 2019

Changes in this version

type Options

+ Encrypt bool

+ EncryptionCipher string

+ EncryptionKey []byte

type Serverz

+ MaxFDs int

+ OpenFDs int

Oct 17, 2018

Changes in this version

type ClusteringOptions

+ RaftCommitTimeout time.Duration

+ RaftElectionTimeout time.Duration

+ RaftHeartbeatTimeout time.Duration

+ RaftLeaseTimeout time.Duration

Sep 4, 2018

Changes in this version

type Options

+ SyslogName string

type StanServer

+ func Run(sOpts *Options, nOpts *natsd.Options) (*StanServer, error)

Apr 3, 2018

Changes in this version

+ var ErrTimeout = errors.New("natslog: read timeout")

Mar 16, 2018

Changes in this version

+ const DefaultLogCacheSize

+ const DefaultLogSnapshots

+ const DefaultTrailingLogs

+ var ErrChanDelInProgress = errors.New("stan: channel is being deleted")

+ var ErrClusteredRestart = errors.New(...)

+ func NewNATSOptions() *server.Options

+ type ClusteringOptions struct

+ Bootstrap bool

+ Clustered bool

+ LogCacheSize int

+ LogSnapshots int

+ NodeID string

+ Peers []string

+ RaftLogPath string

+ RaftLogging bool

+ Sync bool

+ TrailingLogs int64

type Options

+ Clustering ClusteringOptions

type State

+ const Clustered

Dec 19, 2017

Changes in this version

type Options

+ SQLStoreOpts stores.SQLStoreOptions

type Subscriptionz

+ ClientID string

Oct 25, 2017

Changes in this version

type Options

+ CustomLogger logger.Logger

+ EnableLogging bool

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

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

type Subscriptionz

+ IsOffline bool

Jun 27, 2017

Changes in this version

+ const ChannelsPath

+ const ClientsPath

+ const RootPath

+ const ServerPath

+ const StorePath

+ var ErrInvalidClientID = errors.New("stan: invalid clientID: only alphanumeric and `-` or `_` characters allowed")

+ var ErrNoChannel = errors.New("stan: no configured channel")

+ type Channelsz struct

+ Channels []*Channelz

+ ClusterID string

+ Count int

+ Limit int

+ Names []string

+ Now time.Time

+ Offset int

+ ServerID string

+ Total int

+ type Channelz struct

+ Bytes uint64

+ FirstSeq uint64

+ LastSeq uint64

+ Msgs int

+ Name string

+ Subscriptions []*Subscriptionz

+ type Clientsz struct

+ Clients []*Clientz

+ ClusterID string

+ Count int

+ Limit int

+ Now time.Time

+ Offset int

+ ServerID string

+ Total int

+ type Clientz struct

+ HBInbox string

+ ID string

+ Subscriptions map[string][]*Subscriptionz

type Options

+ HandleSignals bool

+ Partitioning bool

+ type Serverz struct

+ Channels int

+ Clients int

+ ClusterID string

+ GoVersion string

+ Now time.Time

+ ServerID string

+ Start time.Time

+ State string

+ Subscriptions int

+ TotalBytes uint64

+ TotalMsgs int

+ Uptime string

+ Version string

+ type Storez struct

+ ClusterID string

+ Limits stores.StoreLimits

+ Now time.Time

+ ServerID string

+ TotalBytes uint64

+ TotalMsgs int

+ Type string

+ type Subscriptionz struct

+ AckInbox string

+ AckWait int

+ DurableName string

+ Inbox string

+ IsDurable bool

+ IsStalled bool

+ LastSent uint64

+ MaxInflight int

+ PendingCount int

+ QueueName string

Apr 10, 2017

Changes in this version

+ const LogPrefix

type Options

+ AckSubsPoolSize int

+ FTGroupName string

type StanServer

+ func (s *StanServer) LastError() error

+ func (s *StanServer) State() State

+ type State int8

+ const FTActive

+ const FTStandby

+ const Failed

+ const Shutdown

+ const Standalone

+ func (state State) String() string

Jan 19, 2017

Changes in this version

+ var ErrInvalidMaxInflight = errors.New("stan: invalid MaxInflight, should be >= 1")

+ var ErrInvalidStart = errors.New("stan: invalid start position")

+ var ErrMissingClient = errors.New("stan: clientID missing")

Dec 21, 2016

Changes in this version

type Options

+ ClientHBFailCount int

+ ClientHBInterval time.Duration

+ ClientHBTimeout time.Duration

Dec 12, 2016

Changes in this version

+ const DefaultSubClosePrefix

Oct 19, 2016

Changes in this version

+ var ErrInvalidDurName = errors.New(...)

+ func ProcessConfigFile(configFile string, opts *Options) error

Aug 8, 2016

Changes in this version

type Options

+ NATSServerURL string

Jul 8, 2016

Changes in this version

+ const DefaultIOBatchSize

+ const DefaultIOSleepTime

type Options

+ IOBatchSize int

+ IOSleepTime int64

Jun 24, 2016

Changes in this version

+ const DefaultChannelLimit

+ const DefaultClientHBTimeout

+ const DefaultClosePrefix

+ const DefaultClusterID

+ const DefaultDiscoverPrefix

+ const DefaultHeartBeatInterval

+ const DefaultMaxFailedHeartBeats

+ const DefaultMsgSizeStoreLimit

+ const DefaultMsgStoreLimit

+ const DefaultPubPrefix

+ const DefaultStoreType

+ const DefaultSubPrefix

+ const DefaultSubStoreLimit

+ const DefaultUnSubPrefix

+ const VERSION

+ var DefaultNatsServerOptions = server.Options

+ var ErrDupDurable = errors.New("stan: duplicate durable registration")

+ var ErrDurableQueue = errors.New("stan: queue subscribers can't be durable")

+ var ErrInvalidAckWait = errors.New("stan: invalid ack wait time, should be >= 1s")

+ var ErrInvalidClient = errors.New("stan: clientID already registered")

+ var ErrInvalidCloseReq = errors.New("stan: invalid close request")

+ var ErrInvalidConnReq = errors.New("stan: invalid connection request")

+ var ErrInvalidPubReq = errors.New("stan: invalid publish request")

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

+ var ErrInvalidSub = errors.New("stan: invalid subscription")

+ var ErrInvalidSubReq = errors.New("stan: invalid subscription request")

+ var ErrInvalidSubject = errors.New("stan: invalid subject")

+ var ErrInvalidTime = errors.New("stan: invalid start time")

+ var ErrInvalidUnsubReq = errors.New("stan: invalid unsubscribe request")

+ var ErrUnknownClient = errors.New("stan: unkwown clientID")

+ func ConfigureLogger(stanOpts *Options, natsOpts *natsd.Options)

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

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

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

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

+ func RemoveLogger()

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

+ type Options struct

+ ClientCA string

+ ClientCert string

+ ClientKey string

+ Debug bool

+ DiscoverPrefix string

+ FileStoreOpts stores.FileStoreOptions

+ FilestoreDir string

+ ID string

+ MaxBytes uint64

+ MaxChannels int

+ MaxMsgs int

+ MaxSubscriptions int

+ Secure bool

+ StoreType string

+ Trace bool

+ func GetDefaultOptions() (o *Options)

+ type StanServer struct

+ func RunServer(ID string) *StanServer

+ func RunServerWithOpts(stanOpts *Options, natsOpts *server.Options) *StanServer

+ func (s *StanServer) ClusterID() string

+ func (s *StanServer) Shutdown()