transform

Documentation

Index

• Variables
• type Config
  • func NewConfig(config interface{}) (*Config, error)
  • func (c *Config) FromJSON(in string) error
  • func (c *Config) FromYAML(in string) error
  • func (c *Config) JSON() (string, error)
  • func (c *Config) String() string
  • func (c *Config) Validate() error
  • func (c Config) WithDefaults() *Config
  • func (c *Config) YAML() (string, error)
• type Filter
  • func NewFilter(tid tenant.Id, plugin string, name string, config interface{}, ...) (*Filter, error)
  • func (f *Filter) Config() interface{}
  • func (f *Filter) Filter(evt event.Event) []event.Event
  • func (f *Filter) Name() string
  • func (f *Filter) Plugin() string
  • func (f *Filter) Tenant() tenant.Id

Variables

var DefaultConfig = Config{
	Transformation: empty,
	ToPath:         "",
}

Types

type Config

type Config struct {
	Transformation interface{} `json:"transformation,omitempty"`
	ToPath         string      `json:"toPath,omitempty"`
	FromPath       string      `json:"fromPath,omitempty"` // optional, if present apply transformation to sub event at path, if sub event is array apply transformation to all elements of array
}

Config can be passed into NewFilter() in order to configure the behavior of the sender.

func NewConfig

func NewConfig(config interface{}) (*Config, error)

func (*Config) FromJSON

func (c *Config) FromJSON(in string) error

func (*Config) FromYAML

func (c *Config) FromYAML(in string) error

func (*Config) JSON

func (c *Config) JSON() (string, error)

func (*Config) String

func (c *Config) String() string

func (*Config) Validate

func (c *Config) Validate() error

Validate will validate configs

func (Config) WithDefaults

func (c Config) WithDefaults() *Config

WithDefaults will set default values

func (*Config) YAML

func (c *Config) YAML() (string, error)

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

func NewFilter

func NewFilter(tid tenant.Id, plugin string, name string, config interface{}, secrets secret.Vault) (*Filter, error)

func (*Filter) Config

func (f *Filter) Config() interface{}

func (*Filter) Filter

func (f *Filter) Filter(evt event.Event) []event.Event

Filter splits an event containing an array into multiple events

func (*Filter) Name

func (f *Filter) Name() string

func (*Filter) Plugin

func (f *Filter) Plugin() string

func (*Filter) Tenant

func (f *Filter) Tenant() tenant.Id