pubsub

Documentation

Index

• func NewEventBus()
• type Event
• type EventBus
  • func (e *EventBus) AsyncPublish(event *Event)
  • func (e *EventBus) Publish(event *Event)
  • func (e *EventBus) Subscribe(topic string, o ObServer)
  • func (e *EventBus) UnSubscribe(topic string, o ObServer)
• type IEventBus
• type ObServer

Functions

func NewEventBus

func NewEventBus()

Types

type Event

type Event struct {
	Topic string
	Val   interface{}
}

type EventBus

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

var EventSystem EventBus

func (*EventBus) AsyncPublish

func (e *EventBus) AsyncPublish(event *Event)

func (*EventBus) Publish

func (e *EventBus) Publish(event *Event)

func (*EventBus) Subscribe

func (e *EventBus) Subscribe(topic string, o ObServer)

func (*EventBus) UnSubscribe

func (e *EventBus) UnSubscribe(topic string, o ObServer)

type IEventBus

type IEventBus interface {
	Subscribe(topic string, server ObServer)
	UnSubscribe(topic string, server ObServer)
	Publish(event *Event)
	AsyncPublish(event *Event)
}

type ObServer

type ObServer interface {
	OnChange(e *Event)
}