Documentation ¶
Index ¶
- func HandleFile(ctx context.Context, file io.Reader, parseChan chan string)
- func HandleRawUDPPacket(ctx context.Context, rawData []byte, parseChan chan string)
- func HandleTCPConnection(ctx context.Context, conn net.Conn, parseChan chan string)
- func HandleUDPConnection(ctx context.Context, conn net.PacketConn, parseChan chan string)
- func RegisterMetrics()
- type PrometheusRemoteWrite
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HandleFile ¶
HandleFile Loads a file and reads line by line
func HandleRawUDPPacket ¶
HandleRawUDPPacket process udp packets in the form of byte arrays
func HandleTCPConnection ¶
HandleTCPConnection process messages from tcp connection
func HandleUDPConnection ¶
func HandleUDPConnection( ctx context.Context, conn net.PacketConn, parseChan chan string, )
HandleUDPConnection processes messages from udp connections
Types ¶
type PrometheusRemoteWrite ¶
PrometheusRemoteWrite https handler
func HandlePrometheusConnection ¶
func HandlePrometheusConnection( parseChan chan parser.PromMetric, ) *PrometheusRemoteWrite
HandlePrometheusConnection returns http hander for prometheus remote writes
func (*PrometheusRemoteWrite) ServeHTTP ¶
func (rcv *PrometheusRemoteWrite) ServeHTTP(w http.ResponseWriter, r *http.Request)
Click to show internal directories.
Click to hide internal directories.