goevents

type Bus interface {
	Publish(topic string, payload EventPayload) error
	AddHandler(handler EventHandler)
}

type Consumer interface {
	AddHandler(handler MessageHandler)
}

type Event struct {
	Topic       string      `json:"topic"`
	ID          string      `json:"id"`
	EmittedTime time.Time   `json:"emitted_time"`
	Payload     interface{} `json:"payload"`
}

type EventHandler interface {
	HandleEvent(event Event) error
}

type EventPayload interface{}

type Message interface {
	Decode() ([]byte, error)
}

type MessageHandler interface {
	HandleMessage(message Message) error
}

type Producer interface {
	Publish(topic string, body []byte) error
}