nats

package module

Go to main page

Versions in this module

v1

v1.7.2

Feb 21, 2019

Changes in this version

+ var ErrNoDeadlineContext = errors.New("nats: context requires a deadline")

type Conn

+ func (nc *Conn) ConnectedAddr() string

+ func (nc *Conn) FlushWithContext(ctx context.Context) error

type Option

+ func MaxPingsOutstanding(max int) Option

+ func SyncQueueLen(max int) Option

v1.7.0

Dec 11, 2018

Changes in this version

+ var ErrClientIDNotSupported = errors.New("nats: client ID not supported by this server")

+ var ErrNkeyAndUser = errors.New("nats: user callback and nkey defined")

+ var ErrNkeyButNoSigCB = errors.New("nats: nkey defined without a signature handler")

+ var ErrNkeysNotSupported = errors.New("nats: nkeys not supported by the server")

+ var ErrNoUserCB = errors.New("nats: user callback not defined")

+ var ErrTokenAlreadySet = errors.New("nats: token and token handler both set")

+ var ErrUserButNoSigCB = errors.New("nats: user callback defined without a signature handler")

+ type AuthTokenHandler func() string

type Conn

+ func (nc *Conn) GetClientID() (uint64, error)

+ func (nc *Conn) NewRespInbox() string

type Option

+ func FlusherTimeout(t time.Duration) Option

+ func Nkey(pubKey string, sigCB SignatureHandler) Option

+ func NkeyOptionFromSeed(seedFile string) (Option, error)

+ func TokenHandler(cb AuthTokenHandler) Option

+ func UserCredentials(userOrChainedFile string, seedFiles ...string) Option

+ func UserJWT(userCB UserJWTHandler, sigCB SignatureHandler) Option

type Options

+ Nkey string

+ SignatureCB SignatureHandler

+ TokenHandler AuthTokenHandler

+ UserJWT UserJWTHandler

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

+ type UserJWTHandler func() (string, error)

v1.6.0

Aug 29, 2018

Changes in this version

+ const DRAINING_PUBS

+ const DRAINING_SUBS

+ const DefaultDrainTimeout

+ var ErrConnectionDraining = errors.New("nats: connection draining")

+ var ErrConnectionReconnecting = errors.New("nats: connection reconnecting")

+ var ErrDrainTimeout = errors.New("nats: draining connection timed out")

+ var ErrNoEchoNotSupported = errors.New("nats: no echo option not supported by this server")

type Conn

+ func (nc *Conn) Drain() error

+ func (nc *Conn) IsDraining() bool

+ func (nc *Conn) NumSubscriptions() int

type EncodedConn

+ func (c *EncodedConn) Drain() error

type Option

+ func DrainTimeout(t time.Duration) Option

+ func NoEcho() Option

+ func PingInterval(t time.Duration) Option

type Options

+ DrainTimeout time.Duration

+ NoEcho bool

type Subscription

+ func (s *Subscription) Drain() error

v1.5.0

Mar 23, 2018

Changes in this version

type Conn

+ func (nc *Conn) Barrier(f func()) error

type Option

+ func ReconnectBufSize(size int) Option

v1.4.0

Dec 20, 2017

Changes in this version

+ type CustomDialer interface

+ Dial func(network, address string) (net.Conn, error)

type Option

+ func SetCustomDialer(dialer CustomDialer) Option

type Options

+ CustomDialer CustomDialer

v1.3.0

Aug 8, 2017

Changes in this version

+ const AUTHORIZATION_ERR

+ const AsyncSubscription

+ const CLOSED

+ const CONNECTED

+ const CONNECTING

+ const ChanSubscription

+ const DEFAULT_ENCODER

+ const DISCONNECTED

+ const DefaultMaxChanLen

+ const DefaultMaxPingOut

+ const DefaultMaxReconnect

+ const DefaultPingInterval

+ const DefaultPort

+ const DefaultReconnectBufSize

+ const DefaultReconnectWait

+ const DefaultSubPendingBytesLimit

+ const DefaultSubPendingMsgsLimit

+ const DefaultTimeout

+ const DefaultURL

+ const GOB_ENCODER

+ const INFO_ARG

+ const InboxPrefix

+ const JSON_ENCODER

+ const LangString

+ const MAX_CONTROL_LINE_SIZE

+ const MINUS_ERR_ARG

+ const MSG_ARG

+ const MSG_END

+ const MSG_PAYLOAD

+ const NilSubscription

+ const OP_I

+ const OP_IN

+ const OP_INF

+ const OP_INFO

+ const OP_INFO_SPC

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

+ const PERMISSIONS_ERR

+ const RECONNECTING

+ const RequestChanLen

