package
Version:
v0.0.0-...-e650048
Opens a new window with list of versions in this module.
Published: Mar 4, 2024
License: AGPL-3.0
Opens a new window with license information.
Imports: 8
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
func Conn() *nats.EncodedConn
Returns the default internal client.
Drains and closes the connection to the embedded NATS server.
Returns the number of subscribers on a given subject.
Start the embedded NATS server. If options are passed as parameters, they will override the internal
options (the common config module is used).
type PingConfig struct {
HowMany int
Timeout time.Duration
Message interface{}
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.