broker

Documentation

Index

• Constants
• func BrokerIngressConformanceFeatures(brokerClass string) []*feature.Feature
• func ControlPlaneBroker(brokerName string) *feature.Feature
• func ControlPlaneConformance(brokerName string) *feature.FeatureSet
• func ControlPlaneDelivery(brokerName string) *feature.Feature
• 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 DataPlaneConformance(brokerName string) *feature.FeatureSet
• func DataPlaneDelivery(brokerName string) *feature.Feature
• func DataPlaneIngress(brokerName string) *feature.Feature
• func DataPlaneObservability(brokerName string) *feature.Feature
• func GoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature
• func SourceToSink(brokerName string) *feature.Feature
• func SourceToSinkWithDLQ(brokerName string) *feature.Feature
• func SourceToSinkWithFlakyDLQ(brokerName string) *feature.Feature
• func TriggerGoesReady(name, brokerName string) *feature.Feature
• type EventingClient
  • func Client(ctx context.Context) *EventingClient

Constants

const (
	BrokerNameKey  = "brokerName"
	TriggerNameKey = "triggerName"
)

Functions

func BrokerIngressConformanceFeatures

func BrokerIngressConformanceFeatures(brokerClass string) []*feature.Feature

func ControlPlaneBroker

func ControlPlaneBroker(brokerName string) *feature.Feature

func ControlPlaneConformance

func ControlPlaneConformance(brokerName string) *feature.FeatureSet

func ControlPlaneDelivery

func ControlPlaneDelivery(brokerName string) *feature.Feature

func ControlPlaneTrigger_GivenBroker

func ControlPlaneTrigger_GivenBroker(brokerName string) *feature.Feature

func ControlPlaneTrigger_GivenBrokerTriggerReady

func ControlPlaneTrigger_GivenBrokerTriggerReady(brokerName string) *feature.Feature

func ControlPlaneTrigger_WithBrokerLifecycle

func ControlPlaneTrigger_WithBrokerLifecycle() *feature.Feature

func ControlPlaneTrigger_WithInvalidFilters

func ControlPlaneTrigger_WithInvalidFilters(brokerName string) *feature.Feature

func ControlPlaneTrigger_WithValidFilters

func ControlPlaneTrigger_WithValidFilters(brokerName string) *feature.Feature

func DataPlaneConformance

func DataPlaneConformance(brokerName string) *feature.FeatureSet

func DataPlaneDelivery

func DataPlaneDelivery(brokerName string) *feature.Feature

func DataPlaneIngress

func DataPlaneIngress(brokerName string) *feature.Feature

func DataPlaneObservability

func DataPlaneObservability(brokerName string) *feature.Feature

func GoesReady

func GoesReady(name string, cfg ...manifest.CfgFn) *feature.Feature

GoesReady returns a feature that will create a Broker of the given name and class, and confirm it becomes ready with an address.

func SourceToSink

func SourceToSink(brokerName string) *feature.Feature

SourceToSink tests to see if a Ready Broker acts as middleware. LoadGenerator --> in [Broker] out --> Recorder

func SourceToSinkWithDLQ

func SourceToSinkWithDLQ(brokerName string) *feature.Feature

SourceToSinkWithDLQ tests to see if a Ready Broker acts as middleware.

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

|
+--[DLQ]--> recorder

func SourceToSinkWithFlakyDLQ

func SourceToSinkWithFlakyDLQ(brokerName string) *feature.Feature

SourceToSinkWithFlakyDLQ tests to see if a Ready Broker acts as middleware.

source ---> broker --trigger--> flake 1/3 --> recorder

|
+--[DLQ]--> recorder

func TriggerGoesReady

func TriggerGoesReady(name, brokerName string) *feature.Feature

TriggerGoesReady returns a feature that tests after the creation of a Trigger, it becomes ready. This feature assumes the Broker already exists.

Types

type EventingClient

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

func Client

func Client(ctx context.Context) *EventingClient