trigger

Documentation

Index

• Constants
• func BadTriggerDoesNotAffectOkTrigger() *feature.Feature
• func Defaulting() *feature.FeatureSet
• func Defaulting_Filter() *feature.Feature
• func Defaulting_SubscriberNamespace() *feature.Feature
• func GetTrigger(ctx context.Context, t feature.T) *eventingv1.Trigger
• func SetTriggerName(name string) feature.StepFn
• func SourceToTriggerSinkWithDLS(triggerName, brokerName string, prober *eventshub.EventProber) *feature.Feature
• func SourceToTriggerSinkWithDLSDontUseBrokers(triggerName, brokerName, brokerSinkName string, prober *eventshub.EventProber) *feature.Feature
• type EventingClient
  • func Client(ctx context.Context) *EventingClient

Constants

const (
	TriggerNameKey = "triggerName"
)

Functions

func BadTriggerDoesNotAffectOkTrigger

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

func SourceToTriggerSinkWithDLS(triggerName, brokerName string, prober *eventshub.EventProber) *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

func SourceToTriggerSinkWithDLSDontUseBrokers(triggerName, brokerName, brokerSinkName string, prober *eventshub.EventProber) *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

Types

type EventingClient

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

func Client

func Client(ctx context.Context) *EventingClient