decode

package

v0.7.0 Latest Latest Go to latest Published: Nov 16, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xmidt-org/ears

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Config
- func NewConfig(config interface{}) (*Config, error)
type Filter
- func NewFilter(tid tenant.Id, plugin string, name string, config interface{}, ...) (*Filter, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var DefaultConfig = Config{
	FromPath: "",
	ToPath:   "",
	Encoding: "base64",
}

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	FromPath string `json:"fromPath,omitempty"`
	ToPath   string `json:"toPath,omitempty"`
	Encoding string `json:"encoding,omitempty"`
}

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

func (Config) WithDefaults ¶

func (c Config) WithDefaults() *Config

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

func (*Filter) Name ¶ added in v0.2.1

func (f *Filter) Name() string

func (*Filter) Plugin ¶ added in v0.2.1

func (f *Filter) Plugin() string

func (*Filter) Tenant ¶ added in v0.3.0

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

Source Files ¶

View all Source files

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