event

Documentation

Index

• Constants
• func Match(pattern, name string) (matched bool)
• func MatchSimple(pattern, name string) bool
• type DefaultEventBus
  • func (eb *DefaultEventBus) Close() error
  • func (eb *DefaultEventBus) CloseTopic(topic common.TopicType)
  • func (eb *DefaultEventBus) HasCallback(topic common.TopicType) bool
  • func (eb *DefaultEventBus) Publish(topic common.TopicType, args ...interface{})
  • func (eb *DefaultEventBus) Subscribe(topic common.TopicType, fn interface{}) (string, error)
  • func (eb *DefaultEventBus) SubscribeSync(topic common.TopicType, fn interface{}) (string, error)
  • func (eb *DefaultEventBus) Unsubscribe(topic common.TopicType, handler string) error
• type EventBus
  • func GetEventBus(id string) EventBus
  • func New() EventBus
  • func NewEventBus(queueSize int) EventBus
  • func SimpleEventBus() EventBus

Constants

const (

	//EventBus params
	EventBusWaitingQueueSize = 102400
)

Functions

func Match

func Match(pattern, name string) (matched bool)

Match - finds whether the text matches/satisfies the pattern string. supports '*' and '?' wildcards in the pattern string. unlike path.Match(), considers a path as a flat name space while matching the pattern. The difference is illustrated in the example here https://play.golang.org/p/Ega9qgD4Qz .

func MatchSimple

func MatchSimple(pattern, name string) bool

MatchSimple - finds whether the text matches/satisfies the pattern string. supports only '*' wildcard in the pattern. considers a file system path as a flat name space.

Types

type DefaultEventBus

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

DefaultEventBus

func (*DefaultEventBus) Close

func (eb *DefaultEventBus) Close() error

func (*DefaultEventBus) CloseTopic

func (eb *DefaultEventBus) CloseTopic(topic common.TopicType)

Close unsubscribe all handlers from given topic

func (*DefaultEventBus) HasCallback

func (eb *DefaultEventBus) HasCallback(topic common.TopicType) bool

HasCallback returns true if exists any callback subscribed to the topic.

func (*DefaultEventBus) Publish

func (eb *DefaultEventBus) Publish(topic common.TopicType, args ...interface{})

Publish executes callback defined for a topic. Any additional argument will be transferred to the callback.

func (*DefaultEventBus) Subscribe

func (eb *DefaultEventBus) Subscribe(topic common.TopicType, fn interface{}) (string, error)

Subscribe subscribes to a topic. Returns error if `fn` is not a function.

func (*DefaultEventBus) SubscribeSync

func (eb *DefaultEventBus) SubscribeSync(topic common.TopicType, fn interface{}) (string, error)

func (*DefaultEventBus) Unsubscribe

func (eb *DefaultEventBus) Unsubscribe(topic common.TopicType, handler string) error

Unsubscribe removes callback defined for a topic. Returns error if there are no callbacks subscribed to the topic.

type EventBus

type EventBus interface {
	io.Closer
	// contains filtered or unexported methods
}

func GetEventBus

func GetEventBus(id string) EventBus

func New

func New() EventBus

New returns new DefaultEventBus with empty handlers.

func NewEventBus

func NewEventBus(queueSize int) EventBus

func SimpleEventBus

func SimpleEventBus() EventBus