Documentation
¶
Overview ¶
Package listener defines the functions for the publisher of messages to the bus.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
Listener accepts measurements in InfluxDB Line Protocol format via UDP or HTTP, batches them and then publishes them to a NATS subject.
func StartHTTPListener ¶
StartHTTPListener initialises listener configured to accept lines from HTTP request bodies instead of via UDP. It starts the listener and its statistician and never returns.
func StartListener ¶
StartListener initialises a listener, starts its statistician goroutine and runs it's main loop. It never returns.
The listener reads incoming UDP packets, batches them up and sends them onwards to a NATS subject.
Source Files
Click to show internal directories.
Click to hide internal directories.