Documentation
¶
Index ¶
- func EELGetHandlersForEvent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]*HandlerConfiguration, error)
- func EELGetPublishers(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]EventPublisher, []error)
- func EELGetPublishersConcurrent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]EventPublisher, []error)
- func EELGetSettings(ctx Context) (*EelSettings, error)
- func EELInit(ctx Context)
- func EELNewHandlerFactory(ctx Context, configFolder string) (*HandlerFactory, []error)
- func EELSimpleEvalExpression(ctx Context, event string, expr string) (string, []error)
- func EELSimpleTransform(ctx Context, event string, transformation string, ...) (string, []error)
- func EELTransformEvent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]interface{}, []error)
- func EELTransformEventByHandlerName(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory, ...) ([]interface{}, []error)
- func EELTransformEventConcurrent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]interface{}, []error)
- func EELUpdateSettings(ctx Context, eelSettings *EelSettings) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EELGetHandlersForEvent ¶
func EELGetHandlersForEvent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]*HandlerConfiguration, error)
EELGetHandlersForEvent gets all handlers for a given event.
func EELGetPublishers ¶
func EELGetPublishers(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]EventPublisher, []error)
EELGetPublishers is similar to EELTransformEvent but return slice of publishers instead of slice of events.
func EELGetPublishersConcurrent ¶
func EELGetPublishersConcurrent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]EventPublisher, []error)
EELGetPublishersConcurrent is the concurrent version of EELGetPublishers. Useful when processing multiple expensive transformations at the same time (e.g. making heavy use of curl() function calls).
func EELGetSettings ¶
func EELGetSettings(ctx Context) (*EelSettings, error)
EELGetSettings get current settings for read / write
func EELNewHandlerFactory ¶
EELNewHandlerFactory creates handler factory for given folder with handler files.
func EELSimpleEvalExpression ¶
EELSingleTransform can work with raw JSON transformation or a transformation wrapped in a config handler. Transformation must yield single result or no result (if filtered).
func EELSimpleTransform ¶
func EELSimpleTransform(ctx Context, event string, transformation string, isTransformationByExample bool) (string, []error)
EELSingleTransform can work with raw JSON transformation or a transformation wrapped in a config handler. Transformation must yield single result or no result (if filtered).
func EELTransformEvent ¶
func EELTransformEvent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]interface{}, []error)
EELTransformEvent transforms single event based on set of configuration handlers. Can yield multiple results.
func EELTransformEventByHandlerName ¶
func EELTransformEventByHandlerName(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory, tenant string, name string) ([]interface{}, []error)
EELTransformEvent transforms single event based on set of configuration handlers. Can yield multiple results.
func EELTransformEventConcurrent ¶
func EELTransformEventConcurrent(ctx Context, event interface{}, eelHandlerFactory *HandlerFactory) ([]interface{}, []error)
EELTransformEventConcurrent is the concurrent version of EELTransformEvent. Useful when processing multiple expensive transformations at the same time (e.g. making heavy use of curl() function calls).
func EELUpdateSettings ¶
func EELUpdateSettings(ctx Context, eelSettings *EelSettings) error
EELGetSettings get current settings for read / write
Types ¶
This section is empty.
Source Files