codec

Documentation

Index

• func Register(name string, factory Factory)
• type Codec
  • func Get(name string) (Codec, bool)
• type Config
  • func (c *Config) DeepCopy() *Config
  • func (c *Config) Merge(from *Config) *Config
  • func (c *Config) Validate() error
• type Factory
• type SinkCodec

Functions

func Register

func Register(name string, factory Factory)

Types

type Codec

type Codec interface {
	Init()
	Encode(event api.Event) ([]byte, error)
}

func Get

func Get(name string) (Codec, bool)

type Config

type Config struct {
	Type          string `yaml:"type,omitempty" default:"json"`
	cfg.CommonCfg `yaml:",inline"`
}

func (*Config) DeepCopy

func (c *Config) DeepCopy() *Config

func (*Config) Merge

func (c *Config) Merge(from *Config) *Config

func (*Config) Validate

func (c *Config) Validate() error

type Factory

type Factory func() Codec

type SinkCodec

type SinkCodec interface {
	SetCodec(c Codec)
}