notifications

type Event ¶

type Event interface{}

Event is a publishable event

type EventTransform ¶

type EventTransform func(Event) Event

EventTransform if a fucntion transforms one kind of event to another

type Notifee ¶

type Notifee struct {
	Data       TopicData
	Subscriber *TopicDataSubscriber
}

Notifee is a topic data subscriber plus a set of data you want to add to any topics subscribed to (used to call SubscribeWithData to inject data when events for a given topic emit)

type Publisher ¶

type Publisher interface {
	Close(Topic)
	Publish(Topic, Event)
	Shutdown()
	Startup()
	Subscribable
}

Publisher is an publisher of events that can be subscribed to

func NewPublisher() Publisher

type Subscribable ¶

type Subscribable interface {
	Subscribe(topic Topic, sub Subscriber) bool
	Unsubscribe(sub Subscriber) bool
}

Subscribable is a stream that can be subscribed to

type Subscriber ¶

type Subscriber interface {
	OnNext(Topic, Event)
	OnClose(Topic)
}

Subscriber is a subscriber that can receive events

type Topic ¶

type Topic interface{}

Topic is a topic that events appear on

type TopicData ¶

type TopicData interface{}

TopicData is data added to every message broadcast on a topic

type TopicDataSubscriber ¶

type TopicDataSubscriber struct {
	Subscriber
	// contains filtered or unexported fields
}

func NewTopicDataSubscriber(sub Subscriber) *TopicDataSubscriber

func (m *TopicDataSubscriber) AddTopicData(id Topic, data TopicData)

func (m *TopicDataSubscriber) OnClose(topic Topic)

func (m *TopicDataSubscriber) OnNext(topic Topic, ev Event)