subscriptionsapi

Documentation

Index

• func CreateSubscriptionsAPIFilters(logger *zap.Logger, filters []v1.SubscriptionsAPIFilter) eventfilter.Filter
• func MaterializeFiltersList(logger *zap.Logger, filters []v1.SubscriptionsAPIFilter) []eventfilter.Filter
• func MaterializeSubscriptionsAPIFilter(logger *zap.Logger, filter v1.SubscriptionsAPIFilter) eventfilter.Filter
• func NewAllFilter(filters ...eventfilter.Filter) eventfilter.Filter
• func NewAnyFilter(filters ...eventfilter.Filter) eventfilter.Filter
• func NewCESQLFilter(expr string) (eventfilter.Filter, error)
• func NewExactFilter(filters map[string]string) (eventfilter.Filter, error)
• func NewNoFilter() eventfilter.Filter
• func NewNotFilter(f eventfilter.Filter) eventfilter.Filter
• func NewPrefixFilter(filters map[string]string) (eventfilter.Filter, error)
• func NewSuffixFilter(filters map[string]string) (eventfilter.Filter, error)
• type FiltersMap
  • func NewFiltersMap() *FiltersMap
  • func (fm *FiltersMap) Delete(trigger *eventingv1.Trigger)
  • func (fm *FiltersMap) Get(trigger *eventingv1.Trigger) (eventfilter.Filter, bool)
  • func (fm *FiltersMap) Set(trigger *eventingv1.Trigger, filter eventfilter.Filter)

Functions

func CreateSubscriptionsAPIFilters

func CreateSubscriptionsAPIFilters(logger *zap.Logger, filters []v1.SubscriptionsAPIFilter) eventfilter.Filter

func MaterializeFiltersList

func MaterializeFiltersList(logger *zap.Logger, filters []v1.SubscriptionsAPIFilter) []eventfilter.Filter

MaterialzieFilterList allows any component that supports `SubscriptionsAPIFilter` to process them

func MaterializeSubscriptionsAPIFilter

func MaterializeSubscriptionsAPIFilter(logger *zap.Logger, filter v1.SubscriptionsAPIFilter) eventfilter.Filter

MaterializeSubscriptionsAPIFilter materializes a SubscriptionsAPIFilter into a runnable Filter.

func NewAllFilter

func NewAllFilter(filters ...eventfilter.Filter) eventfilter.Filter

NewAllFilter returns an event filter which passes if all the contained filters pass

func NewAnyFilter

func NewAnyFilter(filters ...eventfilter.Filter) eventfilter.Filter

NewAnyFilter returns an event filter which passes if any of the contained filters passes.

func NewCESQLFilter

func NewCESQLFilter(expr string) (eventfilter.Filter, error)

NewCESQLFilter returns an event filter which passes if the provided CESQL expression evaluates.

func NewExactFilter

func NewExactFilter(filters map[string]string) (eventfilter.Filter, error)

NewExactFilter returns an event filter which passes if value exactly matches the value of the context attribute in the CloudEvent.

func NewNoFilter

func NewNoFilter() eventfilter.Filter

func NewNotFilter

func NewNotFilter(f eventfilter.Filter) eventfilter.Filter

NewNotFilter returns an event filter which passes if the contained filter fails.

func NewPrefixFilter

func NewPrefixFilter(filters map[string]string) (eventfilter.Filter, error)

NewPrefixFilter returns an event filter which passes if the value of the context attribute in the CloudEvent is prefixed with prefix.

func NewSuffixFilter

func NewSuffixFilter(filters map[string]string) (eventfilter.Filter, error)

NewSuffixFilter returns an event filter which passes if the value of the context attribute in the CloudEvent ends with suffix.

Types

type FiltersMap

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

func NewFiltersMap

func NewFiltersMap() *FiltersMap

func (*FiltersMap) Delete

func (fm *FiltersMap) Delete(trigger *eventingv1.Trigger)

func (*FiltersMap) Get

func (fm *FiltersMap) Get(trigger *eventingv1.Trigger) (eventfilter.Filter, bool)

func (*FiltersMap) Set

func (fm *FiltersMap) Set(trigger *eventingv1.Trigger, filter eventfilter.Filter)