codecs

Documentation

Index

• Constants
• Variables
• type Codec
• type Decoder
• type Encoder
• type JSONCodec
  • func (c *JSONCodec) Decode(data []byte, v interface{}) error
  • func (c *JSONCodec) Encode(v interface{}) ([]byte, error)
• type ProtobufCodec
  • func (c *ProtobufCodec) Decode(data []byte, v interface{}) error
  • func (c *ProtobufCodec) Encode(v interface{}) ([]byte, error)
• type XMLCodec
  • func (c *XMLCodec) Decode(data []byte, v interface{}) error
  • func (c *XMLCodec) Encode(v interface{}) ([]byte, error)

Constants

const (
	JSONCodecName  = "application/json"
	ProtoCodecName = "application/protobuf"
	XMLCodecName   = "application/xml"
)

Variables

var NotProtoMessage = errors.New("not proto message")

var Register = register{/* contains filtered or unexported fields */}

Types

type Codec

type Codec interface {
	Encoder
	Decoder
}

Codec is an interface that encodes message on pub and decodes it on sub.

type Decoder

type Decoder interface {
	Decode([]byte, interface{}) error
}

type Encoder

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

type JSONCodec

type JSONCodec struct {
}

func (*JSONCodec) Decode

func (c *JSONCodec) Decode(data []byte, v interface{}) error

func (*JSONCodec) Encode

func (c *JSONCodec) Encode(v interface{}) ([]byte, error)

type ProtobufCodec

type ProtobufCodec struct {
}

func (*ProtobufCodec) Decode

func (c *ProtobufCodec) Decode(data []byte, v interface{}) error

func (*ProtobufCodec) Encode

func (c *ProtobufCodec) Encode(v interface{}) ([]byte, error)

type XMLCodec

type XMLCodec struct {
}

func (*XMLCodec) Decode

func (c *XMLCodec) Decode(data []byte, v interface{}) error

func (*XMLCodec) Encode

func (c *XMLCodec) Encode(v interface{}) ([]byte, error)