ogitransformer

Documentation

Index

• Variables
• func Transform(msg []byte)
• type NewTransformer
• type Transformer
  • func NewTransformerPlugin() Transformer
  • func NewTransparentTransformer() Transformer
• type TransformerPlugin
  • func (plugin *TransformerPlugin) Transform(msg []byte) error
• type TransparentTransformer
  • func (t *TransparentTransformer) Transform(msg []byte) (err error)

Variables

var (
	TransformerPluginPath = golenv.OverrideIfEnv("TRANSFORMER_PLUGIN_PATH", "./transformer.so")
)

var (
	TransformerType = golenv.OverrideIfEnv("TRANSFORMER_TYPE", "transparent")
)

Functions

func Transform

func Transform(msg []byte)

Types

type NewTransformer

type NewTransformer func() Transformer

type Transformer

type Transformer interface {
	Transform([]byte) error
}

func NewTransformerPlugin

func NewTransformerPlugin() Transformer

func NewTransparentTransformer

func NewTransparentTransformer() Transformer

type TransformerPlugin

type TransformerPlugin struct {
	Name          string
	TransformFunc plugin.Symbol
}

func (*TransformerPlugin) Transform

func (plugin *TransformerPlugin) Transform(msg []byte) error

type TransparentTransformer

type TransparentTransformer struct {
	Topic string
}

func (*TransparentTransformer) Transform

func (t *TransparentTransformer) Transform(msg []byte) (err error)