notifications

package

v0.14.6 Latest Latest Go to latest Published: Apr 22, 2023 License: Apache-2.0, MIT Imports: 2 Imported by: 5

Details

This section is empty.

This section is empty.

This section is empty.

type Event interface{}

Event is a publishable event

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

NewPublisher returns a new message event publisher

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

Subscribable is a stream that can be subscribed to

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

Subscriber is a subscriber that can receive events

type Topic interface{}

Topic is a topic that events appear on

type TopicData interface{}

TopicData is data added to every message broadcast on a topic