handler

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
  • func HandlePrometheusConnection(parseChan chan parser.PromMetric) *PrometheusRemoteWrite
  • func (rcv *PrometheusRemoteWrite) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func HandleFile

func HandleFile(
	ctx context.Context,
	file io.Reader,
	parseChan chan string,
)

HandleFile Loads a file and reads line by line

func HandleRawUDPPacket

func HandleRawUDPPacket(
	ctx context.Context,
	rawData []byte,
	parseChan chan string,
)

HandleRawUDPPacket process udp packets in the form of byte arrays

func HandleTCPConnection

func HandleTCPConnection(
	ctx context.Context,
	conn net.Conn,
	parseChan chan string,
)

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

func RegisterMetrics

func RegisterMetrics()

RegisterMetrics for collection

Types

type PrometheusRemoteWrite

type PrometheusRemoteWrite struct {
	http.Handler
	// contains filtered or unexported fields
}

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)