Versions in this module Expand all Collapse all v0 v0.3.2 Jun 22, 2015 Changes in this version + type Base64Decode struct + func (format *Base64Decode) Configure(conf core.PluginConfig) error + func (format *Base64Decode) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Base64Encode struct + func (format *Base64Encode) Configure(conf core.PluginConfig) error + func (format *Base64Encode) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Envelope struct + func (format *Envelope) Configure(conf core.PluginConfig) error + func (format *Envelope) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Forward struct + func (format *Forward) Configure(conf core.PluginConfig) error + func (format *Forward) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Hostname struct + func (format *Hostname) Configure(conf core.PluginConfig) error + func (format *Hostname) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Identifier struct + func (format *Identifier) Configure(conf core.PluginConfig) error + func (format *Identifier) Format(msg core.Message) ([]byte, core.MessageStreamID) + type JSON struct + func (format *JSON) Configure(conf core.PluginConfig) error + func (format *JSON) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Runlength struct + func (format *Runlength) Configure(conf core.PluginConfig) error + func (format *Runlength) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Sequence struct + func (format *Sequence) Configure(conf core.PluginConfig) error + func (format *Sequence) Format(msg core.Message) ([]byte, core.MessageStreamID) + type StreamMod struct + func (format *StreamMod) Configure(conf core.PluginConfig) error + func (format *StreamMod) Format(msg core.Message) ([]byte, core.MessageStreamID) + type Timestamp struct + func (format *Timestamp) Configure(conf core.PluginConfig) error + func (format *Timestamp) Format(msg core.Message) ([]byte, core.MessageStreamID)