lz4

Documentation

Index

• func Decoder(next msg.Receiver) msg.Receiver
• func Encoder(next msg.Topic) msg.Topic

Functions

func Decoder

func Decoder(next msg.Receiver) msg.Receiver

Decoder wraps a msg.Receiver with lz4 decoding functionality. It only attempts to decode the Message.Body if Content-Encoding is set to lz4. This should be used in conjuction with the base64 decode decorator, when the message queue doesn't support binary. In this case the base64 decorator should be the outermost decorator in order to run first.

func Encoder

func Encoder(next msg.Topic) msg.Topic

Encoder wraps a topic with another which lz4-encodes a Message. This should used in conjunction with the base64 encoder if the underlying message queue does not support binary (eg SQS)