filter

Documentation

Index

• type Filter
  • func NewFilter(log *logrus.Entry, filterType string, aParam []string, ...) (Filter, error)
• type OnlyFilter
  • func (of *OnlyFilter) Filter(in types.Record) (types.Record, error)
• type ReplaceFilter
  • func (rf *ReplaceFilter) Filter(in types.Record) (types.Record, error)
• type SedFilter
  • func (sf *SedFilter) Filter(in types.Record) (types.Record, error)

Types

type Filter

type Filter interface {
	Filter(types.Record) (types.Record, error)
}

Filter provides way to filter record by record.

func NewFilter

func NewFilter(log *logrus.Entry, filterType string, aParam []string, mParam map[string]string) (Filter, error)

NewFilter analyze the config map and return object implemnting Filter of the asked type.

type OnlyFilter

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

OnlyFilter specific type for Only filter operation.

func (*OnlyFilter) Filter

func (of *OnlyFilter) Filter(in types.Record) (types.Record, error)

Filter : Only the content of column by provided values (insert the column if not present).

type ReplaceFilter

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

ReplaceFilter specific type for replace filter operation.

func (*ReplaceFilter) Filter

func (rf *ReplaceFilter) Filter(in types.Record) (types.Record, error)

Filter : replace the content of column by provided values (insert the column if not present).

type SedFilter

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

SedFilter specific type for sed filter operation.

func (*SedFilter) Filter

func (sf *SedFilter) Filter(in types.Record) (types.Record, error)

Filter : Sed the content of column by provided values (insert the column if not present).