broker

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 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
  • func Client(ctx context.Context) *EventingClient

Constants

const (
	BrokerNameKey = "brokerName"
)

Functions

func BrokerStatusDLSURISet

func BrokerStatusDLSURISet(ctx context.Context, t feature.T)

func ControlPlaneBroker

func ControlPlaneBroker(brokerName string) *feature.Feature

func ControlPlaneConformance

func ControlPlaneConformance(brokerName string) *feature.FeatureSet

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 DataPlaneAddressability

func DataPlaneAddressability(brokerName string) *feature.Feature

func DataPlaneConformance

func DataPlaneConformance(brokerName string) *feature.FeatureSet

func DataPlaneIngress

func DataPlaneIngress(brokerName string) *feature.Feature

func DataPlaneObservability

func DataPlaneObservability(brokerName string) *feature.Feature

func DefaultDeliverySpec

func DefaultDeliverySpec() *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() *feature.Feature

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

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, cfg ...manifest.CfgFn) *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