broker

package
v0.42.4 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 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 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.