processor

Documentation

Index

• Constants
• type Anonymize
  • func NewAnonymize(config *AnonymizeConfig) *Anonymize
  • func (p *Anonymize) Do(record intf.Record) bool
  • func (p *Anonymize) SetChannel(channel chan intf.Record)
  • func (p *Anonymize) SetConfig(config *AnonymizeConfig)
  • func (p *Anonymize) Teardown()
• type AnonymizeConfig
• type Metric
• type Metrics
  • func NewMetrics(config *MetricsConfig) *Metrics
  • func (p *Metrics) Do(record intf.Record) bool
  • func (p *Metrics) SetChannel(channel chan intf.Record)
  • func (p *Metrics) SetConfig(config *MetricsConfig)
  • func (p *Metrics) Setup()
  • func (p *Metrics) Teardown()
• type MetricsConfig
• type Mutate
  • func NewMutate(config *MutateConfig) *Mutate
  • func (p *Mutate) Do(record intf.Record) bool
  • func (p *Mutate) SetChannel(channel chan intf.Record)
  • func (p *Mutate) SetConfig(config *MutateConfig)
  • func (p *Mutate) Setup()
  • func (p *Mutate) Teardown()
• type MutateConfig
  • func (mc *MutateConfig) ParseOperations() []*mutate.Operation

Constants

const FIELDSEP = '.'

Types

type Anonymize

type Anonymize struct {
	// contains filtered or unexported fields
}

func NewAnonymize

func NewAnonymize(config *AnonymizeConfig) *Anonymize

func (*Anonymize) Do

func (p *Anonymize) Do(record intf.Record) bool

func (*Anonymize) SetChannel

func (p *Anonymize) SetChannel(channel chan intf.Record)

Just for match the interface

func (*Anonymize) SetConfig

func (p *Anonymize) SetConfig(config *AnonymizeConfig)

func (*Anonymize) Teardown

func (p *Anonymize) Teardown()

Just for match the interface

type AnonymizeConfig

type AnonymizeConfig struct {
	Fields       string
	Hash         string
	EmailSupport bool
}

type Metric

type Metric interface {
	Process(record intf.Record)
	GetValue() interface{}
	GetField() string
	Reset()
}

type Metrics

type Metrics struct {
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics(config *MetricsConfig) *Metrics

func (*Metrics) Do

func (p *Metrics) Do(record intf.Record) bool

func (*Metrics) SetChannel

func (p *Metrics) SetChannel(channel chan intf.Record)

func (*Metrics) SetConfig

func (p *Metrics) SetConfig(config *MetricsConfig)

func (*Metrics) Setup

func (p *Metrics) Setup()

func (*Metrics) Teardown

func (p *Metrics) Teardown()

type MetricsConfig

type MetricsConfig struct {
	Flush   int
	Metrics string
}

type Mutate

type Mutate struct {
	// contains filtered or unexported fields
}

func NewMutate

func NewMutate(config *MutateConfig) *Mutate

func (*Mutate) Do

func (p *Mutate) Do(record intf.Record) bool

func (*Mutate) SetChannel

func (p *Mutate) SetChannel(channel chan intf.Record)

func (*Mutate) SetConfig

func (p *Mutate) SetConfig(config *MutateConfig)

func (*Mutate) Setup

func (p *Mutate) Setup()

func (*Mutate) Teardown

func (p *Mutate) Teardown()

type MutateConfig

type MutateConfig struct {
	Verbose bool
	Cast    []string
}

func (*MutateConfig) ParseOperations

func (mc *MutateConfig) ParseOperations() []*mutate.Operation