Ammending Event Bus Api to remove Pointers
continuous-integration/drone/push Build is passing Details
continuous-integration/drone/pr Build is failing Details

This commit is contained in:
Sarah Jamie Lewis 2021-03-24 13:09:07 -07:00
parent 5d1d057d6a
commit 044f726ae4
2 changed files with 7 additions and 6 deletions

View File

@ -19,7 +19,7 @@ type simpleQueue struct {
// the event.Manager.
type Queue interface {
Publish(event Event)
Next() *Event
Next() Event
Shutdown()
OutChan() <-chan Event
Len() int
@ -52,9 +52,9 @@ func (sq *simpleQueue) Len() int {
}
// Next returns the next available event from the front of the queue
func (sq *simpleQueue) Next() *Event {
func (sq *simpleQueue) Next() Event {
event := <-sq.eventChannel
return &event
return event
}
// Shutdown closes our eventChannel
@ -83,9 +83,9 @@ func (iq *queue) OutChan() <-chan Event {
}
// Out returns the next available event from the front of the queue
func (iq *queue) Next() *Event {
func (iq *queue) Next() Event {
event := <-iq.infChan.Out()
return &event
return event
}
func (iq *queue) Len() int {

View File

@ -7,7 +7,8 @@ import (
"sync"
)
// Event is a structure which binds a given set of data to an Type
// Events are the core struct passed around between various subsystems, they consist of a type which can be
// filtered on, an event ID for tracing and a map of Fields to string values.
type Event struct {
EventType Type
EventID string