codecs

Documentation

Index

• type GobCodec
  • func (j *GobCodec) Decode(b []byte) (*sabuhp.Message, error)
  • func (j *GobCodec) Encode(message *sabuhp.Message) ([]byte, error)
• type JsonCodec
  • func (j *JsonCodec) Decode(b []byte) (*sabuhp.Message, error)
  • func (j *JsonCodec) Encode(message *sabuhp.Message) ([]byte, error)
• type MessagePackCodec
  • func (j *MessagePackCodec) Decode(b []byte) (*sabuhp.Message, error)
  • func (j *MessagePackCodec) Encode(message *sabuhp.Message) ([]byte, error)
• type WrappedGobCodec
  • func (j *WrappedGobCodec) Decode(b []byte) (*sabuhp.WrappedPayload, error)
  • func (j *WrappedGobCodec) Encode(message *sabuhp.WrappedPayload) ([]byte, error)
• type WrappedJsonCodec
  • func (j *WrappedJsonCodec) Decode(b []byte) (*sabuhp.WrappedPayload, error)
  • func (j *WrappedJsonCodec) Encode(message *sabuhp.WrappedPayload) ([]byte, error)
• type WrappedMessagePackCodec
  • func (j *WrappedMessagePackCodec) Decode(b []byte) (*sabuhp.WrappedPayload, error)
  • func (j *WrappedMessagePackCodec) Encode(message *sabuhp.WrappedPayload) ([]byte, error)

Types

type GobCodec

type GobCodec struct{}

func (*GobCodec) Decode

func (j *GobCodec) Decode(b []byte) (*sabuhp.Message, error)

func (*GobCodec) Encode

func (j *GobCodec) Encode(message *sabuhp.Message) ([]byte, error)

type JsonCodec

type JsonCodec struct{}

func (*JsonCodec) Decode

func (j *JsonCodec) Decode(b []byte) (*sabuhp.Message, error)

func (*JsonCodec) Encode

func (j *JsonCodec) Encode(message *sabuhp.Message) ([]byte, error)

type MessagePackCodec

type MessagePackCodec struct{}

func (*MessagePackCodec) Decode

func (j *MessagePackCodec) Decode(b []byte) (*sabuhp.Message, error)

func (*MessagePackCodec) Encode

func (j *MessagePackCodec) Encode(message *sabuhp.Message) ([]byte, error)

type WrappedGobCodec

type WrappedGobCodec struct{}

func (*WrappedGobCodec) Decode

func (j *WrappedGobCodec) Decode(b []byte) (*sabuhp.WrappedPayload, error)

func (*WrappedGobCodec) Encode

func (j *WrappedGobCodec) Encode(message *sabuhp.WrappedPayload) ([]byte, error)

type WrappedJsonCodec

type WrappedJsonCodec struct{}

func (*WrappedJsonCodec) Decode

func (j *WrappedJsonCodec) Decode(b []byte) (*sabuhp.WrappedPayload, error)

func (*WrappedJsonCodec) Encode

func (j *WrappedJsonCodec) Encode(message *sabuhp.WrappedPayload) ([]byte, error)

type WrappedMessagePackCodec

type WrappedMessagePackCodec struct{}

func (*WrappedMessagePackCodec) Decode

func (j *WrappedMessagePackCodec) Decode(b []byte) (*sabuhp.WrappedPayload, error)

func (*WrappedMessagePackCodec) Encode

func (j *WrappedMessagePackCodec) Encode(message *sabuhp.WrappedPayload) ([]byte, error)