Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommandsReader ¶
CommandsReader parses a NATS connection input stream into commands
func NewCommandsReader ¶
func NewCommandsReader(src io.Reader) CommandsReader
NewCommandsReader creates a CommandsReader
func (CommandsReader) NextCommand ¶
func (cr CommandsReader) NextCommand() ([]byte, error)
NextCommand returns the next command in the input stream
type ConnectHandler ¶
ConnectHandler is used in Settings for handling the initial CONNECT of a nats connection
type ErrorHandler ¶
type ErrorHandler func(error)
ErrorHandler is used in Settings for handling errors
type Gateway ¶
type Gateway struct {
// contains filtered or unexported fields
}
Gateway is a HTTP handler that acts as a websocket gateway to a NATS server
type NatsConn ¶
type NatsConn struct { Conn net.Conn CmdReader CommandsReader ServerInfo NatsServerInfo }
NatsConn holds a NATS TCP connection
type NatsServerInfo ¶
type NatsServerInfo string
NatsServerInfo is the information returned by the INFO nats message
Click to show internal directories.
Click to hide internal directories.