encoding

Documentation

Index

• func ConvertMapForJSON(m map[string]interface{}) map[string]interface{}
• type AvroMessageEncoder
  • func (ame *AvroMessageEncoder) Encode(val interface{}) ([]byte, error)
• type JSONExtMessageEncoder
  • func (jme *JSONExtMessageEncoder) Encode(val interface{}) ([]byte, error)
• type JSONMessageEncoder
  • func (jme *JSONMessageEncoder) Encode(val interface{}) ([]byte, error)
• type MessageEncoder

Functions

func ConvertMapForJSON

func ConvertMapForJSON(m map[string]interface{}) map[string]interface{}

Types

type AvroMessageEncoder

type AvroMessageEncoder struct {
	SchemaSpec string
	Binary     bool
}

func (*AvroMessageEncoder) Encode

func (ame *AvroMessageEncoder) Encode(val interface{}) ([]byte, error)

type JSONExtMessageEncoder

type JSONExtMessageEncoder struct{}

func (*JSONExtMessageEncoder) Encode

func (jme *JSONExtMessageEncoder) Encode(val interface{}) ([]byte, error)

type JSONMessageEncoder

type JSONMessageEncoder struct{}

func (*JSONMessageEncoder) Encode

func (jme *JSONMessageEncoder) Encode(val interface{}) ([]byte, error)

type MessageEncoder

type MessageEncoder interface {
	Encode(interface{}) ([]byte, error)
}