encoders

Documentation

Index

• Variables
• func ChainEncode(e Encoder, objs ...interface{}) (ret string, err error)
• func EncodingError(err error) error
• func FullToGelfMessage(m *model.FullMessage) *gelf.Message
• func RELPEncode(e Encoder, txnr int32, command string, obj interface{}) (ret string, err error)
• func SyslogToGelfMessage(m *model.SyslogMessage) *gelf.Message
• func TcpOctetEncode(e Encoder, obj interface{}) (ret string, err error)
• type Encoder
  • func GetEncoder(frmt baseenc.Format) (Encoder, error)

Variables

var AcceptedMimeTypes = []string{
	JsonMimetype,
	AvroMimetype,
	NDJsonMimetype,
	ProtobufMimetype,
	OctetStreamMimetype,
	"text/plain",
}

var AvroMimetype = "application/x-avro-binary"

var JsonMimetype = "application/json"

var MimeTypes = map[baseenc.Format]string{
	baseenc.RFC5424:      PlainMimetype,
	baseenc.RFC3164:      PlainMimetype,
	baseenc.JSON:         JsonMimetype,
	baseenc.FullJSON:     JsonMimetype,
	baseenc.AVRO:         AvroMimetype,
	baseenc.FullAVRO:     AvroMimetype,
	baseenc.JSONAVRO:     JsonMimetype,
	baseenc.FullJSONAVRO: JsonMimetype,
	baseenc.File:         PlainMimetype,
	baseenc.GELF:         JsonMimetype,
	baseenc.Protobuf:     ProtobufMimetype,
}

var NDJsonMimetype = "application/x-ndjson"

var OctetStreamMimetype = "application/octet-stream"

var PlainMimetype = mime.FormatMediaType("text/plain", map[string]string{"charset": "utf-8"})

var ProtobufMimetype = "application/vnd.google.protobuf"

var RMimeTypes = map[string]Encoder{
	JsonMimetype:        encodeJSON,
	NDJsonMimetype:      encodeJSON,
	AvroMimetype:        encodeFullAVRO,
	ProtobufMimetype:    encodePB,
	OctetStreamMimetype: encodePB,
	PlainMimetype:       encode5424,
	"text/plain":        encode5424,
}

Functions

func ChainEncode

func ChainEncode(e Encoder, objs ...interface{}) (ret string, err error)

func EncodingError

func EncodingError(err error) error

func FullToGelfMessage

func FullToGelfMessage(m *model.FullMessage) *gelf.Message

func RELPEncode

func RELPEncode(e Encoder, txnr int32, command string, obj interface{}) (ret string, err error)

func SyslogToGelfMessage

func SyslogToGelfMessage(m *model.SyslogMessage) *gelf.Message

func TcpOctetEncode

func TcpOctetEncode(e Encoder, obj interface{}) (ret string, err error)

Types

type Encoder

type Encoder func(v interface{}, w io.Writer) error

Encoder is the function type that represents encoders

func GetEncoder

func GetEncoder(frmt baseenc.Format) (Encoder, error)