event

Documentation

Index

• func GlobalSyncEvent(param interface{})
• func PublishSyncEvent(name string, message Message)
• func RegisterSyncEvent(name string, callback func(Message))
• type AsyncEvent
• type DataChannel
• type DataEvent
• type DatachannelSlice
• type Driver
  • func (a *Driver) OnEvent(param interface{})
• type EventBus
  • func (eb *EventBus) PublishAsyncEvent(topic string, data interface{})
  • func (eb *EventBus) SubscribeAsyncEvent(topic string, ch DataChannel)
• type EventFuncs
  • func (e *EventFuncs) NewAsyncEvent(topic string)
  • func (e *EventFuncs) PrintDataAsyncEvent(topic string, data DataEvent)
  • func (e *EventFuncs) PublishAsyncEvent(topic string, message interface{})
  • func (e *EventFuncs) RegisterAsyncEvent(topic string, chanEvent chan DataEvent)
• type Message
• type SyncEvent

Functions

func GlobalSyncEvent

func GlobalSyncEvent(param interface{})

func PublishSyncEvent

func PublishSyncEvent(name string, message Message)

func RegisterSyncEvent

func RegisterSyncEvent(name string, callback func(Message))

Register the events, providing the event name and the callback function

Types

type AsyncEvent

type AsyncEvent interface {
	NewAsyncEvent(topic string)
	RegisterAsyncEvent(topic string)
	PrintDataAsyncEvent(topic string, data DataEvent)
	PublishAsyncEvent(topic string, data interface{})
}

type DataChannel

type DataChannel chan DataEvent

type DataEvent

type DataEvent struct {
	Data  interface{}
	Topic string
}

type DatachannelSlice

type DatachannelSlice []DataChannel

type Driver

type Driver struct {
}

func (*Driver) OnEvent

func (a *Driver) OnEvent(param interface{})

Add an event-processing function for function

type EventBus

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

func (*EventBus) PublishAsyncEvent

func (eb *EventBus) PublishAsyncEvent(topic string, data interface{})

func (*EventBus) SubscribeAsyncEvent

func (eb *EventBus) SubscribeAsyncEvent(topic string, ch DataChannel)

type EventFuncs

type EventFuncs struct {
}

func (*EventFuncs) NewAsyncEvent

func (e *EventFuncs) NewAsyncEvent(topic string)

func (*EventFuncs) PrintDataAsyncEvent

func (e *EventFuncs) PrintDataAsyncEvent(topic string, data DataEvent)

func (*EventFuncs) PublishAsyncEvent

func (e *EventFuncs) PublishAsyncEvent(topic string, message interface{})

func (*EventFuncs) RegisterAsyncEvent

func (e *EventFuncs) RegisterAsyncEvent(topic string, chanEvent chan DataEvent)

type Message

type Message struct {
	Type string
	Data []byte
}

type SyncEvent

type SyncEvent interface {
	OnEvent(param interface{})
	GlobalSyncEvent(param interface{})
	PublishSyncEvent(name string, message Message)
	RegisterSyncEvent(name string, callback func(Message))
}