# Functions
DCOptConnectCb sets callback when nats streaming connection establish.
DCOptContext sets base context for handlers.
DCOptDisconnectCb sets callback when nats streaming connection lost due to unexpected errors.
DCOptLogger sets logger for DurConn.
DCOptReconnectWait sets the interval between reconnections.
DCOptRunner sets runner for handlers.
DCOptStanPingInterval sets stan::Pings, must >= 1 (seconds).
DCOptStanPingMaxOut sets stan::Pings, must >= 2.
DCOptStanPubAckWait sets stan::PubAckWait.
DCOptSubjectPrefix sets subject prefix in nats streaming namespace.
DCOptSubRetryWait sets the interval between resubscriptions due to subscription error.
DCOptSubscribeCb sets callback when subscriptions subscribed.
NewDurConn creates a new DurConn.
NewPbJsonPublisher creates a msg publisher using protobuf or json for encoding: - If msg is proto.Message, then use protobuf.
NewPbJsonSubscriber creates a msg subscriber using protobuf or json for decoding.
SubOptStanAckWait sets stan::AckWait for a subscription.
# Variables
DefaultReconnectWait is the default value of DCOptReconnectWait.
DefaultStanPingInterval is the default value of DCOptStanPingInterval.
DefaultStanPingMaxOut is the default value of DCOptStanPingMaxOut.
DefaultStanPubAckWait is the default value of DCOptStanPubAckWait.
DefaultSubjectPrefix is the default value of DCOptSubjectPrefix.
DefaultSubRetryWait is the default value of DCOptSubRetryWait.
ErrClosed is returned when DurConn is closed.
ErrDupSubscription is returned when (subjectName, queue) already subscribed.
ErrNCMaxReconnect is returned if nc has MaxReconnects >= 0.
ErrNotConnected is returned when stan connection has not connected yet.
# Structs
DurConn is 'durable connection' to nats-streaming-server which handles reconnect and resubscription automatically.
# Type aliases
DurConnOption is option in creating DurConn.
SubOption is option in subscription.