Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReadIngestServer ¶
func ReadIngestServer(sink chan<- lineprotocol.Point, addresses []string, shutdown chan struct{})
Types ¶
type HTTPHandler ¶
type HTTPHandler struct {
// contains filtered or unexported fields
}
HTTPHandler handles http POST requests and stores incoming points to a point sink
func NewHTTPHandler ¶
func NewHTTPHandler(sink chan<- lineprotocol.Point) HTTPHandler
func (*HTTPHandler) ServeHTTP ¶
func (h *HTTPHandler) ServeHTTP(writer http.ResponseWriter, request *http.Request)
ServeHTTP processes a POST request with line protocol data
type TCPListener ¶
type TCPListener struct {
// contains filtered or unexported fields
}
TCPLineProtocolListener listens for TCP connections, receives points in line protocol format and stores them in the sink
func NewTCPListener ¶
func NewTCPListener(sink chan<- lineprotocol.Point, address string) TCPListener
func (*TCPListener) Listen ¶
func (l *TCPListener) Listen() error
Listen loops endlessly, accepting tcp connections
Source Files
Click to show internal directories.
Click to hide internal directories.