utils

Documentation

Index

• func Generate(kafkaProducer *kafka.Producer, cfg *config.Config)
• func GenerateRandomLogs(cfg *config.Config, stop chan os.Signal)
• func LiveTail(config *config.Livetail, sigchan chan os.Signal)

Functions

func Generate

func Generate(kafkaProducer *kafka.Producer, cfg *config.Config)

Generate generates a new log with random data and produces it to a random topic via the kafka producer provided to it.

func GenerateRandomLogs

func GenerateRandomLogs(cfg *config.Config, stop chan os.Signal)

GenerateRandomLogs generates logs every in k seconds in a choice of numTopics topics, simulating how many processes would produce logs in ra real-life scenario.

func LiveTail

func LiveTail(config *config.Livetail, sigchan chan os.Signal)

LiveTail is a real-time, bridge between Kafka and a logging medium that allows the observation as they are occuring of newly ingested messages.