format

package

Go to main page

Versions in this module

v0

v0.4.5

Apr 3, 2017

Changes in this version

+ type SplitPick struct

+ func (format *SplitPick) Configure(conf core.PluginConfig) error

+ func (format *SplitPick) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type TemplateJSON struct

+ func (format *TemplateJSON) Configure(conf core.PluginConfig) error

+ func (format *TemplateJSON) Format(msg core.Message) ([]byte, core.MessageStreamID)

v0.4.4

Aug 16, 2016

Changes in this version

+ type Clear struct

+ func (format *Clear) Configure(conf core.PluginConfig) error

+ func (format *Clear) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type ProcessTSV struct

+ func (format *ProcessTSV) Configure(conf core.PluginConfig) error

+ func (format *ProcessTSV) Format(msg core.Message) ([]byte, core.MessageStreamID)

v0.4.3

Apr 29, 2016

Changes in this version

+ type ExtractJSON struct

+ func (format *ExtractJSON) Configure(conf core.PluginConfig) error

+ func (format *ExtractJSON) Format(msg core.Message) ([]byte, core.MessageStreamID)

v0.4.2

Feb 16, 2016

Changes in this version

+ type ProcessJSON struct

+ func (format *ProcessJSON) Configure(conf core.PluginConfig) error

+ func (format *ProcessJSON) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type SplitToJSON struct

+ func (format *SplitToJSON) Configure(conf core.PluginConfig) error

+ func (format *SplitToJSON) Format(msg core.Message) ([]byte, core.MessageStreamID)

v0.4.1

Nov 10, 2015

Changes in this version

+ type CollectdToInflux10 struct

+ func (format *CollectdToInflux10) Configure(conf core.PluginConfig) error

+ func (format *CollectdToInflux10) Format(msg core.Message) ([]byte, core.MessageStreamID)

v0.4.0

Aug 28, 2015

Changes in this version

+ type CollectdToInflux08 struct

+ func (format *CollectdToInflux08) Configure(conf core.PluginConfig) error

+ func (format *CollectdToInflux08) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type CollectdToInflux09 struct

+ func (format *CollectdToInflux09) Configure(conf core.PluginConfig) error

+ func (format *CollectdToInflux09) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type Serialize struct

+ func (format *Serialize) Configure(conf core.PluginConfig) error

+ func (format *Serialize) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type StreamName struct

+ func (format *StreamName) Configure(conf core.PluginConfig) error

+ func (format *StreamName) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type StreamRevert struct

+ func (format *StreamRevert) Configure(conf core.PluginConfig) error

+ func (format *StreamRevert) Format(msg core.Message) ([]byte, core.MessageStreamID)

+ type StreamRoute struct

+ func (format *StreamRoute) Configure(conf core.PluginConfig) error

+ func (format *StreamRoute) Format(msg core.Message) ([]byte, core.MessageStreamID)

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL