transform

Documentation

Index

• type EventFilterPredicate
• type EventTransformer
  • func (et *EventTransformer) Output(input <-chan watch.Event) <-chan model.Record
• type FilteredWatch
  • func NewFilteredWatch(inputWatch watch.Interface, predicates ...EventFilterPredicate) *FilteredWatch
  • func (fw *FilteredWatch) ResultChan() <-chan watch.Event
  • func (fw *FilteredWatch) Stop()
• type Func
• type RuleSelector

Types

type EventFilterPredicate

type EventFilterPredicate func(event watch.Event) bool

type EventTransformer

type EventTransformer struct {
	RuleSelector RuleSelector
	Rules        map[string]Func
}

func (*EventTransformer) Output

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

type FilteredWatch

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

func NewFilteredWatch

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

func (*FilteredWatch) ResultChan

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

func (*FilteredWatch) Stop

func (fw *FilteredWatch) Stop()

type Func

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

type RuleSelector

type RuleSelector func(event watch.Event) string