broker

package

v0.34.5 Latest Latest Go to latest Published: Nov 11, 2022 License: Apache-2.0 Imports: 33 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	BrokerNameKey = "brokerName"
)

This section is empty.

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

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

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

func ControlPlaneTrigger_GivenBroker(brokerName string) *feature.Feature

func ControlPlaneTrigger_GivenBrokerTriggerReady(brokerName string) *feature.Feature

func ControlPlaneTrigger_WithBrokerLifecycle(brokerOpts ...manifest.CfgFn) *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

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(brokerName string) *feature.Feature

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

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

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

func Client(ctx context.Context) *EventingClient