shared

Documentation

Index

• func CheckElasticsearchDocuments(indexName string, expected int)
• func ConsumeTestData(topic string, expected int)
• func ProduceTestData(topic string, count int)

Functions

func CheckElasticsearchDocuments

func CheckElasticsearchDocuments(indexName string, expected int)

CheckElasticsearchDocuments fetches all documents from the passed index and checks for the expected number of matches.

func ConsumeTestData

func ConsumeTestData(topic string, expected int)

ConsumeTestData consumes data from the passed topic, stopping when it reaches the expected number of records or times out.

func ProduceTestData

func ProduceTestData(topic string, count int)

ProduceTestData generates syslog entries onto the test topic.