format

package

Go to main page

Versions in this module

v0

v0.6.0-beta2

Jul 30, 2019

v0.6.0-beta1

Jul 19, 2019

v0.6.0-alpha1

Aug 22, 2018

v0.5.4

Apr 17, 2019

v0.5.3

Apr 23, 2018

v0.5.2

Mar 30, 2018

v0.5.1

Jan 24, 2018

v0.5.0

Dec 21, 2017

Changes in this version

+ type Aggregate struct

+ func (format *Aggregate) ApplyFormatter(msg *core.Message) error

+ func (format *Aggregate) Configure(conf core.PluginConfigReader)

type Base64Decode

+ func (format *Base64Decode) ApplyFormatter(msg *core.Message) error

type Base64Encode

+ func (format *Base64Encode) ApplyFormatter(msg *core.Message) error

type Clear

+ func (format *Clear) ApplyFormatter(msg *core.Message) error

type CollectdToInflux08

+ func (format *CollectdToInflux08) ApplyFormatter(msg *core.Message) error

type CollectdToInflux09

+ func (format *CollectdToInflux09) ApplyFormatter(msg *core.Message) error

type CollectdToInflux10

+ func (format *CollectdToInflux10) ApplyFormatter(msg *core.Message) error

+ type Double struct

+ func (format *Double) ApplyFormatter(msg *core.Message) error

+ func (format *Double) Configure(conf core.PluginConfigReader)

type Envelope

+ func (format *Envelope) ApplyFormatter(msg *core.Message) error

type ExtractJSON

+ func (format *ExtractJSON) ApplyFormatter(msg *core.Message) error

+ type GrokToJSON struct

+ func (format *GrokToJSON) ApplyFormatter(msg *core.Message) error

+ func (format *GrokToJSON) Configure(conf core.PluginConfigReader)

type Hostname

+ func (format *Hostname) ApplyFormatter(msg *core.Message) error

type Identifier

+ func (format *Identifier) ApplyFormatter(msg *core.Message) error

+ type JSONToArray struct

+ func (format *JSONToArray) ApplyFormatter(msg *core.Message) error

+ func (format *JSONToArray) Configure(conf core.PluginConfigReader)

+ type JSONToInflux10 struct

+ func (format *JSONToInflux10) ApplyFormatter(msg *core.Message) error

+ func (format *JSONToInflux10) Configure(conf core.PluginConfigReader)

+ type MetadataCopy struct

+ func (format *MetadataCopy) ApplyFormatter(msg *core.Message) error

+ func (format *MetadataCopy) Configure(conf core.PluginConfigReader)

type ProcessJSON

+ func (format *ProcessJSON) ApplyFormatter(msg *core.Message) error

type ProcessTSV

+ func (format *ProcessTSV) ApplyFormatter(msg *core.Message) error

+ type RegExp struct

+ func (format *RegExp) ApplyFormatter(msg *core.Message) error

+ func (format *RegExp) Configure(conf core.PluginConfigReader)

type Runlength

+ func (format *Runlength) ApplyFormatter(msg *core.Message) error

type Sequence

+ func (format *Sequence) ApplyFormatter(msg *core.Message) error

type Serialize

+ func (format *Serialize) ApplyFormatter(msg *core.Message) error

type SplitPick

+ func (format *SplitPick) ApplyFormatter(msg *core.Message) error

type SplitToJSON

+ func (format *SplitToJSON) ApplyFormatter(msg *core.Message) error

type StreamName

+ func (format *StreamName) ApplyFormatter(msg *core.Message) error

type StreamRevert

+ func (format *StreamRevert) ApplyFormatter(msg *core.Message) error

type StreamRoute

+ func (format *StreamRoute) ApplyFormatter(msg *core.Message) error

type TemplateJSON

+ func (format *TemplateJSON) ApplyFormatter(msg *core.Message) error

+ type TextToJSON struct

+ func (format *TextToJSON) ApplyFormatter(msg *core.Message) error

+ func (format *TextToJSON) Configure(conf core.PluginConfigReader)

type Timestamp

+ func (format *Timestamp) ApplyFormatter(msg *core.Message) error

+ type Trim struct

+ func (format *Trim) ApplyFormatter(msg *core.Message) error

+ func (format *Trim) Configure(conf core.PluginConfigReader)

v0.5.0-rc3.1

Aug 15, 2017

v0.5.0-rc3

Aug 15, 2017

v0.5.0-rc2

Aug 10, 2017

v0.5.0-rc1

Aug 7, 2017

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