codec

Documentation

Index

• func MakeBCTimestampEncoder() func(*common.Time, structform.ExtVisitor) error
• func MakeTimestampEncoder() func(*time.Time, structform.ExtVisitor) error
• func Plugin(name string, f Factory) map[string][]interface{}
• func RegisterType(name string, gen Factory)
• type Codec
  • func CreateEncoder(cfg Config) (Codec, error)
• type Config
• type Factory

Functions

func MakeBCTimestampEncoder

func MakeBCTimestampEncoder() func(*common.Time, structform.ExtVisitor) error

func MakeTimestampEncoder

func MakeTimestampEncoder() func(*time.Time, structform.ExtVisitor) error

func Plugin

func Plugin(name string, f Factory) map[string][]interface{}

func RegisterType

func RegisterType(name string, gen Factory)

Types

type Codec

type Codec interface {
	Encode(index string, event *beat.Event) ([]byte, error)
}

func CreateEncoder

func CreateEncoder(cfg Config) (Codec, error)

type Config

type Config struct {
	Namespace common.ConfigNamespace `config:",inline"`
}

type Factory

type Factory func(*common.Config) (Codec, error)