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
Constants ¶
View Source
const (
TriggerNameKey = "triggerName"
)
Variables ¶
This section is empty.
Functions ¶
func BadTriggerDoesNotAffectOkTrigger ¶ added in v0.29.0
source ---> broker +--[trigger<via1>]--> bad uri
| | | +--[trigger<vai2>]--> sink | +--[DLQ]--> dlq
func Defaulting ¶
func Defaulting() *feature.FeatureSet
func Defaulting_Filter ¶
func GetTrigger ¶
func SetTriggerName ¶
func SourceToTriggerSinkWithDLS ¶ added in v0.28.0
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 ¶ added in v0.28.0
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
Click to show internal directories.
Click to hide internal directories.