subscriptionsapi

package
v0.41.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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 added in v0.39.0

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 added in v0.39.0

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

func NewFiltersMap added in v0.39.0

func NewFiltersMap() *FiltersMap

func (*FiltersMap) Delete added in v0.39.0

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

func (*FiltersMap) Get added in v0.39.0

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

func (*FiltersMap) Set added in v0.39.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL