jtl

package

Go to main page

Versions in this module

v1

v1.42.0

Mar 28, 2022

Changes in this version

+ func HandleEvent(ctx Context, w http.ResponseWriter, r *http.Request) error

type HandlerConfiguration

+ func GetHandlerConfigurationFromFile(ctx Context, filepath string) (*HandlerConfiguration, []error)

+ func GetHandlerConfigurationFromJson(ctx Context, filepath string, handler HandlerConfiguration) (*HandlerConfiguration, []error)

v1.41.0

Jun 2, 2021

v1.40.0

May 10, 2021

v1.39.0

Dec 4, 2020

v1.38.0

Nov 16, 2020

v1.37.0

Mar 9, 2020

v1.36.0

Nov 25, 2019

v1.35.0

Nov 4, 2019

v1.34.0

Oct 17, 2019

Changes in this version

+ func GetApiBasePath() string

+ func SetApiBasePath(basePath string)

type AllTopicHandlersTest

+ BasePath string

type AstTest

+ BasePath string

+ type PluginTemplateParams struct

+ BasePath string

type TopicHandlerTest

+ BasePath string

v1.33.0

Sep 23, 2019

Changes in this version

+ func VersionHandler(w http.ResponseWriter, r *http.Request)

v1.32.0

Aug 9, 2019

Changes in this version

type HandlerConfiguration

+ func (h *HandlerConfiguration) DeepCopy() *HandlerConfiguration

v1.31.0

Jul 19, 2019

Changes in this version

type EventPublisher

+ GetPublisherConfigs func() map[string]string

+ SetPublisherConfigs func(configs map[string]string) error

type HandlerConfiguration

+ PublisherConfigs map[string]string

type HttpPublisher

+ func (p *HttpPublisher) GetPublisherConfigs() map[string]string

+ func (p *HttpPublisher) SetPublisherConfigs(configs map[string]string) error

type NullPublisher

+ func (p *NullPublisher) GetPublisherConfigs() map[string]string

+ func (p *NullPublisher) SetPublisherConfigs(configs map[string]string) error

v1.30.0

Jun 7, 2019

Changes in this version

type TopicHandlerTest

+ IsMBE bool

+ Match string

v1.29.0

May 17, 2019

Changes in this version

+ const CALLBACK_PARAM

+ const CONSUMER_KEY_PARAM

+ const NONCE_PARAM

+ const OAUTH_VERSION

+ const SESSION_HANDLE_PARAM

+ const SIGNATURE_METHOD_HMAC_SHA1

+ const SIGNATURE_METHOD_PARAM

+ const SIGNATURE_METHOD_RSA_SHA1

+ const SIGNATURE_PARAM

+ const TIMESTAMP_PARAM

+ const TOKEN_PARAM

+ const TOKEN_SECRET_PARAM

+ const VERIFIER_PARAM

+ const VERSION_PARAM

type EventPublisher

+ GetAsyncReplyTo func() map[string]string

+ GetPartition func() int32

+ GetTopic func() string

+ SetAsyncReplyTo func(replyTo map[string]string)

+ SetPartition func(int32)

+ SetTopic func(topic string)

type HandlerConfiguration

+ AsyncReplyTo string

+ KafkaTopic string

+ Partition string

type HttpPublisher

+ func (p *HttpPublisher) GetAsyncReplyTo() map[string]string

+ func (p *HttpPublisher) GetPartition() int32

+ func (p *HttpPublisher) GetTopic() string

+ func (p *HttpPublisher) SetAsyncReplyTo(replyTo map[string]string)

+ func (p *HttpPublisher) SetPartition(partition int32)

+ func (p *HttpPublisher) SetTopic(topic string)

type JDoc

+ func (j *JDoc) GetStringMapValueForExpression(ctx Context, path string) map[string]string

type NullPublisher

+ func (p *NullPublisher) GetAsyncReplyTo() map[string]string

+ func (p *NullPublisher) GetPartition() int32

+ func (p *NullPublisher) GetTopic() string

+ func (p *NullPublisher) SetAsyncReplyTo(replyTo map[string]string)

+ func (p *NullPublisher) SetPartition(partition int32)

+ func (p *NullPublisher) SetTopic(topic string)

+ type OAuthConsumer struct

+ func NewOAuthConsumer(serviceProvider string) *OAuthConsumer

+ func (c *OAuthConsumer) BaseParams(consumerKey string, additionalParams map[string]string) *OrderedParams

+ func (c *OAuthConsumer) GetOAuth1Header(ctx Context, method string, reqURL string) (string, error)

+ func (c *OAuthConsumer) LoadConfig(filename string, conf interface{}) error

+ func (c *OAuthConsumer) RequestString(method string, url string, params *OrderedParams) string

+ type OrderedParams struct

+ func NewOrderedParams() *OrderedParams

+ func (o *OrderedParams) Add(key, value string)

+ func (o *OrderedParams) AddUnescaped(key, value string)

+ func (o *OrderedParams) Clone() *OrderedParams

+ func (o *OrderedParams) Get(key string) string

+ func (o *OrderedParams) Keys() []string

+ func (o *OrderedParams) Len() int

+ func (o *OrderedParams) Less(i int, j int) bool

+ func (o *OrderedParams) Swap(i int, j int)

+ type SHA1Signer struct

+ func (s *SHA1Signer) Debug(enabled bool)

+ func (s *SHA1Signer) Sign(message string, tokenSecret string) (string, error)

+ func (s *SHA1Signer) SignatureMethod() string

v1.8.1

Apr 19, 2017

Changes in this version

+ const JPathOr

+ const JPathPrefix

+ const JPathSimple

+ const JPathSuffix

+ const JPathThisSelector

+ const JPathWildcard

+ var JPathSimpleReg *regexp.Regexp

+ func DummyEventHandler(w http.ResponseWriter, r *http.Request)

+ func EventHandler(w http.ResponseWriter, r *http.Request)

+ func FortyTwoHandler(w http.ResponseWriter, r *http.Request)

+ func FortyTwoJsonHandler(w http.ResponseWriter, r *http.Request)

+ func GetASTJsonHandler(w http.ResponseWriter, r *http.Request)

+ func HandlersTestHandler(w http.ResponseWriter, r *http.Request)

+ func LoadInboundPlugins(ctx Context)

+ func ManagePluginsHandler(w http.ResponseWriter, r *http.Request)

+ func ManagePluginsUIHandler(w http.ResponseWriter, r *http.Request)

+ func NilHandler(w http.ResponseWriter, r *http.Request)

+ func ParserDebugHandler(w http.ResponseWriter, r *http.Request)

+ func ParserDebugVizHandler(w http.ResponseWriter, r *http.Request)

+ func PluginConfigHandler(w http.ResponseWriter, r *http.Request)

+ func PostHandler(w http.ResponseWriter, r *http.Request)

+ func ProcessExpressionHandler(w http.ResponseWriter, r *http.Request)

+ func RegisterEventPublisher(newPublisher NewPublisher, protocol string)

+ func RegisterInboundPluginType(newPlugin NewInboundPlugin, pluginType string)

+ func ReloadConfig()

+ func ReloadConfigHandler(w http.ResponseWriter, r *http.Request)

+ func StatusHandler(w http.ResponseWriter, r *http.Request)

+ func TopicTestHandler(w http.ResponseWriter, r *http.Request)

+ func TraceLogConfigHandler(w http.ResponseWriter, r *http.Request)

+ func UnregisterEventPublisher(protocol string)

+ func VetHandler(w http.ResponseWriter, r *http.Request)

+ type AllTopicHandlersTest struct

+ AllHandlerNames []string

+ AllHandlers map[string]*HandlerConfiguration

+ CurrentHandler *HandlerConfiguration

+ Headers string

+ HeadersOut string

+ SelectedHandler string

+ type AstTest struct

+ CustomProperties string

+ ErrorMessage string

+ Expression string

+ Lists [][][]string

+ Message string

+ Result string

+ Transformations string

+ type EventPublisher interface

+ GetApi func() string

+ GetDebug func() bool

+ GetEndpoint func() string

+ GetErrors func() []error

+ GetHeaders func() map[string]string

+ GetPath func() string

+ GetPayload func() string

+ GetPayloadParsed func() *JDoc

+ GetProtocol func() string

+ GetUrl func() string

+ GetVerb func() string

+ Publish func() (string, error)

+ SetAuthInfo func(auth map[string]string)

+ SetDebug func(debug bool)

+ SetEndpoint func(endpoint string)

