chore(notifications): define a queue interface for the new notification system
Define a queue interface that allows queueing and dequeuing items - we need a new type that will contain the types Event
and Sink
.
Proposal
- Create a new
type Notification struct
that has at least anEvent
and aSink
- Define a
type Queue interface
that can:Queue(notification *Notification)
Dequeue(notificationID interface{})
Items() []*Notification
- Add an in-memory queue that implements the
Queue
interface.
Edited by Jaime Martinez