event

Documentation

Index

• type Event
  • func NewEvent(id, source, destination string, header Values, data interface{}) Event
• type Hub
  • func NewHub() Hub
• type ID2ObserverFuncMap
• type ID2ObserverMap
• type Observer
• type ObserverFunc
• type ObserverList
• type Result
  • func NewResult(id, source, destination string) Result
• type SimpleObserver
  • func NewSimpleObserver(id string, hub Hub) SimpleObserver
• type Values
  • func NewValues() Values
  • func (s Values) Get(key string) interface{}
  • func (s Values) GetBool(key string) bool
  • func (s Values) GetInt(key string) int
  • func (s Values) GetString(key string) string
  • func (s Values) Set(key string, value interface{})

Types

type Event

type Event interface {
	ID() string
	Source() string
	Destination() string
	Header() Values
	Data() interface{}
	Match(pattern string) bool
}

func NewEvent

func NewEvent(id, source, destination string, header Values, data interface{}) Event

type Hub

type Hub interface {
	Subscribe(eventID string, observer Observer)
	Unsubscribe(eventID string, observer Observer)
	Post(event Event)
	Send(event Event) Result
	Call(event Event) Result
	Terminate()
}

func NewHub

func NewHub() Hub

type ID2ObserverFuncMap

type ID2ObserverFuncMap map[string]ObserverFunc

type ID2ObserverMap

type ID2ObserverMap map[string]ObserverList

type Observer

type Observer interface {
	ID() string
	Notify(event Event, result Result) bool
}

type ObserverFunc

type ObserverFunc func(Event, Result) bool

type ObserverList

type ObserverList []Observer

type Result

type Result interface {
	Error() error
	Set(data interface{}, err error)
	Get() (interface{}, error)
}

func NewResult

func NewResult(id, source, destination string) Result

type SimpleObserver

type SimpleObserver interface {
	Observer
	Subscribe(eventID string, observerFunc ObserverFunc)
	Unsubscribe(eventID string)
}

func NewSimpleObserver

func NewSimpleObserver(id string, hub Hub) SimpleObserver

type Values

type Values map[string]interface{}

func NewValues

func NewValues() Values

func (Values) Get

func (s Values) Get(key string) interface{}

func (Values) GetBool

func (s Values) GetBool(key string) bool

func (Values) GetInt

func (s Values) GetInt(key string) int

func (Values) GetString

func (s Values) GetString(key string) string

func (Values) Set

func (s Values) Set(key string, value interface{})