+ SetHeaders func(headers map[string]string)

+ SetPath func(path string)

+ SetPayload func(payload string)

+ SetPayloadParsed func(event *JDoc)

+ SetVerb func(verb string)

+ func NewEventPublisher(ctx Context, protocol string) EventPublisher

+ func NewHttpPublisher(ctx Context) EventPublisher

+ func NewNullPublisher(ctx Context) EventPublisher

+ type Filter struct

+ Filter map[string]interface{}

+ FilterAfterTransformation bool

+ IsFilterByExample bool

+ IsFilterInverted bool

+ LogParams map[string]string

+ type HandlerConfiguration struct

+ Active bool

+ AuthInfo map[string]string

+ CustomProperties map[string]interface{}

+ Endpoint interface{}

+ File string

+ Filter map[string]interface{}

+ FilterAfterTransformation bool

+ FilterIfFalse string

+ FilterIfTrue string

+ Filters []*Filter

+ HttpHeaders map[string]string

+ Info string

+ IsFilterByExample bool

+ IsFilterInverted bool

+ IsMatchByExample bool

+ IsTransformationByExample bool

+ Match map[string]interface{}

+ Name string

+ Path interface{}

+ Protocol string

+ TenantId string

+ TerminateOnMatch bool

+ Topic string

+ Transformation interface{}

+ Transformations map[string]*Transformation

+ Verb string

+ Version string

+ func GetCurrentHandlerConfig(ctx Context) *HandlerConfiguration

+ func (h *HandlerConfiguration) GetFilter() *JDoc

+ func (h *HandlerConfiguration) GetNamedTransformation() map[string]*Transformation

+ func (h *HandlerConfiguration) GetTransformation() *JDoc

+ func (h *HandlerConfiguration) IsValidTransformation(ctx Context, t *JDoc, istbe bool) (bool, string)

+ func (h *HandlerConfiguration) ProcessEvent(ctx Context, event *JDoc) ([]EventPublisher, error)

+ func (h *HandlerConfiguration) Save() error

+ type HandlerFactory struct

+ CustomHandlerMap map[string]map[string]*HandlerConfiguration

+ TopicHandlerMap map[string]map[string][]*HandlerConfiguration

+ func GetHandlerFactory(ctx Context) *HandlerFactory

+ func NewHandlerFactory(ctx Context, configFolders []string) (*HandlerFactory, []error)

+ func (hf *HandlerFactory) GetAllHandlers(ctx Context) []*HandlerConfiguration

+ func (hf *HandlerFactory) GetHandlerByName(ctx Context, tenant string, name string) *HandlerConfiguration

+ func (hf *HandlerFactory) GetHandlerConfigurationFromFile(ctx Context, filepath string) (*HandlerConfiguration, []error)

+ func (hf *HandlerFactory) GetHandlerConfigurationFromJson(ctx Context, filepath string, handler HandlerConfiguration) (*HandlerConfiguration, []error)

+ func (hf *HandlerFactory) GetHandlersForEvent(ctx Context, event *JDoc) []*HandlerConfiguration

+ func (hf *HandlerFactory) GetTopicHandlersForTenant(tenantId string, topic string) []*HandlerConfiguration

+ type HttpPublisher struct

+ func (p *HttpPublisher) GetApi() string

+ func (p *HttpPublisher) GetDebug() bool

+ func (p *HttpPublisher) GetEndpoint() string

+ func (p *HttpPublisher) GetErrors() []error

+ func (p *HttpPublisher) GetHeaders() map[string]string

+ func (p *HttpPublisher) GetPath() string

+ func (p *HttpPublisher) GetPayload() string

+ func (p *HttpPublisher) GetPayloadParsed() *JDoc

+ func (p *HttpPublisher) GetProtocol() string

+ func (p *HttpPublisher) GetUrl() string

+ func (p *HttpPublisher) GetVerb() string

+ func (p *HttpPublisher) Publish() (string, error)

+ func (p *HttpPublisher) SetAuthInfo(auth map[string]string)

+ func (p *HttpPublisher) SetDebug(debug bool)

+ func (p *HttpPublisher) SetEndpoint(endpoint string)

+ func (p *HttpPublisher) SetHeaders(headers map[string]string)

+ func (p *HttpPublisher) SetPath(path string)

