Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.3.8

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")

v0.3.6

Dec 21, 2016

Changes in this version

type Options

+ ClientHBFailCount int

+ ClientHBInterval time.Duration

+ ClientHBTimeout time.Duration

v0.3.4

Dec 12, 2016

Changes in this version

+ const DefaultSubClosePrefix

v0.3.0

Oct 19, 2016

Changes in this version

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

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

v0.2.2

Aug 8, 2016

Changes in this version

type Options

+ NATSServerURL string

v0.2.0

Jul 8, 2016

Changes in this version

+ const DefaultIOBatchSize

+ const DefaultIOSleepTime

type Options

+ IOBatchSize int

+ IOSleepTime int64

v0.1.0

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()