transform

package
v1.29.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 16, 2025 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewContextParseFilter

func NewContextParseFilter(c *config.Config) (pipeline.Filter, error)

func NewContextRegexReplace

func NewContextRegexReplace(c *config.Config) (filter pipeline.Filter, err error)

func NewCookieFilter

func NewCookieFilter(c *config.Config) (pipeline.Filter, error)

func NewElasticsearchLookupFilter

func NewElasticsearchLookupFilter(c *config.Config) (pipeline.Filter, error)

func NewRequestBodyJsonDel

func NewRequestBodyJsonDel(c *config.Config) (pipeline.Filter, error)

func NewRequestBodyJsonSet

func NewRequestBodyJsonSet(c *config.Config) (pipeline.Filter, error)

func NewRequestBodyRegexReplace

func NewRequestBodyRegexReplace(c *config.Config) (filter pipeline.Filter, err error)

func NewResponseBodyRegexReplace

func NewResponseBodyRegexReplace(c *config.Config) (filter pipeline.Filter, err error)

func NewResponseHeaderFormatFilter

func NewResponseHeaderFormatFilter(c *config.Config) (pipeline.Filter, error)

func NewSetContext

func NewSetContext(c *config.Config) (pipeline.Filter, error)

func NewSetHostname

func NewSetHostname(c *config.Config) (pipeline.Filter, error)

func NewSetRequestHeader

func NewSetRequestHeader(c *config.Config) (pipeline.Filter, error)

func NewSetRequestQueryArgs

func NewSetRequestQueryArgs(c *config.Config) (pipeline.Filter, error)

func NewSetResponse

func NewSetResponse(c *config.Config) (pipeline.Filter, error)

func NewSetResponseHeader

func NewSetResponseHeader(c *config.Config) (pipeline.Filter, error)

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 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)

func (*Cookie) Name

func (filter *Cookie) Name() string

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 RequestTemplate struct {
	Method      string                 `config:"method"`
	RequestBody string                 `config:"body"`
	Parameters  map[string]interface{} `config:"variable"`
}

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

Jump to

Keyboard shortcuts

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