broker

package
v0.43.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2024 License: Apache-2.0 Imports: 44 Imported by: 1

Documentation

Index

Constants

View Source
const (
	BrokerNameKey = "brokerName"
)

Variables

This section is empty.

Functions

func BrokerDeadLetterSinkExtensions added in v0.36.0

func BrokerDeadLetterSinkExtensions() *feature.FeatureSet

func BrokerDeliverLongMessage added in v0.35.5

func BrokerDeliverLongMessage() *feature.FeatureSet

func BrokerDeliverLongResponseMessage added in v0.35.7

func BrokerDeliverLongResponseMessage() *feature.FeatureSet

func BrokerEventTransformationForTriggerAssert added in v0.43.0

func BrokerEventTransformationForTriggerAssert(f *feature.Feature,
	cfg brokerEventTransformationConfig)

func BrokerEventTransformationForTriggerSetup added in v0.43.0

func BrokerEventTransformationForTriggerSetup(f *feature.Feature) brokerEventTransformationConfig

func BrokerPreferHeaderCheck added in v0.35.0

func BrokerPreferHeaderCheck() *feature.Feature

func BrokerRedelivery added in v0.35.0

func BrokerRedelivery() *feature.FeatureSet

func BrokerSendEventWithOIDC added in v0.40.2

func BrokerSendEventWithOIDC() *feature.FeatureSet

func BrokerSendEventWithOIDCTokenToDLS added in v0.40.2

func BrokerSendEventWithOIDCTokenToDLS() *feature.Feature

func BrokerSendEventWithOIDCTokenToReply added in v0.40.2

func BrokerSendEventWithOIDCTokenToReply() *feature.Feature

func BrokerSendEventWithOIDCTokenToSubscriber added in v0.40.2

func BrokerSendEventWithOIDCTokenToSubscriber() *feature.Feature

func BrokerStatusDLSURISet added in v0.27.0

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

func BrokerWorkFlowWithTransformation added in v0.37.0

func BrokerWorkFlowWithTransformation() *feature.FeatureSet

func ControlPlaneBroker added in v0.22.0

func ControlPlaneBroker(brokerName string, brokerOpts ...manifest.CfgFn) *feature.Feature

func ControlPlaneConformance added in v0.22.0

func ControlPlaneConformance(brokerName string, brokerOpts ...manifest.CfgFn) *feature.FeatureSet

func ControlPlaneTrigger_GivenBroker added in v0.22.0

func ControlPlaneTrigger_GivenBroker(brokerName string) *feature.Feature

func ControlPlaneTrigger_GivenBrokerTriggerReady added in v0.22.0

func ControlPlaneTrigger_GivenBrokerTriggerReady(brokerName string) *feature.Feature

func ControlPlaneTrigger_WithBrokerLifecycle added in v0.22.0

func ControlPlaneTrigger_WithBrokerLifecycle(brokerOpts ...manifest.CfgFn) *feature.Feature

func ControlPlaneTrigger_WithInvalidFilters added in v0.22.0

func ControlPlaneTrigger_WithInvalidFilters(brokerName string) *feature.Feature

func ControlPlaneTrigger_WithValidFilters added in v0.22.0

func ControlPlaneTrigger_WithValidFilters(brokerName string) *feature.Feature

func DataPlaneAddressability added in v0.23.0

func DataPlaneAddressability(brokerName string) *feature.Feature

func DataPlaneConformance added in v0.22.0

func DataPlaneConformance(brokerName string) *feature.FeatureSet

func DataPlaneIngress added in v0.22.0

func DataPlaneIngress(brokerName string) *feature.Feature

func DataPlaneObservability added in v0.22.0

func DataPlaneObservability(brokerName string) *feature.Feature

func DefaultDeliverySpec added in v0.29.0

func DefaultDeliverySpec() *feature.Feature

func GoesReady added in v0.22.0

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 GoesReadyInDifferentNamespace added in v0.42.0

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

func ManyTriggers added in v0.38.0

func ManyTriggers() *feature.FeatureSet

func RotateMTChannelBrokerTLSCertificates added in v0.38.5

func RotateMTChannelBrokerTLSCertificates() *feature.Feature

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 added in v0.22.0

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 added in v0.22.0

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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL