Documentation
¶
Index ¶
- func NewContextParseFilter(c *config.Config) (pipeline.Filter, error)
- func NewContextRegexReplace(c *config.Config) (filter pipeline.Filter, err error)
- func NewCookieFilter(c *config.Config) (pipeline.Filter, error)
- func NewElasticsearchLookupFilter(c *config.Config) (pipeline.Filter, error)
- func NewRequestBodyJsonDel(c *config.Config) (pipeline.Filter, error)
- func NewRequestBodyJsonSet(c *config.Config) (pipeline.Filter, error)
- func NewRequestBodyRegexReplace(c *config.Config) (filter pipeline.Filter, err error)
- func NewResponseBodyRegexReplace(c *config.Config) (filter pipeline.Filter, err error)
- func NewResponseHeaderFormatFilter(c *config.Config) (pipeline.Filter, error)
- func NewSetContext(c *config.Config) (pipeline.Filter, error)
- func NewSetHostname(c *config.Config) (pipeline.Filter, error)
- func NewSetRequestHeader(c *config.Config) (pipeline.Filter, error)
- func NewSetRequestQueryArgs(c *config.Config) (pipeline.Filter, error)
- func NewSetResponse(c *config.Config) (pipeline.Filter, error)
- func NewSetResponseHeader(c *config.Config) (pipeline.Filter, error)
- type ContextParseFilter
- type ContextRegexReplace
- type Cookie
- type ElasticsearchLookup
- type RequestBodyJsonDel
- type RequestBodyJsonSet
- type RequestBodyRegexReplace
- type RequestTemplate
- type ResponseBodyRegexReplace
- type ResponseHeaderFormatFilter
- type SetContext
- type SetHostname
- type SetRequestHeader
- type SetRequestQueryArgs
- type SetResponse
- type SetResponseHeader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContextRegexReplace ¶
func NewSetRequestQueryArgs ¶
Types ¶
type ContextParseFilter ¶
type ContextParseFilter struct {
SkipError bool `config:"skip_error"`
Context string `config:"context"`
Pattern string `config:"pattern"`
Group string `config:"group"`
// contains filtered or unexported fields
}
func (*ContextParseFilter) Filter ¶
func (filter *ContextParseFilter) Filter(ctx *fasthttp.RequestCtx)
func (*ContextParseFilter) Name ¶
func (filter *ContextParseFilter) Name() string
type ContextRegexReplace ¶
type ContextRegexReplace struct {
Context string `config:"context"`
Pattern string `config:"pattern"`
To string `config:"to"`
// contains filtered or unexported fields
}
func (*ContextRegexReplace) Filter ¶
func (filter *ContextRegexReplace) Filter(ctx *fasthttp.RequestCtx)
func (*ContextRegexReplace) Name ¶
func (filter *ContextRegexReplace) Name() string
type Cookie ¶
type Cookie struct {
Reset bool `config:"reset"` //reset request cookies
Cookies map[string]string `config:"cookies"` //request cookies
}
func (*Cookie) Filter ¶
func (filter *Cookie) Filter(ctx *fasthttp.RequestCtx)
type ElasticsearchLookup ¶
type ElasticsearchLookup struct {
Elasticsearch string `config:"target.elasticsearch"`
IndexPattern string `config:"target.index_pattern"`
Template RequestTemplate `config:"target.template"`
JoinBySourceFieldValuesKeyPath []string `config:"source.join_by_field_values.json_path"`
}
func (*ElasticsearchLookup) Filter ¶
func (filter *ElasticsearchLookup) Filter(ctx *fasthttp.RequestCtx)
func (*ElasticsearchLookup) Lookup ¶
func (filter *ElasticsearchLookup) Lookup(docsID []interface{}) map[interface{}][]byte
func (*ElasticsearchLookup) Name ¶
func (filter *ElasticsearchLookup) Name() string
type RequestBodyJsonDel ¶
type RequestBodyJsonDel struct {
IgnoreMissing bool `config:"ignore_missing"`
Path []string `config:"path"`
}
func (*RequestBodyJsonDel) Filter ¶
func (filter *RequestBodyJsonDel) Filter(ctx *fasthttp.RequestCtx)
func (*RequestBodyJsonDel) Name ¶
func (filter *RequestBodyJsonDel) Name() string
type RequestBodyJsonSet ¶
type RequestBodyJsonSet struct {
IgnoreMissing bool `config:"ignore_missing"`
Path []string `config:"path"`
// contains filtered or unexported fields
}
func (*RequestBodyJsonSet) Filter ¶
func (filter *RequestBodyJsonSet) Filter(ctx *fasthttp.RequestCtx)
func (*RequestBodyJsonSet) Name ¶
func (filter *RequestBodyJsonSet) Name() string
type RequestBodyRegexReplace ¶
type RequestBodyRegexReplace struct {
Pattern string `config:"pattern"`
To string `config:"to"`
// contains filtered or unexported fields
}
func (*RequestBodyRegexReplace) Filter ¶
func (filter *RequestBodyRegexReplace) Filter(ctx *fasthttp.RequestCtx)
func (*RequestBodyRegexReplace) Name ¶
func (filter *RequestBodyRegexReplace) Name() string
type RequestTemplate ¶
type ResponseBodyRegexReplace ¶
type ResponseBodyRegexReplace struct {
Pattern string `config:"pattern"`
To string `config:"to"`
// contains filtered or unexported fields
}
func (*ResponseBodyRegexReplace) Filter ¶
func (filter *ResponseBodyRegexReplace) Filter(ctx *fasthttp.RequestCtx)
func (*ResponseBodyRegexReplace) Name ¶
func (filter *ResponseBodyRegexReplace) Name() string
type ResponseHeaderFormatFilter ¶
type ResponseHeaderFormatFilter struct {
}
func (*ResponseHeaderFormatFilter) Filter ¶
func (filter *ResponseHeaderFormatFilter) Filter(ctx *fasthttp.RequestCtx)
func (*ResponseHeaderFormatFilter) Name ¶
func (filter *ResponseHeaderFormatFilter) Name() string
type SetContext ¶
type SetContext struct {
ContextKeyword string `config:"context_keyword"`
VariableKeyword string `config:"variable_keyword"`
Context map[string]interface{} `config:"context"`
// contains filtered or unexported fields
}
func (*SetContext) Filter ¶
func (filter *SetContext) Filter(ctx *fasthttp.RequestCtx)
func (*SetContext) Name ¶
func (filter *SetContext) Name() string
type SetHostname ¶
type SetHostname struct {
Hostname string `config:"hostname"`
}
func (*SetHostname) Filter ¶
func (filter *SetHostname) Filter(ctx *fasthttp.RequestCtx)
func (*SetHostname) Name ¶
func (filter *SetHostname) Name() string
type SetRequestHeader ¶
type SetRequestHeader struct {
Headers []string `config:"headers"`
// contains filtered or unexported fields
}
func (*SetRequestHeader) Filter ¶
func (filter *SetRequestHeader) Filter(ctx *fasthttp.RequestCtx)
func (*SetRequestHeader) Name ¶
func (filter *SetRequestHeader) Name() string
type SetRequestQueryArgs ¶
type SetRequestQueryArgs struct {
Args []string `config:"args"`
// contains filtered or unexported fields
}
func (*SetRequestQueryArgs) Filter ¶
func (filter *SetRequestQueryArgs) Filter(ctx *fasthttp.RequestCtx)
func (*SetRequestQueryArgs) Name ¶
func (filter *SetRequestQueryArgs) Name() string
type SetResponse ¶
type SetResponse struct {
Status int `config:"status"`
ContentType string `config:"content_type"`
Body string `config:"body"`
}
func (*SetResponse) Filter ¶
func (filter *SetResponse) Filter(ctx *fasthttp.RequestCtx)
func (*SetResponse) Name ¶
func (filter *SetResponse) Name() string
type SetResponseHeader ¶
type SetResponseHeader struct {
Headers []string `config:"headers"`
// contains filtered or unexported fields
}
func (*SetResponseHeader) Filter ¶
func (filter *SetResponseHeader) Filter(ctx *fasthttp.RequestCtx)
func (*SetResponseHeader) Name ¶
func (filter *SetResponseHeader) Name() string
Click to show internal directories.
Click to hide internal directories.