watchbus

Documentation

Index

• type EventBus
  • func NewEventBus(db drivers.DB) *EventBus
  • func (eb *EventBus) SetCondition(cond *operator.Condition)
  • func (eb *EventBus) Subscribe(topic, uuid string, ch chan *drivers.WatchEvent) error
  • func (eb *EventBus) Unsubscribe(topic, uuid string) error

Types

type EventBus

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

EventBus dispatch event

func NewEventBus

func NewEventBus(db drivers.DB) *EventBus

NewEventBus create event bus

func (*EventBus) SetCondition

func (eb *EventBus) SetCondition(cond *operator.Condition)

SetCondition set condition

func (*EventBus) Subscribe

func (eb *EventBus) Subscribe(topic, uuid string, ch chan *drivers.WatchEvent) error

Subscribe subscribe event for certain topic, here topic is database table

func (*EventBus) Unsubscribe

func (eb *EventBus) Unsubscribe(topic, uuid string) error

Unsubscribe unsubscribe topic