processor

Documentation

Index

• 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

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
}