events

Documentation

Index

• type Event
• type EventService
• type EventSystem
• type Listener
• type Publisher
  • func GetPublisher(sp view.ServiceProvider) (Publisher, error)
• type Service
  • func (s *Service) GetPublisher() Publisher
  • func (s *Service) GetSubscriber() Subscriber
• type Subscriber
  • func GetSubscriber(sp view.ServiceProvider) (Subscriber, error)
• type Subscribers
  • func NewSubscribers() *Subscribers
  • func (s *Subscribers) Delete(id string, wrapped interface{})
  • func (s *Subscribers) Get(id string, wrapped interface{}) (interface{}, bool)
  • func (s *Subscribers) Set(id string, wrapped, wrapper interface{})

Types

type Event

type Event interface {
	Topic() string
	Message() interface{}
}

type EventService

type EventService interface {
	GetPublisher() Publisher
	GetSubscriber() Subscriber
}

type EventSystem

type EventSystem interface {
	Subscriber
	Publisher
}

type Listener

type Listener interface {
	OnReceive(event Event)
}

type Publisher

type Publisher interface {
	Publish(event Event)
}

func GetPublisher

func GetPublisher(sp view.ServiceProvider) (Publisher, error)

type Service

type Service struct {
	EventSystem EventSystem
}

func (*Service) GetPublisher

func (s *Service) GetPublisher() Publisher

func (*Service) GetSubscriber

func (s *Service) GetSubscriber() Subscriber

type Subscriber

type Subscriber interface {
	Subscribe(topic string, receiver Listener)
	Unsubscribe(topic string, receiver Listener)
}

func GetSubscriber

func GetSubscriber(sp view.ServiceProvider) (Subscriber, error)

type Subscribers

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

Subscribers is a thread-safe map of subscribers. It is used to keep track of bindings between wrapped listeners and their wrappers.

func NewSubscribers

func NewSubscribers() *Subscribers

NewSubscribers returns a new instance of Subscribers.

func (*Subscribers) Delete

func (s *Subscribers) Delete(id string, wrapped interface{})

Delete removes the binding for the given id and wrapped listener

func (*Subscribers) Get

func (s *Subscribers) Get(id string, wrapped interface{}) (interface{}, bool)

Get returns the wrapper listener for the given id and wrapped listener.

func (*Subscribers) Set

func (s *Subscribers) Set(id string, wrapped, wrapper interface{})

Set sets a new binding between a wrapped listener and its wrapper. The binding is indexed by the passed id.