+ const STALE_CONNECTION

+ const SyncSubscription

+ const Version

+ var DefaultOptions = GetDefaultOptions()

+ var ErrAuthorization = errors.New("nats: authorization violation")

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

+ var ErrBadSubscription = errors.New("nats: invalid subscription")

+ var ErrBadTimeout = errors.New("nats: timeout invalid")

+ var ErrChanArg = errors.New("nats: argument needs to be a channel type")

+ var ErrConnectionClosed = errors.New("nats: connection closed")

+ var ErrInvalidArg = errors.New("nats: invalid argument")

+ var ErrInvalidConnection = errors.New("nats: invalid connection")

+ var ErrInvalidContext = errors.New("nats: invalid context")

+ var ErrInvalidMsg = errors.New("nats: invalid message or message nil")

+ var ErrJsonParse = errors.New("nats: connect message, json parse error")

+ var ErrMaxMessages = errors.New("nats: maximum messages delivered")

+ var ErrMaxPayload = errors.New("nats: maximum payload exceeded")

+ var ErrMultipleTLSConfigs = errors.New("nats: multiple tls.Configs not allowed")

+ var ErrNoInfoReceived = errors.New("nats: protocol exception, INFO not received")

+ var ErrNoServers = errors.New("nats: no servers available for connection")

+ var ErrReconnectBufExceeded = errors.New("nats: outbound buffer limit exceeded")

+ var ErrSecureConnRequired = errors.New("nats: secure connection required")

+ var ErrSecureConnWanted = errors.New("nats: secure connection not available")

+ var ErrSlowConsumer = errors.New("nats: slow consumer, messages dropped")

+ var ErrStaleConnection = errors.New("nats: " + STALE_CONNECTION)

+ var ErrSyncSubRequired = errors.New("nats: illegal call on an async subscription")

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

+ var ErrTypeSubscription = errors.New("nats: invalid subscription type")

+ func NewInbox() string

+ func RegisterEncoder(encType string, enc Encoder)

+ type Conn struct

+ Opts Options

+ func Connect(url string, options ...Option) (*Conn, error)

+ func (nc *Conn) AuthRequired() bool

+ func (nc *Conn) Buffered() (int, error)

+ func (nc *Conn) ChanQueueSubscribe(subj, group string, ch chan *Msg) (*Subscription, error)

+ func (nc *Conn) ChanSubscribe(subj string, ch chan *Msg) (*Subscription, error)

+ func (nc *Conn) Close()

+ func (nc *Conn) ConnectedServerId() string

+ func (nc *Conn) ConnectedUrl() string

+ func (nc *Conn) DiscoveredServers() []string

+ func (nc *Conn) Flush() error

+ func (nc *Conn) FlushTimeout(timeout time.Duration) (err error)

+ func (nc *Conn) IsClosed() bool

+ func (nc *Conn) IsConnected() bool

+ func (nc *Conn) IsReconnecting() bool

+ func (nc *Conn) LastError() error

+ func (nc *Conn) MaxPayload() int64

+ func (nc *Conn) Publish(subj string, data []byte) error

+ func (nc *Conn) PublishMsg(m *Msg) error

+ func (nc *Conn) PublishRequest(subj, reply string, data []byte) error

+ func (nc *Conn) QueueSubscribe(subj, queue string, cb MsgHandler) (*Subscription, error)

+ func (nc *Conn) QueueSubscribeSync(subj, queue string) (*Subscription, error)

+ func (nc *Conn) QueueSubscribeSyncWithChan(subj, queue string, ch chan *Msg) (*Subscription, error)

+ func (nc *Conn) Request(subj string, data []byte, timeout time.Duration) (*Msg, error)

+ func (nc *Conn) RequestWithContext(ctx context.Context, subj string, data []byte) (*Msg, error)

+ func (nc *Conn) Servers() []string

+ func (nc *Conn) SetClosedHandler(cb ConnHandler)

+ func (nc *Conn) SetDisconnectHandler(dcb ConnHandler)

+ func (nc *Conn) SetDiscoveredServersHandler(dscb ConnHandler)

+ func (nc *Conn) SetErrorHandler(cb ErrHandler)

+ func (nc *Conn) SetReconnectHandler(rcb ConnHandler)

+ func (nc *Conn) Stats() Statistics

+ func (nc *Conn) Status() Status

+ func (nc *Conn) Subscribe(subj string, cb MsgHandler) (*Subscription, error)

+ func (nc *Conn) SubscribeSync(subj string) (*Subscription, error)

+ func (nc *Conn) TLSRequired() bool

+ type ConnHandler func(*Conn)

+ type EncodedConn struct

