Documentation
¶
Index ¶
Constants ¶
View Source
const ( EMAIL_STREAM = "emails" MAX_STREAM_RECONNECTS = -1 // never stop trying to reconnect )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NATSConnections ¶
type NATSConnections struct {
Conn *nats.Conn
JS nats.JetStreamContext
}
func InitNats ¶
func InitNats(config *config.NATSConfig) (*NATSConnections, error)
InitNats initializes the NATS connection and sets up streams
func (*NATSConnections) Close ¶
func (n *NATSConnections) Close()
Source Files
Click to show internal directories.
Click to hide internal directories.