event

Documentation

Index

• Constants
• func HasListener(eventType string) bool
• func Post(eventType string, event interface{})
• func PublishEnabled() bool
• func RegisterListener(name string, listener Listener, eventTypes []string) error
• func UnRegisterListener(name string, eventTypes []string)
• type Context
  • func (ec *Context) GetEvent() interface{}
  • func (ec *Context) GetEventType() string
• type Emitter
  • func (te *Emitter) HasListeners() bool
  • func (te *Emitter) Publish(evtCtx *Context)
  • func (te *Emitter) RegisterListener(name string, listener Listener) error
  • func (te *Emitter) UnRegisterListener(name string) error
• type Listener

Constants

const (
	EnvPublishAuditEventsKey = "FLOGO_PUBLISH_AUDIT_EVENTS"
)

Functions

func HasListener

func HasListener(eventType string) bool

func Post

func Post(eventType string, event interface{})

Puts event with given type and data on the channel

func PublishEnabled

func PublishEnabled() bool

func RegisterListener

func RegisterListener(name string, listener Listener, eventTypes []string) error

Registers listener for given event types

func UnRegisterListener

func UnRegisterListener(name string, eventTypes []string)

Unregister event listener for given event types . To unregister from all event types, set eventTypes to nil

Types

type Context

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

Context is a wrapper over specific event

func (*Context) GetEvent

func (ec *Context) GetEvent() interface{}

Returns wrapped event data

func (*Context) GetEventType

func (ec *Context) GetEventType() string

Returns event type

type Emitter

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

func (*Emitter) HasListeners

func (te *Emitter) HasListeners() bool

func (*Emitter) Publish

func (te *Emitter) Publish(evtCtx *Context)

func (*Emitter) RegisterListener

func (te *Emitter) RegisterListener(name string, listener Listener) error

func (*Emitter) UnRegisterListener

func (te *Emitter) UnRegisterListener(name string) error

type Listener

type Listener interface {
	// Called when matching event occurs
	HandleEvent(*Context) error
}