common

type CompressGZIP ¶

type CompressGZIP struct {
}

CompressGZIP Gzip compression

func (es *CompressGZIP) Compress(subBatchMessages []byte) ([]byte, error)

func (es *CompressGZIP) GetType() uint8

type CompressNONE ¶

type CompressNONE struct {
}

CompressNONE No compression

func (es *CompressNONE) Compress(subBatchMessages []byte) ([]byte, error)

func (es *CompressNONE) GetType() uint8

type CompresserCodec ¶

type CompresserCodec interface {
	Compress(subBatchMessages []byte) ([]byte, error)
	GetType() uint8
}

type Message ¶

type Message interface {
	encoding.BinaryMarshaler
	encoding.BinaryUnmarshaler
}

Message is the interface for the message

type PublishingMessager ¶

type PublishingMessager interface {
	io.WriterTo
	SetPublishingId(publishingId uint64)
	PublishingId() uint64
	SetMessage(message Message)
	Message() Message
}

PublishingMessager is the interface for the publishing message it creates a message with a publishingId and a Message The message doesn't contain the publishingId this is why we need this interface