bus

type Bus ¶

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

The Bus allows publish-subscribe-style communication between components

func NewBus() *Bus

func (b *Bus) Publish(topic Topic, message ...Message) (Future, error)

func (b *Bus) Subscribe(topic Topic, listener MessageListener) error

type ChType ¶

type ChType int

var (
	ChTypeUnidirectional ChType = 0
	ChTypeBidirectional  ChType = 1
)

type Channel ¶

type Channel chan Event

type Event ¶

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

type Future ¶

type Future interface {
	Get() (Message, error)
	GetAll() ([]Message, error)
}

type Message ¶

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

Message is send on the bus to all subscribed listeners

func NewMessage(id MessageID, data interface{}) Message

func (m Message) Data() interface{}

func (m Message) ID() MessageID

type MessageID ¶

type MessageID uint64

type MessageListener ¶

type MessageListener interface {
	Rev(message Message) Message
}

MessageListener is the signature of functions that can handle an EventMessage.

type Payload ¶

type Payload interface{}

Payload represents a simple data

type Publisher ¶

type Publisher interface {
	Publish(topic Topic, message ...Message) (Future, error)
}

type Subscriber ¶

type Subscriber interface {
	Subscribe(topic Topic, listener MessageListener) error
}

type Topic ¶

type Topic struct {
	ID   string
	Type ChType
}

func BiTopic(ID string) Topic

func UniTopic(ID string) Topic