+ Conn *Conn

+ Enc Encoder

+ func NewEncodedConn(c *Conn, encType string) (*EncodedConn, error)

+ func (c *EncodedConn) BindRecvChan(subject string, channel interface{}) (*Subscription, error)

+ func (c *EncodedConn) BindRecvQueueChan(subject, queue string, channel interface{}) (*Subscription, error)

+ func (c *EncodedConn) BindSendChan(subject string, channel interface{}) error

+ func (c *EncodedConn) Close()

+ func (c *EncodedConn) Flush() error

+ func (c *EncodedConn) FlushTimeout(timeout time.Duration) (err error)

+ func (c *EncodedConn) LastError() error

+ func (c *EncodedConn) Publish(subject string, v interface{}) error

+ func (c *EncodedConn) PublishRequest(subject, reply string, v interface{}) error

+ func (c *EncodedConn) QueueSubscribe(subject, queue string, cb Handler) (*Subscription, error)

+ func (c *EncodedConn) Request(subject string, v interface{}, vPtr interface{}, timeout time.Duration) error

+ func (c *EncodedConn) RequestWithContext(ctx context.Context, subject string, v interface{}, vPtr interface{}) error

+ func (c *EncodedConn) Subscribe(subject string, cb Handler) (*Subscription, error)

+ type Encoder interface

+ Decode func(subject string, data []byte, vPtr interface{}) error

+ Encode func(subject string, v interface{}) ([]byte, error)

+ func EncoderForType(encType string) Encoder

+ type ErrHandler func(*Conn, *Subscription, error)

+ type Handler interface

+ type Msg struct

+ Data []byte

+ Reply string

+ Sub *Subscription

+ Subject string

+ type MsgHandler func(msg *Msg)

+ type Option func(*Options) error

+ func ClientCert(certFile, keyFile string) Option

+ func ClosedHandler(cb ConnHandler) Option

+ func Dialer(dialer *net.Dialer) Option

+ func DisconnectHandler(cb ConnHandler) Option

+ func DiscoveredServersHandler(cb ConnHandler) Option

+ func DontRandomize() Option

+ func ErrorHandler(cb ErrHandler) Option

+ func MaxReconnects(max int) Option

+ func Name(name string) Option

+ func NoReconnect() Option

+ func ReconnectHandler(cb ConnHandler) Option

+ func ReconnectWait(t time.Duration) Option

+ func RootCAs(file ...string) Option

+ func Secure(tls ...*tls.Config) Option

+ func Timeout(t time.Duration) Option

+ func Token(token string) Option

+ func UseOldRequestStyle() Option

+ func UserInfo(user, password string) Option

+ type Options struct

+ AllowReconnect bool

+ AsyncErrorCB ErrHandler

+ ClosedCB ConnHandler

+ Dialer *net.Dialer

+ DisconnectedCB ConnHandler

+ DiscoveredServersCB ConnHandler

+ FlusherTimeout time.Duration

+ MaxPingsOut int

+ MaxReconnect int

+ Name string

+ NoRandomize bool

+ Password string

+ Pedantic bool

+ PingInterval time.Duration

+ ReconnectBufSize int

+ ReconnectWait time.Duration

+ ReconnectedCB ConnHandler

+ Secure bool

+ Servers []string

+ SubChanLen int

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ Token string

+ Url string

+ UseOldRequestStyle bool

+ User string

+ Verbose bool

+ func GetDefaultOptions() Options

+ func (o Options) Connect() (*Conn, error)

+ type Statistics struct

+ InBytes uint64

+ InMsgs uint64

+ OutBytes uint64

+ OutMsgs uint64

+ Reconnects uint64

+ type Status int

+ type Subscription struct

+ Queue string

+ Subject string

+ func (s *Subscription) AutoUnsubscribe(max int) error

+ func (s *Subscription) ClearMaxPending() error

+ func (s *Subscription) Delivered() (int64, error)

+ func (s *Subscription) Dropped() (int, error)

+ func (s *Subscription) IsValid() bool

+ func (s *Subscription) MaxPending() (int, int, error)

+ func (s *Subscription) NextMsg(timeout time.Duration) (*Msg, error)

+ func (s *Subscription) NextMsgWithContext(ctx context.Context) (*Msg, error)

+ func (s *Subscription) Pending() (int, int, error)

+ func (s *Subscription) PendingLimits() (int, int, error)

+ func (s *Subscription) QueuedMsgs() (int, error)

+ func (s *Subscription) SetPendingLimits(msgLimit, bytesLimit int) error

+ func (s *Subscription) Type() SubscriptionType

+ func (s *Subscription) Unsubscribe() error

+ type SubscriptionType int

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