server

package

v0.3.0 Latest Latest Go to latest Published: Oct 19, 2016 License: MIT Imports: 24 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lrh3321/nats-streaming-server

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
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 ProcessConfigFile(configFile string, opts *Options) error
func RemoveLogger()
func Tracef(format string, v ...interface{})
type Options
- func GetDefaultOptions() (o *Options)
type StanServer
- func RunServer(ID string) *StanServer
- func RunServerWithOpts(stanOpts *Options, natsOpts *server.Options) *StanServer
- func (s *StanServer) ClusterID() string
- func (s *StanServer) Shutdown()

Constants ¶

View Source

const (
	// VERSION is the current version for the NATS Streaming server.
	VERSION = "0.3.0"

	DefaultClusterID      = "test-cluster"
	DefaultDiscoverPrefix = "_STAN.discover"
	DefaultPubPrefix      = "_STAN.pub"
	DefaultSubPrefix      = "_STAN.sub"
	DefaultUnSubPrefix    = "_STAN.unsub"
	DefaultClosePrefix    = "_STAN.close"
	DefaultStoreType      = stores.TypeMemory

	// Heartbeat intervals.
	DefaultHeartBeatInterval   = 30 * time.Second
	DefaultClientHBTimeout     = 10 * time.Second
	DefaultMaxFailedHeartBeats = int((5 * time.Minute) / DefaultHeartBeatInterval)

	// DefaultIOBatchSize is the maximum number of messages to accumulate before flushing a store.
	DefaultIOBatchSize = 1024

	// DefaultIOSleepTime is the duration (in micro-seconds) the server waits for more messages
	// before starting processing. Set to 0 (or negative) to disable the wait.
	DefaultIOSleepTime = int64(0)
)

Server defaults.

Variables ¶

View Source

var (
	ErrInvalidSubject  = errors.New("stan: invalid subject")
	ErrInvalidSequence = errors.New("stan: invalid start sequence")
	ErrInvalidTime     = errors.New("stan: invalid start time")
	ErrInvalidSub      = errors.New("stan: invalid subscription")
	ErrInvalidClient   = errors.New("stan: clientID already registered")
	ErrInvalidAckWait  = errors.New("stan: invalid ack wait time, should be >= 1s")
	ErrInvalidConnReq  = errors.New("stan: invalid connection request")
	ErrInvalidPubReq   = errors.New("stan: invalid publish request")
	ErrInvalidSubReq   = errors.New("stan: invalid subscription request")
	ErrInvalidUnsubReq = errors.New("stan: invalid unsubscribe request")
	ErrInvalidCloseReq = errors.New("stan: invalid close request")
	ErrDupDurable      = errors.New("stan: duplicate durable registration")
	ErrInvalidDurName  = errors.New("stan: durable name of a durable queue subscriber can't contain the character ':'")
	ErrUnknownClient   = errors.New("stan: unkwown clientID")
)

Errors.

View Source

var DefaultNatsServerOptions = server.Options{
	Host:   "localhost",
	Port:   4222,
	NoLog:  true,
	NoSigs: true,
}

DefaultNatsServerOptions are default options for the NATS server

Functions ¶

func ConfigureLogger ¶

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

ConfigureLogger configures logging for STAN and the embedded NATS server based on options passed.

func Debugf ¶

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

Debugf logs a debug statement

func Errorf ¶

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

Errorf logs an error

func Fatalf ¶

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

Fatalf logs a fatal error

func Noticef ¶

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

Noticef logs a notice statement

func ProcessConfigFile ¶ added in v0.3.0

func ProcessConfigFile(configFile string, opts *Options) error

ProcessConfigFile parses the configuration file `configFile` and updates the given Streaming options `opts`.

func RemoveLogger ¶

func RemoveLogger()

RemoveLogger clears the logger instance and debug/trace flags. Used for testing.

func Tracef ¶

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

Tracef logs a trace statement

Types ¶

type Options ¶

type Options struct {
	ID                 string
	DiscoverPrefix     string
	StoreType          string
	FilestoreDir       string
	FileStoreOpts      stores.FileStoreOptions
	stores.StoreLimits        // Store limits (MaxChannels, etc..)
	Trace              bool   // Verbose trace
	Debug              bool   // Debug trace
	Secure             bool   // Create a TLS enabled connection w/o server verification
	ClientCert         string // Client Certificate for TLS
	ClientKey          string // Client Key for TLS
	ClientCA           string // Client CAs for TLS
	IOBatchSize        int    // Number of messages we collect from clients before processing them.
	IOSleepTime        int64  // Duration (in micro-seconds) the server waits for more message to fill up a batch.
	NATSServerURL      string // URL for external NATS Server to connect to. If empty, NATS Server is embedded.
}

Options for STAN Server

func GetDefaultOptions ¶

func GetDefaultOptions() (o *Options)

GetDefaultOptions returns default options for the STAN server

type StanServer ¶

type StanServer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

StanServer structure represents the STAN server

func RunServer ¶

func RunServer(ID string) *StanServer

RunServer will startup an embedded STAN server and a nats-server to support it.

func RunServerWithOpts ¶

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

RunServerWithOpts will startup an embedded STAN server and a nats-server to support it.

func (*StanServer) ClusterID ¶

func (s *StanServer) ClusterID() string

ClusterID returns the STAN Server's ID.

func (*StanServer) Shutdown ¶

func (s *StanServer) Shutdown()

Shutdown will close our NATS connection and shutdown any embedded NATS server.

Source Files ¶

View all Source files

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