package
0.0.0-20211226042609-cf9cf47646e2
Repository: https://github.com/jeffrisberg/liveprojectasynchronouseventswithkafka.git
Documentation: pkg.go.dev

# Functions

EventExists will check to see if an event has already been processed.
HandleError will publish an error event to Kafka.
Health returns a HTTP 200 status code indicating the service is alive.
InsertEvent will insert a row into the processed_events table to indicate an event was processed.
NewDB returns a default localhost reference to a DB.
ReceiveOrder handler will accept an order, validate the payload and publish an OrderReceived event to Kafka.
Root returns a HTTP 200 status code.

# Structs

DB represents an interaction with a database.
Server represents the web server hosting the service.