Documentation
¶
Index ¶
- Constants
- func BrokerStatusDLSURISet(ctx context.Context, t feature.T)
- func ControlPlaneBroker(brokerName string) *feature.Feature
- func ControlPlaneConformance(brokerName string) *feature.FeatureSet
- func ControlPlaneTrigger_GivenBroker(brokerName string) *feature.Feature
- func ControlPlaneTrigger_GivenBrokerTriggerReady(brokerName string) *feature.Feature
- func ControlPlaneTrigger_WithBrokerLifecycle() *feature.Feature
- func ControlPlaneTrigger_WithInvalidFilters(brokerName string) *feature.Feature
- func ControlPlaneTrigger_WithValidFilters(brokerName string) *feature.Feature
- func DataPlaneAddressability(brokerName string) *feature.Feature
- func DataPlaneConformance(brokerName string) *feature.FeatureSet
- func DataPlaneIngress(brokerName string) *feature.Feature
- func DataPlaneObservability(brokerName string) *feature.Feature
- func DefaultDeliverySpec() *feature.Feature
- func GoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature
- func GoesReadyWithProbeReceiver(name, sinkName string, prober *eventshub.EventProber, cfg ...manifest.CfgFn) *feature.Feature
- func SourceToSink(brokerName string) *feature.Feature
- func SourceToSinkWithDLQ() *feature.Feature
- func SourceToSinkWithFlakyDLQ(brokerName string) *feature.Feature
- func TriggerGoesReady(name, brokerName string, cfg ...manifest.CfgFn) *feature.Feature
- type EventingClient
Constants ¶
const (
BrokerNameKey = "brokerName"
)
Variables ¶
This section is empty.
Functions ¶
func BrokerStatusDLSURISet ¶ added in v0.27.0
func ControlPlaneBroker ¶ added in v0.22.0
func ControlPlaneConformance ¶ added in v0.22.0
func ControlPlaneConformance(brokerName string) *feature.FeatureSet
func ControlPlaneTrigger_GivenBroker ¶ added in v0.22.0
func ControlPlaneTrigger_GivenBrokerTriggerReady ¶ added in v0.22.0
func ControlPlaneTrigger_WithBrokerLifecycle ¶ added in v0.22.0
func ControlPlaneTrigger_WithInvalidFilters ¶ added in v0.22.0
func ControlPlaneTrigger_WithValidFilters ¶ added in v0.22.0
func DataPlaneAddressability ¶ added in v0.23.0
func DataPlaneConformance ¶ added in v0.22.0
func DataPlaneConformance(brokerName string) *feature.FeatureSet
func DataPlaneIngress ¶ added in v0.22.0
func DataPlaneObservability ¶ added in v0.22.0
func DefaultDeliverySpec ¶ added in v0.29.0
func GoesReady ¶ added in v0.22.0
GoesReady returns a feature that will create a Broker of the given name and class, and confirm it becomes ready with an address.
func GoesReadyWithProbeReceiver ¶ added in v0.28.0
func GoesReadyWithProbeReceiver(name, sinkName string, prober *eventshub.EventProber, cfg ...manifest.CfgFn) *feature.Feature
GoesReadyWithProbeReceiver returns a feature that will create a Broker of the given name and class, with an event receiver as its DLS and confirm it becomes ready with an address.
func SourceToSink ¶
SourceToSink tests to see if a Ready Broker acts as middleware. LoadGenerator --> in [Broker] out --> Recorder
func SourceToSinkWithDLQ ¶ added in v0.22.0
SourceToSinkWithDLQ tests to see if a Trigger with no DLQ and a bad Sink, subscribed to a Ready Broker, forward unsent events to it's Broker's DLQ
source ---> broker<Via> --trigger--> bad uri
| +--[DLQ]--> dlq
func SourceToSinkWithFlakyDLQ ¶ added in v0.22.0
SourceToSinkWithFlakyDLQ tests to see if a Ready Broker acts as middleware.
source ---> broker --trigger--> flake 1/3 --> recorder
| +--[DLQ]--> recorder
Types ¶
type EventingClient ¶ added in v0.22.0
type EventingClient struct {
Brokers eventingclientsetv1.BrokerInterface
Triggers eventingclientsetv1.TriggerInterface
}
func Client ¶ added in v0.22.0
func Client(ctx context.Context) *EventingClient
Source Files