trigger

package
v0.41.1 Latest Latest
Warning

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

Go to latest
Published: May 6, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TriggerNameKey = "triggerName"
)

Variables

This section is empty.

Functions

func BadTriggerDoesNotAffectOkTrigger added in v0.29.0

func BadTriggerDoesNotAffectOkTrigger() *feature.Feature

source ---> broker +--[trigger<via1>]--> bad uri

|   |
|   +--[trigger<vai2>]--> sink
|
+--[DLQ]--> dlq

func Defaulting

func Defaulting() *feature.FeatureSet

func Defaulting_Filter

func Defaulting_Filter() *feature.Feature

func Defaulting_SubscriberNamespace

func Defaulting_SubscriberNamespace() *feature.Feature

func GetTrigger

func GetTrigger(ctx context.Context, t feature.T) *eventingv1.Trigger

func SetTriggerName

func SetTriggerName(name string) feature.StepFn

func SourceToTriggerSinkWithDLS added in v0.28.0

func SourceToTriggerSinkWithDLS() *feature.Feature

SourceToTriggerSinkWithDLS tests to see if a Ready Trigger with a DLS defined send failing events to it's DLS.

source ---> broker --trigger--> bad uri

|
+--[DLS]--> sink

func SourceToTriggerSinkWithDLSDontUseBrokers added in v0.28.0

func SourceToTriggerSinkWithDLSDontUseBrokers() *feature.Feature

SourceToTriggerSinkWithDLSDontUseBrokers tests to see if a Ready Trigger sends failing events to it's DLS even when it's corresponding Ready Broker also have a DLS defined.

source ---> broker --trigger--> bad uri

|          |
+--[DLS]   +--[DLS]--> sink

func TriggerDependencyAnnotation added in v0.35.0

func TriggerDependencyAnnotation() *feature.Feature

This test is for avoiding regressions on the trigger dependency annotation functionality.

func TriggerWithTLSSubscriber added in v0.38.0

func TriggerWithTLSSubscriber() *feature.Feature

func TriggerWithTLSSubscriberTrustBundle added in v0.40.0

func TriggerWithTLSSubscriberTrustBundle() *feature.Feature

Types

type EventingClient

type EventingClient struct {
	Brokers  eventingclientsetv1.BrokerInterface
	Triggers eventingclientsetv1.TriggerInterface
}

func Client

func Client(ctx context.Context) *EventingClient

Jump to

Keyboard shortcuts

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