processors

package module

v0.0.0-...-00c2bea Latest Latest Go to latest Published: Jul 8, 2016 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mirdhyn/processors

Links

Open Source Insights

README ¶

processors

veino processors

contributors

@mirdhyn (GeoIP Filter, AMQP Input)

used packages

mitchellh/mapstructure
ChimeraCoder/anaconda
etrepat/postman/watch
go-fsnotify/fsnotify
hpcloud/tail
nu7hatch/gouuid
parnurzeal/gorequest
vjeantet/go.enmime
vjeantet/govaluate
vjeantet/grok
gopkg.in/fsnotify.v1
gopkg.in/go-playground/validator.v8
gopkg.in/mgo.v2
gopkg.in/olivere/elastic.v2
github.com/streadway/amqp
github.com/oschwald/geoip2-golang

Documentation ¶

Index ¶

Variables
func AddFields(fields map[string]interface{}, data *mxj.Map)
func AddTags(tags []string, data *mxj.Map)
func Convert(fields map[string]string, data *mxj.Map)
func Dynamic(str *string, fields *mxj.Map)
func Gsub(fields []string, data *mxj.Map)
func Join(fields map[string]string, data *mxj.Map)
func LowerCaseFields(fields []string, data *mxj.Map)
func Merge(fields map[string]string, data *mxj.Map)
func ProcessCommonFields(data *mxj.Map, add_fields map[string]interface{}, tags []string, ...)
func ProcessCommonFields2(data *mxj.Map, add_fields map[string]interface{}, tags []string, ...)
func RemoveAllButFields(fields []string, data *mxj.Map)
func RemoveFields(fields []string, data *mxj.Map)
func RemoveTags(tags []string, data *mxj.Map)
func RenameFields(fields map[string]string, data *mxj.Map)
func SetType(typevalue string, data *mxj.Map)
func Split(fields map[string]string, data *mxj.Map)
func Strip(fields []string, data *mxj.Map)
func UpdateFields(fields map[string]interface{}, data *mxj.Map)
func UpperCaseFields(fields []string, data *mxj.Map)
type Base
- func (b *Base) Configure(ctx veino.ProcessorContext, conf map[string]interface{}) error
- func (b *Base) ConfigureAndValidate(ctx veino.ProcessorContext, conf map[string]interface{}, rawVal interface{}) error
- func (b *Base) Receive(e veino.IPacket) error
- func (b *Base) Start(e veino.IPacket) error
- func (b *Base) Stop(e veino.IPacket) error
- func (b *Base) Tick(e veino.IPacket) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// DefaultLogger is used when Config.Logger == nil
	DefaultLogger = log.New(os.Stderr, "", log.LstdFlags)

	// DiscardingLogger can be used to disable logging output
	DiscardingLogger = log.New(ioutil.Discard, "", 0)
)

Functions ¶

func AddFields ¶

func AddFields(fields map[string]interface{}, data *mxj.Map)

func AddTags ¶

func AddTags(tags []string, data *mxj.Map)

func Convert ¶

func Convert(fields map[string]string, data *mxj.Map)

func Dynamic ¶

func Dynamic(str *string, fields *mxj.Map)

Dynamic includes field value in place of %{key.path} When no field is not found replace with ""

func Gsub ¶

func Gsub(fields []string, data *mxj.Map)

func Join ¶

func Join(fields map[string]string, data *mxj.Map)

func LowerCaseFields ¶

func LowerCaseFields(fields []string, data *mxj.Map)

func Merge ¶

func Merge(fields map[string]string, data *mxj.Map)

func ProcessCommonFields ¶

func ProcessCommonFields(data *mxj.Map, add_fields map[string]interface{}, tags []string, typevalue string)

func ProcessCommonFields2 ¶

func ProcessCommonFields2(data *mxj.Map,
	add_fields map[string]interface{},
	tags []string,
	remove_field []string,
	remove_tag []string)

func RemoveAllButFields ¶

func RemoveAllButFields(fields []string, data *mxj.Map)

func RemoveFields ¶

func RemoveFields(fields []string, data *mxj.Map)

func RemoveTags ¶

func RemoveTags(tags []string, data *mxj.Map)

func RenameFields ¶

func RenameFields(fields map[string]string, data *mxj.Map)

func SetType ¶

func SetType(typevalue string, data *mxj.Map)

func Split ¶

func Split(fields map[string]string, data *mxj.Map)

func Strip ¶

func Strip(fields []string, data *mxj.Map)

func UpdateFields ¶

func UpdateFields(fields map[string]interface{}, data *mxj.Map)

func UpperCaseFields ¶

func UpperCaseFields(fields []string, data *mxj.Map)

Types ¶

type Base ¶

type Base struct {
	Send      veino.PacketSender
	NewPacket veino.PacketBuilder
	Logger    logger
}

func (*Base) Configure ¶

func (b *Base) Configure(ctx veino.ProcessorContext, conf map[string]interface{}) error

func (*Base) ConfigureAndValidate ¶

func (b *Base) ConfigureAndValidate(ctx veino.ProcessorContext, conf map[string]interface{}, rawVal interface{}) error

func (*Base) Receive ¶

func (b *Base) Receive(e veino.IPacket) error

func (*Base) Start ¶

func (b *Base) Start(e veino.IPacket) error

func (*Base) Stop ¶

func (b *Base) Stop(e veino.IPacket) error

func (*Base) Tick ¶

func (b *Base) Tick(e veino.IPacket) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
filter-date
filter-drop Drops everything received	Drops everything received
filter-geoip
filter-grok
filter-json
filter-mutate mutate filter allows to perform general mutations on fields.	mutate filter allows to perform general mutations on fields.
filter-split splitt	splitt
filter-uuid
input-amqp
input-beats
input-elasticsearch
input-exec
input-file
input-httppoller HTTPPoller allows you to call an HTTP Endpoint, decode the output of it into an event	HTTPPoller allows you to call an HTTP Endpoint, decode the output of it into an event
input-imap
input-stdin
input-twitter
output-elasticsearch
output-elasticsearch2
output-file
output-mongodb
output-null Drops everything received	Drops everything received
output-rabbitmq
output-stdout
when void just do nothing with events, so usefull !	void just do nothing with events, so usefull !

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