Documentation ¶
Index ¶
- Variables
- type Connection
- func (c *Connection) Connect() error
- func (c *Connection) Disconnect()
- func (c *Connection) IsConnected() bool
- func (c *Connection) Publish(topic string, message []byte) error
- func (c *Connection) Status() <-chan struct{}
- func (c *Connection) Subscribe(topic string, queue string, handler bus.MessageHandler) (interface{}, error)
- func (c *Connection) Unsubscribe(handle interface{}) error
- type Option
- func WithClientID(id string) Option
- func WithCloseHandler(h nats.ConnHandler) Option
- func WithClusterID(id string) Option
- func WithConnectionLostHandler(h stan.ConnectionLostHandler) Option
- func WithDisconnectHandler(h nats.ConnHandler) Option
- func WithDurable(n string) Option
- func WithLogger(l logger.Logger) Option
- func WithName(n string) Option
- func WithReconnectDelay(t time.Duration) Option
- func WithReconnectHandler(h nats.ConnHandler) Option
- func WithURL(u string) Option
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNotConnected = errors.New("stan: not connected")
)
Errors
Functions ¶
This section is empty.
Types ¶
type Connection ¶
Connection interface
func CreateConnection ¶
func CreateConnection(opts ...Option) *Connection
CreateConnection creates new connection
func (*Connection) Publish ¶
func (c *Connection) Publish(topic string, message []byte) error
Publish message
func (*Connection) Subscribe ¶
func (c *Connection) Subscribe(topic string, queue string, handler bus.MessageHandler) (interface{}, error)
Subscribe for messages
func (*Connection) Unsubscribe ¶
func (c *Connection) Unsubscribe(handle interface{}) error
Unsubscribe subscription
type Option ¶
type Option func(*options)
Option initializes Options properties
func WithCloseHandler ¶
func WithCloseHandler(h nats.ConnHandler) Option
WithCloseHandler initializes closeHandler option
func WithClusterID ¶
WithClusterID initializes clusterID option
func WithConnectionLostHandler ¶
func WithConnectionLostHandler(h stan.ConnectionLostHandler) Option
WithConnectionLostHandler initializes connectionLostHandler option
func WithDisconnectHandler ¶
func WithDisconnectHandler(h nats.ConnHandler) Option
WithDisconnectHandler initializes disconnectHandler option
func WithReconnectDelay ¶
WithReconnectDelay initializes reconnectDelay option
func WithReconnectHandler ¶
func WithReconnectHandler(h nats.ConnHandler) Option
WithReconnectHandler initializes reconnectHandler option
Click to show internal directories.
Click to hide internal directories.