codec

Documentation

Index

• Variables
• 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)
  • func (c *Config) Validate() error
• type Factory
• type SourceCodec

Variables

var ProductFunc = func(productFunc api.ProductFunc, codec Codec) api.ProductFunc {
	return func(event api.Event) api.Result {
		if codec != nil {
			if _, err := codec.Decode(event); err != nil {
				log.Error("source codec decode failed: %v", err)

			}
		}

		productFunc(event)
		return result.Success()
	}
}

Functions

func Register

func Register(name string, factory Factory)

Types

type Codec

type Codec interface {
	Init()
	Decode(event api.Event) (api.Event, 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)

func (*Config) Validate

func (c *Config) Validate() error

type Factory

type Factory func() Codec

type SourceCodec

type SourceCodec interface {
	SetCodec(c Codec)
}