codec

type Decoder interface {
	Decode(reader io.Reader) (<-chan message.Message, <-chan error)
}

type Encoder interface {
	// Encode takes messages from a the messages channel, encodes them in the desired format, and writes them to
	//        storage. When the messages channel is closed it will also close the storage writer.
	Encode(messages <-chan message.Message, storage storage.Writer) error
	// GetMimeType returns the MIME type of this format
	GetMimeType() string
	// GetFileExtension returns the desired file extension for this format
	GetFileExtension() string
}