Documentation ¶
Index ¶
Constants ¶
const ( METADATA = "metadata" LABELS = "labels" APIVERSION = "apiVersion" KIND = "kind" NAME = "name" NAMESPACE = "namespace" EVENT = "event" // TODO: remove MESSAGE = "message" HEADER = "header" JOBID = "jobid" TYPEINT = "int" TYPEDOUBLE = "double" TYPEBOOL = "bool" TYPESTRING = "string" TYPELIST = "list" TYPEMAP = "map" WEBHOOK = "webhook" BODY = "body" IF = "if" SWITCH = "switch" DEFAULT = "default" EVENTSOURCE = "eventSource" INPUT = "input" OUTPUT = "output" SETTINGS = "settings" EVENTTRIGGERS = "eventTriggers" SYSTEMERROR = "systemError" FUNCTIONS = "functions" )
constants for parsing
const ( // IfFlag is flag for If statement IfFlag uint = 1 << iota // SwitchFlag is flag for switch statement SwitchFlag // DefaultFlag is flag for default statement DefaultFlag // BodyFlag is flag for body statement BodyFlag )
Variables ¶
This section is empty.
Functions ¶
func GetTimestamp ¶
func GetTimestamp() string
GetTimestamp Get timestamp. Timestamp format is UTC time expressed as:
YYYYMMDDHHMMSSL, where L is last digits in multiples of 1/10 second.
WARNING: This function may sleep up to 0.1 second per request if there are too many concurent requests
func ReadTriggerDefinition ¶
func ReadTriggerDefinition(fileName string, td *EventTriggerDefinition) error
ReadTriggerDefinition reads the event trigger definition from a file.
func SubstituteTemplate ¶
SubstituteTemplate replaces all values in a template.
Types ¶
type EventTriggerDefinition ¶
type EventTriggerDefinition struct { Setting []map[interface{}]interface{} // all settings EventTriggers map[string][]map[interface{}]interface{} // event source name to triggers Functions map[string]map[interface{}]interface{} // function name to function body }
EventTriggerDefinition represents an event trigger definition
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor contains the event trigger definition and the file it was loaded from
func NewProcessor ¶
func NewProcessor(env *endpoints.Environment) *Processor
NewProcessor creates a new trigger processor.
func (*Processor) Initialize ¶
Initialize initializes a Processor with the specified trigger directory
func (*Processor) ProcessMessage ¶
func (p *Processor) ProcessMessage(message map[string]interface{}, eventSource string) ([]map[string]interface{}, error)
ProcessMessage processes an event message.
func (*Processor) StartListeners ¶
StartListeners starts all event source listeners.