event

Documentation

Index

• Constants
• func NewEventManager(engine model.Elasticfeed) model.EventManager
• type Event
  • func NewEvent(data interface{}) *Event
• type EventManager
  • func (this *EventManager) GetEventsMap() map[string]interface{}
  • func (this *EventManager) Init()
  • func (this *EventManager) InstallSchedule(name string, spec string, cb func() error) error
  • func (this *EventManager) Off(event string)
  • func (this *EventManager) On(name string, callback func(event *Event))
  • func (this *EventManager) Trigger(name string, data interface{})

Constants

const (
	EVENT_STORING      = "storing"
	EVENT_PROCESSING   = "processing"
	EVENT_DISTRIBUTING = "distributing"
	EVENT_LEARNING     = "learning"

	EVENT_STORING_CREATE_ENTRY       = "create-entry"
	EVENT_STORING_CREATE_VIEWER      = "create-viewer"
	EVENT_PROCESSING_FEED_MAINTAINER = "feed-maintainer"
	EVENT_PROCESSING_SENSOR_UPDATE   = "sensor-update"
	EVENT_DISTRIBUTING_PUSH_ENTRY    = "push-entry"
	EVENT_LEARNING_CREATE_METRIC     = "create-metric"
)

Functions

func NewEventManager

func NewEventManager(engine model.Elasticfeed) model.EventManager

Types

type Event

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

func NewEvent

func NewEvent(data interface{}) *Event

type EventManager

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

func (*EventManager) GetEventsMap

func (this *EventManager) GetEventsMap() map[string]interface{}

func (*EventManager) Init

func (this *EventManager) Init()

func (*EventManager) InstallSchedule

func (this *EventManager) InstallSchedule(name string, spec string, cb func() error) error

func (*EventManager) Off

func (this *EventManager) Off(event string)

func (*EventManager) On

func (this *EventManager) On(name string, callback func(event *Event))

func (*EventManager) Trigger

func (this *EventManager) Trigger(name string, data interface{})