sse

type Event struct {
	ID        int64
	Data      EventData
	TTL       int64 `json:"-"`
	Timestamp int64 `json:"-"`
}

type EventData struct {
	Name    string      `json:"name"`
	Payload interface{} `json:"payload"`
}

type MemStorage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Service struct {
	// contains filtered or unexported fields
}

type Storage interface {
	// get all events in channel
	GetAllInChannel(channelID string) []Event
	// get events in a channel which has id greater than given one
	GetByLastID(channelID string, lastEventID int64) []Event
	// Add event to storage
	Add(channelID string, event Event) error
	// Delete event from storage
	Delete(channelID string, event Event) error
	// Deletes event which is older then given time from channel
	GC(eventMaxAge, gcPeriod string, wg *sync.WaitGroup) error
}