transform

Aug 17, 2018

Changes in this version

+ type EventFilterPredicate func(event watch.Event) bool

+ type EventTransformer struct

+ RuleSelector RuleSelector

+ Rules map[string]Func

+ func (et *EventTransformer) Output(input <-chan watch.Event) <-chan model.Record

+ type FilteredWatch struct

+ func NewFilteredWatch(inputWatch watch.Interface, predicates ...EventFilterPredicate) *FilteredWatch

+ func (fw *FilteredWatch) ResultChan() <-chan watch.Event

+ func (fw *FilteredWatch) Stop()

+ type Func func(event watch.Event) model.Record

+ type RuleSelector func(event watch.Event) string