Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTopic ¶
CreateTopic creates Kafka topic to produces website checks onto if it does not exist.
Types ¶
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
Producer generates the website checks into a Kafka topic
func NewProducer ¶
NewProducer handles the creation of the async producers and associated GoRoutines
func (*Producer) Produce ¶
func (p *Producer) Produce(wp domain.WebsiteParams, wr domain.WebsiteResult) error
Produce produces a website check
Click to show internal directories.
Click to hide internal directories.