+ func (p *HttpPublisher) SetPayload(payload string)

+ func (p *HttpPublisher) SetPayloadParsed(event *JDoc)

+ func (p *HttpPublisher) SetVerb(verb string)

+ type InboundPlugin interface

+ GetSettings func() *PluginSettings

+ IsActive func() bool

+ StartPlugin func(Context)

+ StopPlugin func(Context)

+ func GetInboundPluginByName(name string) InboundPlugin

+ func GetInboundPluginByType(pluginType string) InboundPlugin

+ func NewStdinPlugin(settings *PluginSettings) InboundPlugin

+ func NewWebhookPlugin(settings *PluginSettings) InboundPlugin

+ type JDoc struct

+ func NewJDocFromFile(filePath string) (*JDoc, error)

+ func NewJDocFromInterface(o interface{}) (*JDoc, error)

+ func NewJDocFromMap(m map[string]interface{}) (*JDoc, error)

+ func NewJDocFromString(doc string) (*JDoc, error)

+ func (j *JDoc) ApplyTransformation(ctx Context, transformation *JDoc) *JDoc

+ func (j *JDoc) ApplyTransformationByExample(ctx Context, tf *JDoc) *JDoc

+ func (j *JDoc) Equals(j2 *JDoc) bool

+ func (j *JDoc) EvalPath(ctx Context, path string) interface{}

+ func (j *JDoc) GetFlatObject() map[string]interface{}

+ func (j *JDoc) GetFloatValue(path string) float64

+ func (j *JDoc) GetFloatValueForExpression(ctx Context, expr string) float64

+ func (j *JDoc) GetIntValue(path string) int

+ func (j *JDoc) GetIntValueForExpression(ctx Context, expr string) int

+ func (j *JDoc) GetMapValue(path string) map[string]interface{}

+ func (j *JDoc) GetMapValueForExpression(ctx Context, expr string) map[string]interface{}

+ func (j *JDoc) GetNumberValue(path string) float64

+ func (j *JDoc) GetNumberValueForExpression(ctx Context, expr string) float64

+ func (j *JDoc) GetOriginalObject() interface{}

+ func (j *JDoc) GetSliceValue(path string) []interface{}

+ func (j *JDoc) GetSliceValueForExpression(ctx Context, expr string) []interface{}

+ func (j *JDoc) GetStringSliceValue(path string) []string

+ func (j *JDoc) GetStringSliceValueForExpression(ctx Context, expr string) []string

+ func (j *JDoc) GetStringValue(path string) string

+ func (j *JDoc) GetStringValueForExpression(ctx Context, expr string) string

+ func (j *JDoc) GetValue(path string) interface{}

+ func (j *JDoc) GetValueForExpression(ctx Context, expr string) interface{}

+ func (j *JDoc) HasPath(path string) bool

+ func (j *JDoc) IsValidPath(expr string) bool

+ func (j *JDoc) IsValidPathExpression(ctx Context, expr string) bool

+ func (j *JDoc) ListAllPaths() []string

+ func (j *JDoc) MatchesPattern(pattern *JDoc) (bool, int)

+ func (j *JDoc) ParseExpression(ctx Context, expr interface{}) interface{}

+ func (j *JDoc) String() string

+ func (j *JDoc) StringPretty() string

+ func (j *JDoc) VetExpression(ctx Context, expr interface{}) string

+ type JExprD3Node struct

+ Children []*JExprD3Node

+ Name string

+ Parent string

+ type JExprItem struct

+ func NewJExpr(expr string) (*JExprItem, error)

+ func (a *JExprItem) CollapseNextLeafDebug(ctx Context, doc *JDoc) bool

+ func (a *JExprItem) Execute(ctx Context, doc *JDoc) interface{}

+ func (a *JExprItem) ExecuteDebug(ctx Context, doc *JDoc) (interface{}, [][][]string)

+ func (a *JExprItem) GetD3Json(cur *JExprD3Node) *JExprD3Node

+ type JFunction struct

+ func NewFunction(fn string) *JFunction

+ func (f *JFunction) ExecuteFunction(ctx Context, doc *JDoc, params []string) interface{}

+ type NewInboundPlugin func(*PluginSettings) InboundPlugin

+ type NewPublisher func(ctx Context) EventPublisher

+ type NullPublisher struct

