receiver

Documentation

Index

• func FileReader(ctx context.Context, path string, sendChannels *[]chan parser.Metric)
• func Prometheus(ctx context.Context, addr string, sendChannels *[]chan parser.Metric)
• func RawUDPServer(ctx context.Context, address string, sendChannels *[]chan parser.Metric)
• func TCPServer(ctx context.Context, addr string, sendChannels *[]chan parser.Metric)
• func UDPServer(ctx context.Context, address string, sendChannels *[]chan parser.Metric)

Functions

func FileReader

func FileReader(
	ctx context.Context,
	path string,
	sendChannels *[]chan parser.Metric,
)

FileReader loads from file

func Prometheus

func Prometheus(
	ctx context.Context,
	addr string,
	sendChannels *[]chan parser.Metric,
)

Prometheus http endpoint for Remote Write

func RawUDPServer

func RawUDPServer(
	ctx context.Context,
	address string,
	sendChannels *[]chan parser.Metric,
)

RawUDPServer binds to a port and listens to udp packets TODO filter by port currectly

func TCPServer

func TCPServer(
	ctx context.Context,
	addr string,
	sendChannels *[]chan parser.Metric,
)

TCPServer Create a tcp server on a given port TODO handle closed connections and EOF more gracefully

func UDPServer

func UDPServer(
	ctx context.Context,
	address string,
	sendChannels *[]chan parser.Metric,
)

UDPServer Create a udp server on a given port