codec

package

v0.21.18 Latest Latest Go to latest Published: Oct 13, 2021 License: GPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Codec interface {
	Marshal(v interface{}) ([]byte, error)
	Unmarshal(bs []byte) (interface{}, error)
	String() string
}

Codec is a simple encoding interface used for the broker/transport where headers are not supported by the underlying implementation.

type JSON struct {
	// contains filtered or unexported fields
}

func NewJSONCodec(id string, factory func() interface{}) *JSON

func (p *JSON) Marshal(msg interface{}) ([]byte, error)

Marshal implements Codec.

func (*JSON) String() string

func (p *JSON) Unmarshal(msg []byte) (interface{}, error)

Unmarshal implements Codec.

type NewCodec func() Codec

NewCodec Takes in a connection/buffer and returns a new Codec

type Proto struct {
	// contains filtered or unexported fields
}

Proto is a Codec for proto/snappy

func NewProtoCodec(id string, factory func() proto.Message) Proto

func (p Proto) Marshal(msg interface{}) ([]byte, error)

Marshal implements Codec

func (p Proto) String() string

func (p Proto) Unmarshal(bytes []byte) (interface{}, error)

Unmarshal implements Codec

type String struct{}

String is a code for strings.

func (String) Marshal(msg interface{}) ([]byte, error)

Marshal implements Codec.

func (String) String() string

func (String) Unmarshal(bytes []byte) (interface{}, error)

Unmarshal implements Codec.