+ func (p *NullPublisher) GetApi() string

+ func (p *NullPublisher) GetDebug() bool

+ func (p *NullPublisher) GetEndpoint() string

+ func (p *NullPublisher) GetErrors() []error

+ func (p *NullPublisher) GetHeaders() map[string]string

+ func (p *NullPublisher) GetPath() string

+ func (p *NullPublisher) GetPayload() string

+ func (p *NullPublisher) GetPayloadParsed() *JDoc

+ func (p *NullPublisher) GetProtocol() string

+ func (p *NullPublisher) GetUrl() string

+ func (p *NullPublisher) GetVerb() string

+ func (p *NullPublisher) Publish() (string, error)

+ func (p *NullPublisher) SetAuthInfo(auth map[string]string)

+ func (p *NullPublisher) SetDebug(debug bool)

+ func (p *NullPublisher) SetEndpoint(endpoint string)

+ func (p *NullPublisher) SetHeaders(headers map[string]string)

+ func (p *NullPublisher) SetPath(path string)

+ func (p *NullPublisher) SetPayload(payload string)

+ func (p *NullPublisher) SetPayloadParsed(event *JDoc)

+ func (p *NullPublisher) SetVerb(verb string)

+ type PluginConfigList []*PluginSettings

+ func GetPluginConfigList(ctx Context) PluginConfigList

+ type PluginSettings struct

+ Active bool

+ AutoStart bool

+ ExitOnErr bool

+ Name string

+ Parameters map[string]interface{}

+ RestartOk bool

+ Stats PluginStats

+ Type string

+ type PluginStats struct

+ MessageCount uint64

+ MessagesPerMinute uint64

+ MessagesPerSecond uint64

+ Misc map[string]interface{}

+ type StdinPlugin struct

+ Settings *PluginSettings

+ ShuttingDown bool

+ func (p *StdinPlugin) GetSettings() *PluginSettings

+ func (p *StdinPlugin) IsActive() bool

+ func (p *StdinPlugin) StartPlugin(ctx Context)

+ func (p *StdinPlugin) StartStdInConsumer(ctx Context, r io.Reader)

+ func (p *StdinPlugin) StopPlugin(ctx Context)

+ type TopicHandlerTest struct

+ CustomProperties string

+ ErrorMessage string

+ Filters string

+ IsTBE bool

+ Message string

+ Path interface{}

+ PathExpression string

+ Response string

+ Transformation string

+ Transformations string

+ type TraceLogger struct

+ EventChannel chan *JDoc

+ File *os.File

+ Settings *EelTraceLogParams

+ Writer *bufio.Writer

+ func NewTraceLogger(ctx Context, config *EelSettings) *TraceLogger

+ func (t *TraceLogger) CloseTraceLog(ctx Context)

+ func (t *TraceLogger) TraceLog(ctx Context, event *JDoc, incoming bool)

+ type Transformation struct

+ IsTransformationByExample bool

+ Transformation interface{}

+ func (t *Transformation) GetTransformation() *JDoc

+ func (t *Transformation) SetTransformation(tf *JDoc)

+ type WebhookPlugin struct

+ Settings *PluginSettings

+ ShuttingDown bool

+ func (p *WebhookPlugin) GetSettings() *PluginSettings

+ func (p *WebhookPlugin) IsActive() bool

+ func (p *WebhookPlugin) StartPlugin(ctx Context)

+ func (p *WebhookPlugin) StartWebhookConsumer(ctx Context)

+ func (p *WebhookPlugin) StopPlugin(ctx Context)

+ type WorkDispatcher struct

+ WorkQueue chan *WorkRequest

+ WorkerQueue chan chan *WorkRequest

+ func GetWorkDispatcher(ctx Context) *WorkDispatcher

+ func NewWorkDispatcher(nworkers int, queueDepth int) *WorkDispatcher

+ func (disp *WorkDispatcher) Start(ctx Context)

+ func (disp *WorkDispatcher) Stop(ctx Context)

+ type WorkRequest struct

+ Ctx Context

+ Event *JDoc

+ Raw string

+ type Worker struct

+ WorkerQueue chan chan *WorkRequest

+ func NewWorker(id int, workerQueue chan chan *WorkRequest) *Worker

+ func (w *Worker) Start()

+ func (w *Worker) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL